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
-
Field Summary
Fields inherited from class org.apache.activemq.artemis.core.protocol.core.impl.ActiveMQClientProtocolManager
connection, topologyResponseHandler -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionbooleancheckForFailover(String nodeID) protected PacketnewCreateSessionPacket(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 SessionContextnewSessionContext(String name, int confirmationWindowSize, Channel sessionChannel, CreateSessionResponseMessage response) protected voidsendHandshake(Connection transportConnection) voidsendSubscribeTopology(boolean isServer) protected ClusterTopologyChangeMessageMethods 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
-
Constructor Details
-
HornetQClientProtocolManager
public HornetQClientProtocolManager()
-
-
Method Details
-
sendHandshake
- Overrides:
sendHandshakein classActiveMQClientProtocolManager
-
newSessionContext
protected SessionContext newSessionContext(String name, int confirmationWindowSize, Channel sessionChannel, CreateSessionResponseMessage response) - Overrides:
newSessionContextin classActiveMQClientProtocolManager
-
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:
newCreateSessionPacketin classActiveMQClientProtocolManager
-
sendSubscribeTopology
public void sendSubscribeTopology(boolean isServer) - Specified by:
sendSubscribeTopologyin interfaceClientProtocolManager- Overrides:
sendSubscribeTopologyin classActiveMQClientProtocolManager
-
checkForFailover
- Specified by:
checkForFailoverin interfaceClientProtocolManager- Overrides:
checkForFailoverin classActiveMQClientProtocolManager- Throws:
ActiveMQException
-
updateTransportConfiguration
protected ClusterTopologyChangeMessage updateTransportConfiguration(ClusterTopologyChangeMessage topMessage) - Overrides:
updateTransportConfigurationin classActiveMQClientProtocolManager
-