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

Class HornetQClientSessionContext

java.lang.Object

org.apache.activemq.artemis.spi.core.remoting.SessionContext

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

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

public class HornetQClientSessionContext
extends ActiveMQSessionContext

Field Summary

Fields inherited from class org.apache.activemq.artemis.spi.core.remoting.SessionContext

idGenerator, remotingConnection, sendAckHandler, session

Constructor Summary

Constructors

Constructor and Description
HornetQClientSessionContext(String name, RemotingConnection remotingConnection, Channel sessionChannel, int serverVersion, int confirmationWindow)

Method Summary

Modifier and Type	Method and Description
ClientSession.AddressQuery	addressQuery(SimpleString address)
ClientConsumerInternal	createConsumer(SimpleString queueName, SimpleString filterString, int windowSize, int maxRate, int ackBatchSize, boolean browseOnly, Executor executor, Executor flowControlExecutor)
protected CreateSessionMessage	newCreateSession(String username, String password, int minLargeMessageSize, boolean xa, boolean autoCommitSends, boolean autoCommitAcks, boolean preAcknowledge)
ClientSession.QueueQuery	queueQuery(SimpleString queueName)

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

addSessionMetadata, addUniqueMetaData, calcWindowSize, cleanup, closeConsumer, configureTransactionTimeout, createQueue, createSharedQueue, deleteQueue, expireMessage, forceDelivery, getConfirmationWindow, getCreditsOnSendingFull, getName, getReconnectID, getServerVersion, getSessionChannel, handleReceiveProducerCredits, handleReceiveProducerFailCredits, handleReceiveSlowConsumerKillMessage, isKilled, isWritable, kill, linkFlowControl, lockCommunications, lookupTCCL, reattachOnNewConnection, recoverSessionTimeout, recreateConsumerOnServer, recreateSession, releaseCommunications, resetMetadata, resetName, restartSession, returnBlocking, sendACK, sendConsumerCredits, sendFullMessage, sendInitialChunkOnLargeMessage, sendLargeMessageChunk, sendProducerCreditsMessage, sendServerLargeMessageChunk, sessionClose, sessionStart, sessionStop, setSendAcknowledgementHandler, simpleCommit, simpleRollback, supportsLargeMessage, xaCommit, xaEnd, xaFailed, xaForget, xaPrepare, xaRollback, xaScan, xaStart

Methods inherited from class org.apache.activemq.artemis.spi.core.remoting.SessionContext

getRemotingConnection, getSession, handleReceiveContinuation, handleReceiveLargeMessage, handleReceiveMessage, handleReceiveProducerCredits, handleReceiveProducerFailCredits, setSession

Methods inherited from class java.lang.Object

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

Constructor Detail

HornetQClientSessionContext

public HornetQClientSessionContext(String name,
                                   RemotingConnection remotingConnection,
                                   Channel sessionChannel,
                                   int serverVersion,
                                   int confirmationWindow)

Method Detail

queueQuery

public ClientSession.QueueQuery queueQuery(SimpleString queueName)
                                    throws ActiveMQException

Overrides:

queueQuery in class ActiveMQSessionContext

Throws:

ActiveMQException

newCreateSession

protected CreateSessionMessage newCreateSession(String username,
                                                String password,
                                                int minLargeMessageSize,
                                                boolean xa,
                                                boolean autoCommitSends,
                                                boolean autoCommitAcks,
                                                boolean preAcknowledge)

Overrides:

newCreateSession in class ActiveMQSessionContext

addressQuery

public ClientSession.AddressQuery addressQuery(SimpleString address)
                                        throws ActiveMQException

Overrides:

addressQuery in class ActiveMQSessionContext

Throws:

ActiveMQException

createConsumer

public ClientConsumerInternal createConsumer(SimpleString queueName,
                                             SimpleString filterString,
                                             int windowSize,
                                             int maxRate,
                                             int ackBatchSize,
                                             boolean browseOnly,
                                             Executor executor,
                                             Executor flowControlExecutor)
                                      throws ActiveMQException

Overrides:

createConsumer in class ActiveMQSessionContext

Throws:

ActiveMQException