Package org.apache.activemq.artemis.core.protocol.core.impl

Class ActiveMQClientProtocolManager

java.lang.Object

org.apache.activemq.artemis.core.protocol.core.impl.ActiveMQClientProtocolManager

All Implemented Interfaces:

ClientProtocolManager

Direct Known Subclasses:

HornetQClientProtocolManager

public class ActiveMQClientProtocolManager
extends Object
implements ClientProtocolManager

This class will return specific packets for different types of actions happening on a messaging protocol.

This is trying to unify the Core client into multiple protocols.

Returning null in certain packets means no action is taken on this specific protocol.

Semantic properties could also be added to this implementation.

Implementations of this class need to be stateless.

Field Summary

Fields

Modifier and Type	Field	Description
protected RemotingConnectionImpl	connection
protected TopologyResponseHandler	topologyResponseHandler

Constructor Summary

Constructors

Constructor	Description
ActiveMQClientProtocolManager()

Method Summary

Modifier and Type	Method	Description
void	addChannelHandlers(io.netty.channel.ChannelPipeline pipeline)
boolean	checkForFailover(String nodeID)
boolean	cleanupBeforeFailover(ActiveMQException cause)
RemotingConnection	connect(Connection transportConnection, long callTimeout, long callFailoverTimeout, List<Interceptor> incomingInterceptors, List<Interceptor> outgoingInterceptors, TopologyResponseHandler topologyResponseHandler)
protected PacketDecoder	createPacketDecoder()
SessionContext	createSessionContext(String name, String username, String password, boolean xa, boolean autoCommitSends, boolean autoCommitAcks, boolean preAcknowledge, int minLargeMessageSize, int confirmationWindowSize, String clientID)
SessionContext	createSessionContext(Version clientVersion, String name, String username, String password, boolean xa, boolean autoCommitSends, boolean autoCommitAcks, boolean preAcknowledge, int minLargeMessageSize, int confirmationWindowSize, String clientID)
Channel	getChannel0()
Channel	getChannel1()
RemotingConnection	getCurrentConnection()
String	getName()
ClientSessionFactory	getSessionFactory()
boolean	isAlive()
Lock	lockSessionCreation()
protected Packet	newCreateSessionPacket(int clientVersion, String name, String username, String password, boolean xa, boolean autoCommitSends, boolean autoCommitAcks, boolean preAcknowledge, int minLargeMessageSize, int confirmationWindowSize, long sessionChannelID, String clientID)
protected SessionContext	newSessionContext(String name, int confirmationWindowSize, Channel sessionChannel, CreateSessionResponseMessage response)
void	ping(long connectionTTL)
protected void	sendHandshake(Connection transportConnection)
void	sendSubscribeTopology(boolean isServer)
ActiveMQClientProtocolManager	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.
protected ClusterTopologyChangeMessage	updateTransportConfiguration(ClusterTopologyChangeMessage topMessage)
boolean	waitOnLatch(long milliseconds)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

connection

protected volatile RemotingConnectionImpl connection

topologyResponseHandler

protected TopologyResponseHandler topologyResponseHandler

Constructor Details

ActiveMQClientProtocolManager

public ActiveMQClientProtocolManager()

Method Details

getName

public String getName()

Specified by:

getName in interface ClientProtocolManager

setSessionFactory

public void setSessionFactory(ClientSessionFactory factory)

Specified by:

setSessionFactory in interface ClientProtocolManager

getSessionFactory

public ClientSessionFactory getSessionFactory()

Specified by:

getSessionFactory in interface ClientProtocolManager

addChannelHandlers

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

Specified by:

addChannelHandlers in interface ClientProtocolManager

waitOnLatch

public boolean waitOnLatch(long milliseconds)
                    throws InterruptedException

Specified by:

waitOnLatch in interface ClientProtocolManager

Throws:

InterruptedException

getChannel0

public Channel getChannel0()

getCurrentConnection

public RemotingConnection getCurrentConnection()

Specified by:

getCurrentConnection in interface ClientProtocolManager

getChannel1

public Channel getChannel1()

setExecutor

public ActiveMQClientProtocolManager setExecutor(Executor executor)

Specified by:

setExecutor in interface ClientProtocolManager

lockSessionCreation

public Lock lockSessionCreation()

Specified by:

lockSessionCreation in interface ClientProtocolManager

stop

public void stop()

Description copied from interface: ClientProtocolManager

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

Specified by:

stop in interface ClientProtocolManager

isAlive

public boolean isAlive()

Specified by:

isAlive in interface ClientProtocolManager

ping

public void ping(long connectionTTL)

Specified by:

ping in interface ClientProtocolManager

sendSubscribeTopology

public void sendSubscribeTopology(boolean isServer)

Specified by:

sendSubscribeTopology in interface ClientProtocolManager

createSessionContext

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

Specified by:

createSessionContext in interface ClientProtocolManager

Throws:

ActiveMQException

createSessionContext

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

Throws:

ActiveMQException

newCreateSessionPacket

protected Packet newCreateSessionPacket(int clientVersion,
 String name,
 String username,
 String password,
 boolean xa,
 boolean autoCommitSends,
 boolean autoCommitAcks,
 boolean preAcknowledge,
 int minLargeMessageSize,
 int confirmationWindowSize,
 long sessionChannelID,
 String clientID)

newSessionContext

protected SessionContext newSessionContext(String name,
 int confirmationWindowSize,
 Channel sessionChannel,
 CreateSessionResponseMessage response)

cleanupBeforeFailover

public boolean cleanupBeforeFailover(ActiveMQException cause)

Specified by:

cleanupBeforeFailover in interface ClientProtocolManager

checkForFailover

public boolean checkForFailover(String nodeID)
                         throws ActiveMQException

Specified by:

checkForFailover in interface ClientProtocolManager

Throws:

ActiveMQException

connect

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

Specified by:

connect in interface ClientProtocolManager

sendHandshake

protected void sendHandshake(Connection transportConnection)

updateTransportConfiguration

protected ClusterTopologyChangeMessage updateTransportConfiguration(ClusterTopologyChangeMessage topMessage)

createPacketDecoder

protected PacketDecoder createPacketDecoder()