|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.jboss.jms.server.endpoint.ServerConnectionEndpoint
public class ServerConnectionEndpoint
Concrete implementation of ConnectionEndpoint.
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,
org.jboss.remoting.callback.ServerInvokerCallbackHandler callbackHandler,
int dupsOKBatchSize)
|
Method Summary | |
---|---|
void |
close()
Close the instance |
void |
closeCallbackClient()
|
long |
closing(long sequence)
Tell the instance to prepare to close |
SessionDelegate |
createSessionDelegate(boolean transacted,
int acknowledgmentMode,
boolean isXA)
|
org.jboss.remoting.callback.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 |
---|
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, org.jboss.remoting.callback.ServerInvokerCallbackHandler callbackHandler, int dupsOKBatchSize) throws java.lang.Exception
failedNodeID
- - zero or positive values mean connection creation attempt is result of
failover. Negative values are ignored (mean regular connection creation attempt).
java.lang.Exception
Method Detail |
---|
public SessionDelegate createSessionDelegate(boolean transacted, int acknowledgmentMode, boolean isXA) throws javax.jms.JMSException
createSessionDelegate
in interface ConnectionEndpoint
javax.jms.JMSException
public java.lang.String getClientID() throws javax.jms.JMSException
getClientID
in interface ConnectionEndpoint
javax.jms.JMSException
public void setClientID(java.lang.String clientID) throws javax.jms.JMSException
setClientID
in interface ConnectionEndpoint
javax.jms.JMSException
public void start() throws javax.jms.JMSException
start
in interface ConnectionEndpoint
javax.jms.JMSException
public void stop() throws javax.jms.JMSException
stop
in interface ConnectionEndpoint
javax.jms.JMSException
public void close() throws javax.jms.JMSException
Closeable
close
in interface Closeable
javax.jms.JMSException
public long closing(long sequence) throws javax.jms.JMSException
Closeable
closing
in interface Closeable
javax.jms.JMSException
public void closeCallbackClient()
public void sendTransaction(TransactionRequest request, boolean checkForDuplicates) throws javax.jms.JMSException
sendTransaction
in interface ConnectionEndpoint
javax.jms.JMSException
public MessagingXid[] getPreparedTransactions() throws javax.jms.JMSException
getPreparedTransactions
in interface ConnectionEndpoint
javax.jms.JMSException
public IDBlock getIdBlock(int size) throws javax.jms.JMSException
getIdBlock
in interface ConnectionEndpoint
javax.jms.JMSException
public java.lang.String getUsername()
public java.lang.String getPassword()
public SecurityStore getSecurityManager()
public org.jboss.remoting.callback.ServerInvokerCallbackHandler getCallbackHandler()
public ServerPeer getServerPeer()
public ServerConnectionFactoryEndpoint getConnectionFactoryEndpoint()
public java.util.Collection getSessions()
public java.lang.String toString()
toString
in class java.lang.Object
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |