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 and Description
HornetQClientProtocolManager()

Method Summary

Modifier and Type	Method and Description
boolean	checkForFailover(String liveNodeID)
protected Packet	newCreateSessionPacket(Version clientVersion, String name, String username, String password, boolean xa, boolean autoCommitSends, boolean autoCommitAcks, boolean preAcknowledge, int minLargeMessageSize, int confirmationWindowSize, long sessionChannelID)
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 Detail

HornetQClientProtocolManager

public HornetQClientProtocolManager()

Method Detail

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(Version clientVersion,
                                        String name,
                                        String username,
                                        String password,
                                        boolean xa,
                                        boolean autoCommitSends,
                                        boolean autoCommitAcks,
                                        boolean preAcknowledge,
                                        int minLargeMessageSize,
                                        int confirmationWindowSize,
                                        long sessionChannelID)

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 liveNodeID)
                         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