Interface ClientProtocolManager

public interface ClientProtocolManager

Method Summary

Modifier and Type	Method	Description
void	addChannelHandlers(io.netty.channel.ChannelPipeline pipeline)	Sending methods
boolean	checkForFailover(String nodeID)
boolean	cleanupBeforeFailover(ActiveMQException cause)
RemotingConnection	connect(Connection transportConnection, long callTimeout, long callFailoverTimeout, List<Interceptor> incomingInterceptors, List<Interceptor> outgoingInterceptors, TopologyResponseHandler topologyResponseHandler)	Life Cycle Methods:
SessionContext	createSessionContext(String name, String username, String password, boolean xa, boolean autoCommitSends, boolean autoCommitAcks, boolean preAcknowledge, int minLargeMessageSize, int confirmationWindowSize, String clientID)
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)

Method Details

setExecutor

ClientProtocolManager setExecutor(Executor executor)

connect

RemotingConnection connect(Connection transportConnection,
 long callTimeout,
 long callFailoverTimeout,
 List<Interceptor> incomingInterceptors,
 List<Interceptor> outgoingInterceptors,
 TopologyResponseHandler topologyResponseHandler)

Life Cycle Methods:

getCurrentConnection

RemotingConnection getCurrentConnection()

lockSessionCreation

Lock lockSessionCreation()

waitOnLatch

boolean waitOnLatch(long milliseconds)
             throws InterruptedException

Throws:

InterruptedException

stop

void stop()

This is to be called when a connection failed and we want to interrupt any communication. This used to be called exitLoop at some point o the code.. with a method named causeExit from ClientSessionFactoryImpl

isAlive

boolean isAlive()

addChannelHandlers

void addChannelHandlers(io.netty.channel.ChannelPipeline pipeline)

Sending methods

sendSubscribeTopology

void sendSubscribeTopology(boolean isServer)

ping

void ping(long connectionTTL)

createSessionContext

SessionContext createSessionContext(String name,
 String username,
 String password,
 boolean xa,
 boolean autoCommitSends,
 boolean autoCommitAcks,
 boolean preAcknowledge,
 int minLargeMessageSize,
 int confirmationWindowSize,
 String clientID)
                             throws ActiveMQException

Throws:

ActiveMQException

cleanupBeforeFailover

boolean cleanupBeforeFailover(ActiveMQException cause)

checkForFailover

boolean checkForFailover(String nodeID)
                  throws ActiveMQException

Throws:

ActiveMQException

setSessionFactory

void setSessionFactory(ClientSessionFactory factory)

getSessionFactory

ClientSessionFactory getSessionFactory()

getName

String getName()