org.jboss.jms.client.delegate
Class ClientConnectionFactoryDelegate

java.lang.Object
  org.jboss.jms.client.delegate.DelegateSupport
      org.jboss.jms.client.delegate.ClientConnectionFactoryDelegate

All Implemented Interfaces:

ConnectionFactoryDelegate, ConnectionFactoryEndpoint, java.io.Serializable, Streamable

public class ClientConnectionFactoryDelegate

extends DelegateSupport

implements ConnectionFactoryDelegate, java.io.Serializable

The client-side ConnectionFactory delegate class.

Version:

$Revision: 2686 $ $Id: ClientConnectionFactoryDelegate.java 2686 2007-05-15 08:47:20Z timfox $

Author:

Tim Fox, Ovidiu Feodorov

See Also:

Serialized Form

Field Summary

Fields inherited from class org.jboss.jms.client.delegate.DelegateSupport

client, id, state, version

Constructor Summary

ClientConnectionFactoryDelegate()

ClientConnectionFactoryDelegate(int objectID, int serverID, java.lang.String serverLocatorURI, Version serverVersion, boolean clientPing)

Method Summary

CreateConnectionResult	createConnectionDelegate(java.lang.String username, java.lang.String password, int failedNodeID)
byte[]	getClientAOPStack()
boolean	getClientPing()
int	getServerID()
java.lang.String	getServerLocatorURI()
Version	getServerVersion()
static Version	getVersionToUse(Version connectionVersion)
void	read(java.io.DataInputStream in)
void	synchronizeWith(DelegateSupport newDelegate) During HA events, delegates corresponding to new enpoints on the new server are created and the state of those delegates has to be transfered to the "failed" delegates.
java.lang.String	toString()
void	write(java.io.DataOutputStream out)

Methods inherited from class org.jboss.jms.client.delegate.DelegateSupport

doInvoke, doInvokeOneway, getClient, getID, getName, getState, handleThrowable, setState

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

ClientConnectionFactoryDelegate

public ClientConnectionFactoryDelegate(int objectID,
                                       int serverID,
                                       java.lang.String serverLocatorURI,
                                       Version serverVersion,
                                       boolean clientPing)

ClientConnectionFactoryDelegate

public ClientConnectionFactoryDelegate()

Method Detail

getVersionToUse

public static Version getVersionToUse(Version connectionVersion)

createConnectionDelegate

public CreateConnectionResult createConnectionDelegate(java.lang.String username,
                                                       java.lang.String password,
                                                       int failedNodeID)
                                                throws JMSException

Specified by:

createConnectionDelegate in interface ConnectionFactoryEndpoint

Parameters:

failedNodeID - - zero or positive values mean the connection creation attempt is result of failover. Negative values are ignored (mean regular connection creation attempt).

Throws:

JMSException

getClientAOPStack

public byte[] getClientAOPStack()
                         throws JMSException

Specified by:

getClientAOPStack in interface ConnectionFactoryEndpoint

Throws:

JMSException

toString

public java.lang.String toString()

getServerLocatorURI

public java.lang.String getServerLocatorURI()

getServerID

public int getServerID()

getClientPing

public boolean getClientPing()

getServerVersion

public Version getServerVersion()

synchronizeWith

public void synchronizeWith(DelegateSupport newDelegate)
                     throws java.lang.Exception

Description copied from class: DelegateSupport

During HA events, delegates corresponding to new enpoints on the new server are created and the state of those delegates has to be transfered to the "failed" delegates. For example, a "failed" connection delegate will have to assume the ID of the new connection endpoint, the new RemotingConnection instance, etc.

Overrides:

synchronizeWith in class DelegateSupport

Throws:

java.lang.Exception

read

public void read(java.io.DataInputStream in)
          throws java.lang.Exception

Specified by:

read in interface Streamable

Overrides:

read in class DelegateSupport

Throws:

java.lang.Exception

write

public void write(java.io.DataOutputStream out)
           throws java.lang.Exception

Specified by:

write in interface Streamable

Overrides:

write in class DelegateSupport

Throws:

java.lang.Exception