public interface ClientProtocolManager
Modifier and Type | Method and Description |
---|---|
void |
addChannelHandlers(io.netty.channel.ChannelPipeline pipeline) |
boolean |
checkForFailover(String liveNodeID) |
boolean |
cleanupBeforeFailover(ActiveMQException cause) |
RemotingConnection |
connect(Connection transportConnection,
long callTimeout,
long callFailoverTimeout,
List<Interceptor> incomingInterceptors,
List<Interceptor> outgoingInterceptors,
TopologyResponseHandler topologyResponseHandler) |
SessionContext |
createSessionContext(String name,
String username,
String password,
boolean xa,
boolean autoCommitSends,
boolean autoCommitAcks,
boolean preAcknowledge,
int minLargeMessageSize,
int confirmationWindowSize) |
RemotingConnection |
getCurrentConnection() |
String |
getName() |
ClientSessionFactory |
getSessionFactory() |
boolean |
isAlive() |
Lock |
lockSessionCreation() |
void |
ping(long connectionTTL) |
void |
sendSubscribeTopology(boolean isServer) |
void |
setSessionFactory(ClientSessionFactory factory) |
void |
stop()
This is to be called when a connection failed and we want to interrupt any communication.
|
boolean |
waitOnLatch(long milliseconds) |
RemotingConnection connect(Connection transportConnection, long callTimeout, long callFailoverTimeout, List<Interceptor> incomingInterceptors, List<Interceptor> outgoingInterceptors, TopologyResponseHandler topologyResponseHandler)
RemotingConnection getCurrentConnection()
Lock lockSessionCreation()
boolean waitOnLatch(long milliseconds) throws InterruptedException
InterruptedException
void stop()
boolean isAlive()
void addChannelHandlers(io.netty.channel.ChannelPipeline pipeline)
void sendSubscribeTopology(boolean isServer)
void ping(long connectionTTL)
SessionContext createSessionContext(String name, String username, String password, boolean xa, boolean autoCommitSends, boolean autoCommitAcks, boolean preAcknowledge, int minLargeMessageSize, int confirmationWindowSize) throws ActiveMQException
ActiveMQException
boolean cleanupBeforeFailover(ActiveMQException cause)
boolean checkForFailover(String liveNodeID) throws ActiveMQException
ActiveMQException
void setSessionFactory(ClientSessionFactory factory)
ClientSessionFactory getSessionFactory()
String getName()
Copyright © 2016 JBoss by Red Hat. All rights reserved.