Package org.apache.activemq.artemis.core.protocol.hornetq.client

Class HornetQClientProtocolManager

java.lang.Object

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

org.apache.activemq.artemis.core.protocol.hornetq.client.HornetQClientProtocolManager

All Implemented Interfaces:

ClientProtocolManager

public class HornetQClientProtocolManager
extends ActiveMQClientProtocolManager

Field Summary

Fields inherited from class org.apache.activemq.artemis.core.protocol.core.impl.ActiveMQClientProtocolManager

connection, topologyResponseHandler

Constructor Summary

Constructors

Constructor	Description
HornetQClientProtocolManager()

Method Summary

Modifier and Type	Method	Description
boolean	checkForFailover(String nodeID)
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)
protected void	sendHandshake(Connection transportConnection)
void	sendSubscribeTopology(boolean isServer)
protected ClusterTopologyChangeMessage	updateTransportConfiguration(ClusterTopologyChangeMessage topMessage)

Methods inherited from class org.apache.activemq.artemis.core.protocol.core.impl.ActiveMQClientProtocolManager

addChannelHandlers, cleanupBeforeFailover, connect, createPacketDecoder, createSessionContext, createSessionContext, getChannel0, getChannel1, getCurrentConnection, getName, getSessionFactory, isAlive, lockSessionCreation, ping, setExecutor, setSessionFactory, stop, waitOnLatch

Methods inherited from class java.lang.Object

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

Constructor Details

HornetQClientProtocolManager

public HornetQClientProtocolManager()

Method Details

sendHandshake

protected void sendHandshake(Connection transportConnection)

Overrides:

sendHandshake in class ActiveMQClientProtocolManager

newSessionContext

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

Overrides:

newSessionContext in class ActiveMQClientProtocolManager

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)

Overrides:

newCreateSessionPacket in class ActiveMQClientProtocolManager

sendSubscribeTopology

public void sendSubscribeTopology(boolean isServer)

Specified by:

sendSubscribeTopology in interface ClientProtocolManager

Overrides:

sendSubscribeTopology in class ActiveMQClientProtocolManager

checkForFailover

public boolean checkForFailover(String nodeID)
                         throws ActiveMQException

Specified by:

checkForFailover in interface ClientProtocolManager

Overrides:

checkForFailover in class ActiveMQClientProtocolManager

Throws:

ActiveMQException

updateTransportConfiguration

protected ClusterTopologyChangeMessage updateTransportConfiguration(ClusterTopologyChangeMessage topMessage)

Overrides:

updateTransportConfiguration in class ActiveMQClientProtocolManager