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

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

addChannelHandlers, checkForFailover, cleanupBeforeFailover, connect, createSessionContext, createSessionContext, getChannel0, getChannel1, getCurrentConnection, getName, getPacketDecoder, getSessionFactory, isAlive, lockSessionCreation, ping, 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