org.jboss.jms.server.endpoint
Class ServerConnectionEndpoint

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

All Implemented Interfaces:

Closeable, ConnectionEndpoint

public class ServerConnectionEndpoint
extends java.lang.Object
implements ConnectionEndpoint

Concrete implementation of ConnectionEndpoint.

Version:

$Revision: 3241 $ $Id: ServerConnectionEndpoint.java 3241 2007-10-25 12:49:33Z timfox $

Author:

Ovidiu Feodorov, Tim Fox

Constructor Summary

ServerConnectionEndpoint(ServerPeer serverPeer, java.lang.String clientID, java.lang.String username, java.lang.String password, int prefetchSize, int defaultTempQueueFullSize, int defaultTempQueuePageSize, int defaultTempQueueDownCacheSize, int failedNodeID, ServerConnectionFactoryEndpoint cfendpoint, java.lang.String remotingSessionID, java.lang.String clientVMID, byte versionToUse, ServerInvokerCallbackHandler callbackHandler, int dupsOKBatchSize)

Method Summary

void	close() Close the instance
long	closing(long sequence) Tell the instance to prepare to close
SessionDelegate	createSessionDelegate(boolean transacted, int acknowledgmentMode, boolean isXA)
ServerInvokerCallbackHandler	getCallbackHandler()
java.lang.String	getClientID()
ServerConnectionFactoryEndpoint	getConnectionFactoryEndpoint()
IDBlock	getIdBlock(int size)
java.lang.String	getPassword()
MessagingXid[]	getPreparedTransactions() Get array of XA transactions in prepared state- This would be used by the transaction manager in recovery or by a tool to apply heuristic decisions to commit or rollback particular transactions
SecurityStore	getSecurityManager()
ServerPeer	getServerPeer()
java.util.Collection	getSessions()
java.lang.String	getUsername()
void	sendTransaction(TransactionRequest request, boolean checkForDuplicates)
void	setClientID(java.lang.String clientID)
void	start()
void	stop()
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

ServerConnectionEndpoint

public ServerConnectionEndpoint(ServerPeer serverPeer,
                                java.lang.String clientID,
                                java.lang.String username,
                                java.lang.String password,
                                int prefetchSize,
                                int defaultTempQueueFullSize,
                                int defaultTempQueuePageSize,
                                int defaultTempQueueDownCacheSize,
                                int failedNodeID,
                                ServerConnectionFactoryEndpoint cfendpoint,
                                java.lang.String remotingSessionID,
                                java.lang.String clientVMID,
                                byte versionToUse,
                                ServerInvokerCallbackHandler callbackHandler,
                                int dupsOKBatchSize)
                         throws java.lang.Exception

Parameters:

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

Throws:

java.lang.Exception

Method Detail

createSessionDelegate

public SessionDelegate createSessionDelegate(boolean transacted,
                                             int acknowledgmentMode,
                                             boolean isXA)
                                      throws JMSException

Specified by:

createSessionDelegate in interface ConnectionEndpoint

Throws:

JMSException

getClientID

public java.lang.String getClientID()
                             throws JMSException

Specified by:

getClientID in interface ConnectionEndpoint

Throws:

JMSException

setClientID

public void setClientID(java.lang.String clientID)
                 throws JMSException

Specified by:

setClientID in interface ConnectionEndpoint

Throws:

JMSException

start

public void start()
           throws JMSException

Specified by:

start in interface ConnectionEndpoint

Throws:

JMSException

stop

public void stop()
          throws JMSException

Specified by:

stop in interface ConnectionEndpoint

Throws:

JMSException

close

public void close()
           throws JMSException

Description copied from interface: Closeable

Close the instance

Specified by:

close in interface Closeable

Throws:

JMSException

closing

public long closing(long sequence)
             throws JMSException

Description copied from interface: Closeable

Tell the instance to prepare to close

Specified by:

closing in interface Closeable

Throws:

JMSException

sendTransaction

public void sendTransaction(TransactionRequest request,
                            boolean checkForDuplicates)
                     throws JMSException

Specified by:

sendTransaction in interface ConnectionEndpoint

Throws:

JMSException

getPreparedTransactions

public MessagingXid[] getPreparedTransactions()
                                       throws JMSException

Get array of XA transactions in prepared state- This would be used by the transaction manager in recovery or by a tool to apply heuristic decisions to commit or rollback particular transactions

Specified by:

getPreparedTransactions in interface ConnectionEndpoint

Throws:

JMSException

getIdBlock

public IDBlock getIdBlock(int size)
                   throws JMSException

Specified by:

getIdBlock in interface ConnectionEndpoint

Throws:

JMSException

getUsername

public java.lang.String getUsername()

getPassword

public java.lang.String getPassword()

getSecurityManager

public SecurityStore getSecurityManager()

getCallbackHandler

public ServerInvokerCallbackHandler getCallbackHandler()

getServerPeer

public ServerPeer getServerPeer()

getConnectionFactoryEndpoint

public ServerConnectionFactoryEndpoint getConnectionFactoryEndpoint()

getSessions

public java.util.Collection getSessions()

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object