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 org.apache.activemq.artemis.core.protocol.core.impl.ActiveMQSessionContext

  • Field Summary

    Fields inherited from class SessionContext

    idGenerator, remotingConnection, sendAckHandler, session

  • Constructor Summary

    Constructors
    Constructor
    Description
    HornetQClientSessionContext(String name, RemotingConnection remotingConnection, org.apache.activemq.artemis.core.protocol.core.Channel sessionChannel, int serverVersion, int confirmationWindow)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    ClientSession.AddressQuery
    addressQuery(SimpleString address)
     
    org.apache.activemq.artemis.core.client.impl.ClientConsumerInternal
    createConsumer(SimpleString queueName, SimpleString filterString, int priority, int windowSize, int maxRate, int ackBatchSize, boolean browseOnly, Executor executor, Executor flowControlExecutor, int onMessageCloseTimeout)
     
    protected org.apache.activemq.artemis.core.protocol.core.impl.wireformat.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, createAddress, createAddress, createProducer, createQueue, createQueue, createQueue, createQueue, createQueue, createSharedQueue, createSharedQueue, createSharedQueue, createSharedQueue, createSharedQueue, deleteQueue, expireMessage, forceDelivery, getConfirmationWindow, getCreditsOnSendingFull, getDefaultConsumerWindowSize, getName, getReconnectID, getSendAcknowledgementHandler, getServerVersion, getSessionChannel, handleReceiveProducerCredits, handleReceiveProducerFailCredits, handleReceiveSlowConsumerKillMessage, isKilled, isWritable, kill, linkFlowControl, lockCommunications, lookupTCCL, reattachOnNewConnection, recoverSessionTimeout, recreateConsumerOnServer, recreateSession, releaseCommunications, removeProducer, resetMetadata, resetName, restartSession, returnBlocking, sendACK, sendConsumerCredits, sendFullMessage, sendInitialChunkOnLargeMessage, sendLargeMessageChunk, sendProducerCreditsMessage, sendServerLargeMessageChunk, sessionClose, sessionStart, sessionStop, setSendAcknowledgementHandler, simpleCommit, simpleCommit, simpleRollback, supportsLargeMessage, transferConnection, xaCommit, xaEnd, xaFailed, xaForget, xaPrepare, xaRollback, xaScan, xaStart

    Methods inherited from class SessionContext

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

    Methods inherited from class Object

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

  • Constructor Details

    • HornetQClientSessionContext

      public HornetQClientSessionContext(String name, RemotingConnection remotingConnection, org.apache.activemq.artemis.core.protocol.core.Channel sessionChannel, int serverVersion, int confirmationWindow)

  • Method Details

    • queueQuery

      public ClientSession.QueueQuery queueQuery(SimpleString queueName) throws ActiveMQException
      Overrides:
      queueQuery in class org.apache.activemq.artemis.core.protocol.core.impl.ActiveMQSessionContext
      Throws:
      ActiveMQException

    • newCreateSession

      protected org.apache.activemq.artemis.core.protocol.core.impl.wireformat.CreateSessionMessage newCreateSession(String username, String password, int minLargeMessageSize, boolean xa, boolean autoCommitSends, boolean autoCommitAcks, boolean preAcknowledge)
      Overrides:
      newCreateSession in class org.apache.activemq.artemis.core.protocol.core.impl.ActiveMQSessionContext

    • addressQuery

      public ClientSession.AddressQuery addressQuery(SimpleString address) throws ActiveMQException
      Overrides:
      addressQuery in class org.apache.activemq.artemis.core.protocol.core.impl.ActiveMQSessionContext
      Throws:
      ActiveMQException

    • createConsumer

      public org.apache.activemq.artemis.core.client.impl.ClientConsumerInternal createConsumer(SimpleString queueName, SimpleString filterString, int priority, int windowSize, int maxRate, int ackBatchSize, boolean browseOnly, Executor executor, Executor flowControlExecutor, int onMessageCloseTimeout) throws ActiveMQException
      Overrides:
      createConsumer in class org.apache.activemq.artemis.core.protocol.core.impl.ActiveMQSessionContext
      Throws:
      ActiveMQException