org.jboss.jms.server.endpoint
Class ServerConnectionFactoryEndpoint

java.lang.Object
  org.jboss.jms.server.endpoint.ServerConnectionFactoryEndpoint

All Implemented Interfaces:

ConnectionFactoryEndpoint

public class ServerConnectionFactoryEndpoint

extends java.lang.Object

implements ConnectionFactoryEndpoint

Concrete implementation of ConnectionFactoryEndpoint

Version:

$Revision: 2717 $ $Id: ServerConnectionFactoryEndpoint.java 2717 2007-05-19 15:36:10Z timfox $

Author:

Ovidiu Feodorov, Tim Fox

Field Summary

protected int	defaultTempQueueDownCacheSize
protected int	defaultTempQueueFullSize
protected int	defaultTempQueuePageSize
protected int	dupsOKBatchSize

Constructor Summary

ServerConnectionFactoryEndpoint(int id, ServerPeer serverPeer, java.lang.String defaultClientID, JNDIBindings jndiBindings, int preFetchSize, int defaultTempQueueFullSize, int defaultTempQueuePageSize, int defaultTempQueueDownCacheSize, int dupsOKBatchSize)

Method Summary

CreateConnectionResult	createConnectionDelegate(java.lang.String username, java.lang.String password, int failedNodeID)
CreateConnectionResult	createConnectionDelegate(java.lang.String username, java.lang.String password, int failedNodeID, java.lang.String remotingSessionID, java.lang.String clientVMID, byte versionToUse, ServerInvokerCallbackHandler callbackHandler)
byte[]	getClientAOPStack()
int	getID()
JNDIBindings	getJNDIBindings()
ServerPeer	getServerPeer()
java.lang.String	toString()
void	updateClusteredClients(ClientConnectionFactoryDelegate[] delegates, java.util.Map failoverMap) Sends a cluster view update message to its associated ClusteredConnectionFactories.

Methods inherited from class java.lang.Object

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

Field Detail

defaultTempQueueFullSize

protected int defaultTempQueueFullSize

defaultTempQueuePageSize

protected int defaultTempQueuePageSize

defaultTempQueueDownCacheSize

protected int defaultTempQueueDownCacheSize

dupsOKBatchSize

protected int dupsOKBatchSize

Constructor Detail

ServerConnectionFactoryEndpoint

public ServerConnectionFactoryEndpoint(int id,
                                       ServerPeer serverPeer,
                                       java.lang.String defaultClientID,
                                       JNDIBindings jndiBindings,
                                       int preFetchSize,
                                       int defaultTempQueueFullSize,
                                       int defaultTempQueuePageSize,
                                       int defaultTempQueueDownCacheSize,
                                       int dupsOKBatchSize)

Parameters:

jndiBindings - - names under which the corresponding JBossConnectionFactory is bound in JNDI.

Method Detail

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

createConnectionDelegate

public CreateConnectionResult createConnectionDelegate(java.lang.String username,
                                                       java.lang.String password,
                                                       int failedNodeID,
                                                       java.lang.String remotingSessionID,
                                                       java.lang.String clientVMID,
                                                       byte versionToUse,
                                                       ServerInvokerCallbackHandler callbackHandler)
                                                throws JMSException

Parameters:

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

Throws:

JMSException

getClientAOPStack

public byte[] getClientAOPStack()
                         throws JMSException

Specified by:

getClientAOPStack in interface ConnectionFactoryEndpoint

Throws:

JMSException

getID

public int getID()

getJNDIBindings

public JNDIBindings getJNDIBindings()

getServerPeer

public ServerPeer getServerPeer()

updateClusteredClients

public void updateClusteredClients(ClientConnectionFactoryDelegate[] delegates,
                                   java.util.Map failoverMap)
                            throws java.lang.Exception

Sends a cluster view update message to its associated ClusteredConnectionFactories. Observation: It is placed here, because if we decide to lock the ServerEndpoint while we send updates, we would need the method here to perform WriteLocks on objects.

Throws:

java.lang.Exception

toString

public java.lang.String toString()