|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.jboss.jms.client.remoting.JMSRemotingConnection
public class JMSRemotingConnection
Encapsulates the state and behaviour from jboss remoting needed for a JMS connection. Each JMS connection maintains a single Client instance for invoking on the server.
Field Summary | |
---|---|
static java.lang.String |
CALLBACK_POLL_PERIOD_DEFAULT
|
protected boolean |
failed
|
Constructor Summary | |
---|---|
JMSRemotingConnection(java.lang.String serverLocatorURI,
boolean clientPing,
boolean strictTck)
|
Method Summary | |
---|---|
boolean |
addConnectionListener(ConsolidatedRemotingConnectionListener listener)
|
static void |
addInvokerCallbackHandler(java.lang.Object configurer,
Client client,
java.util.Map initialMetadata,
InvokerLocator serverLocator,
InvokerCallbackHandler invokerCallbackHandler)
Configures and add the invokerCallbackHandler the right way (push or pull). |
void |
addPlainConnectionListener(ConnectionListener listener)
|
static java.util.Map |
createCallbackMetadata(boolean doPushCallbacks,
java.util.Map metadata,
InvokerLocator serverLocator)
Build the configuration we need to use to make sure a callback server works the way we want. |
CallbackManager |
getCallbackManager()
|
ConsolidatedRemotingConnectionListener |
getConnectionListener()
|
Client |
getRemotingClient()
|
boolean |
isFailed()
|
boolean |
isStrictTck()
|
ConsolidatedRemotingConnectionListener |
removeConnectionListener()
May return null, if no connection listener was previously installed. |
void |
removePlainConnectionListener(ConnectionListener listener)
|
void |
setFailed()
Used by the FailoverCommandCenter to mark this remoting connection as "condemned", following a failure detected by either a failed invocation, or the ConnectionListener. |
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 |
Field Detail |
---|
public static final java.lang.String CALLBACK_POLL_PERIOD_DEFAULT
protected boolean failed
Constructor Detail |
---|
public JMSRemotingConnection(java.lang.String serverLocatorURI, boolean clientPing, boolean strictTck) throws java.lang.Exception
java.lang.Exception
Method Detail |
---|
public static java.util.Map createCallbackMetadata(boolean doPushCallbacks, java.util.Map metadata, InvokerLocator serverLocator)
doPushCallbacks
- - whether the callback should be push or pull. For socket transport
allow true push callbacks, with callback Connector. For http transport, simulate push
callbacks.metadata
- - metadata that should be added to the metadata map being created. Can be
null.
public static void addInvokerCallbackHandler(java.lang.Object configurer, Client client, java.util.Map initialMetadata, InvokerLocator serverLocator, InvokerCallbackHandler invokerCallbackHandler) throws java.lang.Throwable
configurer
- - passed for logging purposes only.initialMetadata
- - some initial metadata that we might want to pass along when
registering invoker callback handler.
java.lang.Throwable
public void start() throws java.lang.Throwable
java.lang.Throwable
public void stop()
public Client getRemotingClient()
public CallbackManager getCallbackManager()
public boolean isStrictTck()
public boolean isFailed()
public void setFailed()
public boolean addConnectionListener(ConsolidatedRemotingConnectionListener listener)
public void addPlainConnectionListener(ConnectionListener listener)
public void removePlainConnectionListener(ConnectionListener listener)
public ConsolidatedRemotingConnectionListener getConnectionListener()
public ConsolidatedRemotingConnectionListener removeConnectionListener()
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 |