org.jboss.jms.client.delegate
Class ClientClusteredConnectionFactoryDelegate

java.lang.Object
  org.jboss.jms.client.delegate.ClientClusteredConnectionFactoryDelegate

All Implemented Interfaces:

ConnectionFactoryDelegate, ConnectionFactoryEndpoint, java.io.Serializable

public class ClientClusteredConnectionFactoryDelegate

extends java.lang.Object

implements java.io.Serializable, ConnectionFactoryDelegate

A ClientClusteredConnectionFactoryDelegate. It DOESN'T extend DelegateSupport, because none of DelegateSupport's attributes make sense here: there is no corresponding enpoint on the server, there's no ID, etc. This is just a "shallow" delegate, that in turn delegates to its sub-delegates (ClientConnectionFactoryDelegate instances)

Version:

$Revision: 2740 $ $Id: ClientClusteredConnectionFactoryDelegate.java 2740 2007-05-30 11:36:28Z timfox $

Author:

Ovidiu Feodorov, Clebert Suconic, Tim Fox

See Also:

Serialized Form

Constructor Summary

ClientClusteredConnectionFactoryDelegate(ClientConnectionFactoryDelegate[] delegates, java.util.Map failoverMap, LoadBalancingPolicy loadBalancingPolicy, boolean supportsFailover)

Method Summary

CreateConnectionResult	createConnectionDelegate(java.lang.String username, java.lang.String password, int failedNodeID) This invocation should either be handled by the client-side interceptor chain or by the server-side endpoint.
byte[]	getClientAOPStack()
ClientConnectionFactoryDelegate[]	getDelegates()
java.util.Map	getFailoverMap()
IDBlock	getIdBlock(int size) This invocation should either be handled by the client-side interceptor chain or by the server-side endpoint.
LoadBalancingPolicy	getLoadBalancingPolicy()
boolean	isSupportsFailover()
void	setDelegates(ClientConnectionFactoryDelegate[] dels)
void	setFailoverMap(java.util.Map failoverMap)
java.lang.String	toString()
void	updateFailoverInfo(ClientConnectionFactoryDelegate[] delegates, java.util.Map failoverMap) Method used to update the delegate and failoverMap during viewChange

Methods inherited from class java.lang.Object

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

Constructor Detail

ClientClusteredConnectionFactoryDelegate

public ClientClusteredConnectionFactoryDelegate(ClientConnectionFactoryDelegate[] delegates,
                                                java.util.Map failoverMap,
                                                LoadBalancingPolicy loadBalancingPolicy,
                                                boolean supportsFailover)

Method Detail

getClientAOPStack

public byte[] getClientAOPStack()
                         throws JMSException

Specified by:

getClientAOPStack in interface ConnectionFactoryEndpoint

Throws:

JMSException

createConnectionDelegate

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

This invocation should either be handled by the client-side interceptor chain or by the server-side endpoint.

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

getIdBlock

public IDBlock getIdBlock(int size)
                   throws JMSException

This invocation should either be handled by the client-side interceptor chain or by the server-side endpoint.

Throws:

JMSException

getDelegates

public ClientConnectionFactoryDelegate[] getDelegates()

setDelegates

public void setDelegates(ClientConnectionFactoryDelegate[] dels)

getFailoverMap

public java.util.Map getFailoverMap()

setFailoverMap

public void setFailoverMap(java.util.Map failoverMap)

getLoadBalancingPolicy

public LoadBalancingPolicy getLoadBalancingPolicy()

isSupportsFailover

public boolean isSupportsFailover()

updateFailoverInfo

public void updateFailoverInfo(ClientConnectionFactoryDelegate[] delegates,
                               java.util.Map failoverMap)

Method used to update the delegate and failoverMap during viewChange

toString

public java.lang.String toString()