public class HornetQClientSessionContext extends ActiveMQSessionContext
idGenerator, remotingConnection, sendAckHandler, session
Constructor and Description |
---|
HornetQClientSessionContext(String name,
RemotingConnection remotingConnection,
Channel sessionChannel,
int serverVersion,
int confirmationWindow) |
Modifier and Type | Method and Description |
---|---|
ClientSession.AddressQuery |
addressQuery(SimpleString address) |
ClientConsumerInternal |
createConsumer(SimpleString queueName,
SimpleString filterString,
int priority,
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) |
addSessionMetadata, addUniqueMetaData, calcWindowSize, cleanup, closeConsumer, configureTransactionTimeout, createAddress, createAddress, createQueue, createQueue, createQueue, createQueue, createSharedQueue, createSharedQueue, createSharedQueue, createSharedQueue, deleteQueue, expireMessage, forceDelivery, getConfirmationWindow, getCreditsOnSendingFull, getDefaultConsumerWindowSize, 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, simpleCommit, simpleRollback, supportsLargeMessage, xaCommit, xaEnd, xaFailed, xaForget, xaPrepare, xaRollback, xaScan, xaStart
getRemotingConnection, getSession, handleReceiveContinuation, handleReceiveLargeMessage, handleReceiveMessage, handleReceiveProducerCredits, handleReceiveProducerFailCredits, setSession
public HornetQClientSessionContext(String name, RemotingConnection remotingConnection, Channel sessionChannel, int serverVersion, int confirmationWindow)
public ClientSession.QueueQuery queueQuery(SimpleString queueName) throws ActiveMQException
queueQuery
in class ActiveMQSessionContext
ActiveMQException
protected CreateSessionMessage newCreateSession(String username, String password, int minLargeMessageSize, boolean xa, boolean autoCommitSends, boolean autoCommitAcks, boolean preAcknowledge)
newCreateSession
in class ActiveMQSessionContext
public ClientSession.AddressQuery addressQuery(SimpleString address) throws ActiveMQException
addressQuery
in class ActiveMQSessionContext
ActiveMQException
public ClientConsumerInternal createConsumer(SimpleString queueName, SimpleString filterString, int priority, int windowSize, int maxRate, int ackBatchSize, boolean browseOnly, Executor executor, Executor flowControlExecutor) throws ActiveMQException
createConsumer
in class ActiveMQSessionContext
ActiveMQException
Copyright © 2019 JBoss by Red Hat. All rights reserved.