org.jboss.jms.client.p2p
Class P2PConnectionDelegate

java.lang.Object
  extended byorg.jboss.jms.client.p2p.P2PConnectionDelegate
All Implemented Interfaces:
ConnectionDelegate (src) , Lifecycle (src)

public class P2PConnectionDelegate
extends java.lang.Object
implements ConnectionDelegate (src)

The p2p connection


Constructor Summary
P2PConnectionDelegate(java.lang.String username, java.lang.String password)
           
 
Method Summary
 void channelClosed(Channel arg0)
           
 void channelConnected(Channel arg0)
           
 void channelDisconnected(Channel arg0)
           
 void channelReconnected(Address arg0)
           
 void channelShunned()
           
 void close()
          Close the delegate
 void closing()
          Notify about to close
 SessionDelegate (src) createSession(boolean isXA, boolean transacted, int acknowledgeMode)
          Create a session
 void deleteTempDestination(JBossTemporaryDestination (src)  destination)
          Delete the temporary destination
 void finalize()
           
 java.lang.String getClientID()
          Retrieve the client id
 java.util.Enumeration getJMSXPropertyNames()
          Retrieve the extension property names
 byte[] getState()
           
 void receive(Message message)
           
 void setClientID(java.lang.String id)
          Set the client id
 void setExceptionListener(ExceptionListener (src)  listener)
          Set the exception listener
 void setState(byte[] arg0)
           
 void start()
          Start the connection
 void stop()
          Stop the connection
 
Methods inherited from class java.lang.Object
clone, equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

P2PConnectionDelegate

public P2PConnectionDelegate(java.lang.String username,
                             java.lang.String password)
                      throws JMSException (src) 
Method Detail

close

public void close()
           throws JMSException (src) 
Description copied from interface: Lifecycle (src)
Close the delegate

Specified by:
close in interface Lifecycle (src)
Throws:
JMSException (src) - for any error

closing

public void closing()
             throws JMSException (src) 
Description copied from interface: Lifecycle (src)
Notify about to close

Specified by:
closing in interface Lifecycle (src)
Throws:
JMSException (src) - for any error

createSession

public SessionDelegate (src)  createSession(boolean isXA,
                                     boolean transacted,
                                     int acknowledgeMode)
                              throws JMSException (src) 
Description copied from interface: ConnectionDelegate (src)
Create a session

Specified by:
createSession in interface ConnectionDelegate (src)
Parameters:
transacted - whether the session is transacted
Returns:
the session
Throws:
JMSException (src) - for any error

getClientID

public java.lang.String getClientID()
                             throws JMSException (src) 
Description copied from interface: ConnectionDelegate (src)
Retrieve the client id

Specified by:
getClientID in interface ConnectionDelegate (src)
Returns:
the client id
Throws:
JMSException (src) - for any error

getJMSXPropertyNames

public java.util.Enumeration getJMSXPropertyNames()
                                           throws JMSException (src) 
Description copied from interface: ConnectionDelegate (src)
Retrieve the extension property names

Specified by:
getJMSXPropertyNames in interface ConnectionDelegate (src)
Returns:
an enumeration of extension properties
Throws:
JMSException (src) - for any error

deleteTempDestination

public void deleteTempDestination(JBossTemporaryDestination (src)  destination)
Description copied from interface: ConnectionDelegate (src)
Delete the temporary destination

Specified by:
deleteTempDestination in interface ConnectionDelegate (src)

setClientID

public void setClientID(java.lang.String id)
                 throws JMSException (src) 
Description copied from interface: ConnectionDelegate (src)
Set the client id

Specified by:
setClientID in interface ConnectionDelegate (src)
Parameters:
id - the client id
Throws:
JMSException (src) - for any error

setExceptionListener

public void setExceptionListener(ExceptionListener (src)  listener)
                          throws JMSException (src) 
Description copied from interface: ConnectionDelegate (src)
Set the exception listener

Specified by:
setExceptionListener in interface ConnectionDelegate (src)
Throws:
JMSException (src) - for any error

start

public void start()
           throws JMSException (src) 
Description copied from interface: ConnectionDelegate (src)
Start the connection

Specified by:
start in interface ConnectionDelegate (src)
Throws:
JMSException (src) - for any error

stop

public void stop()
          throws JMSException (src) 
Description copied from interface: ConnectionDelegate (src)
Stop the connection

Specified by:
stop in interface ConnectionDelegate (src)
Throws:
JMSException (src) - for any error

channelClosed

public void channelClosed(Channel arg0)

channelConnected

public void channelConnected(Channel arg0)

channelDisconnected

public void channelDisconnected(Channel arg0)

channelReconnected

public void channelReconnected(Address arg0)

channelShunned

public void channelShunned()

getState

public byte[] getState()

receive

public void receive(Message message)

setState

public void setState(byte[] arg0)

finalize

public void finalize()
              throws java.lang.Throwable
Throws:
java.lang.Throwable