public interface ClientProtocolManager
Modifier and Type | Method and Description |
---|---|
void |
addChannelHandlers(io.netty.channel.ChannelPipeline pipeline) |
boolean |
checkForFailover(String liveNodeID) |
boolean |
cleanupBeforeFailover(org.apache.activemq.artemis.api.core.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) |
ClientProtocolManager |
setExecutor(Executor executor) |
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) |
ClientProtocolManager setExecutor(Executor executor)
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 org.apache.activemq.artemis.api.core.ActiveMQException
org.apache.activemq.artemis.api.core.ActiveMQException
boolean cleanupBeforeFailover(org.apache.activemq.artemis.api.core.ActiveMQException cause)
boolean checkForFailover(String liveNodeID) throws org.apache.activemq.artemis.api.core.ActiveMQException
org.apache.activemq.artemis.api.core.ActiveMQException
void setSessionFactory(ClientSessionFactory factory)
ClientSessionFactory getSessionFactory()
String getName()
Copyright © 2021 The Apache Software Foundation. All Rights Reserved.