Modifier and Type | Method and Description |
---|---|
protected SessionContext |
ClientSessionFactoryImpl.createSessionChannel(String name,
String username,
String password,
boolean xa,
boolean autoCommitSends,
boolean autoCommitAcks,
boolean preAcknowledge) |
SessionContext |
ClientSessionImpl.getSessionContext() |
SessionContext |
ClientSessionInternal.getSessionContext() |
Modifier and Type | Method and Description |
---|---|
ClientProducerCredits |
ClientProducerCreditManagerImpl.getCredits(SimpleString address,
boolean anon,
SessionContext context) |
ClientProducerCredits |
ClientProducerCreditManager.getCredits(SimpleString address,
boolean anon,
SessionContext context) |
void |
ClientProducerCredits.init(SessionContext sessionContext) |
void |
ClientProducerCreditsImpl.init(SessionContext sessionContext) |
Constructor and Description |
---|
ClientConsumerImpl(ClientSessionInternal session,
ConsumerContext consumerContext,
SimpleString queueName,
SimpleString filterString,
boolean browseOnly,
int clientWindowSize,
int ackBatchSize,
TokenBucketLimiter rateLimiter,
Executor executor,
Executor flowControlExecutor,
SessionContext sessionContext,
ClientSession.QueueQuery queueInfo,
ClassLoader contextClassLoader) |
ClientProducerImpl(ClientSessionInternal session,
SimpleString address,
TokenBucketLimiter rateLimiter,
boolean blockOnNonDurableSend,
boolean blockOnDurableSend,
boolean autoGroup,
SimpleString groupID,
int minLargeMessageSize,
SessionContext sessionContext) |
Modifier and Type | Class and Description |
---|---|
class |
ActiveMQSessionContext |
Modifier and Type | Method and Description |
---|---|
SessionContext |
ActiveMQClientProtocolManager.createSessionContext(String name,
String username,
String password,
boolean xa,
boolean autoCommitSends,
boolean autoCommitAcks,
boolean preAcknowledge,
int minLargeMessageSize,
int confirmationWindowSize) |
SessionContext |
ActiveMQClientProtocolManager.createSessionContext(Version clientVersion,
String name,
String username,
String password,
boolean xa,
boolean autoCommitSends,
boolean autoCommitAcks,
boolean preAcknowledge,
int minLargeMessageSize,
int confirmationWindowSize) |
protected SessionContext |
ActiveMQClientProtocolManager.newSessionContext(String name,
int confirmationWindowSize,
Channel sessionChannel,
CreateSessionResponseMessage response) |
Modifier and Type | Class and Description |
---|---|
class |
HornetQClientSessionContext |
Modifier and Type | Method and Description |
---|---|
protected SessionContext |
HornetQClientProtocolManager.newSessionContext(String name,
int confirmationWindowSize,
Channel sessionChannel,
CreateSessionResponseMessage response) |
Modifier and Type | Method and Description |
---|---|
SessionContext |
ClientProtocolManager.createSessionContext(String name,
String username,
String password,
boolean xa,
boolean autoCommitSends,
boolean autoCommitAcks,
boolean preAcknowledge,
int minLargeMessageSize,
int confirmationWindowSize) |
Copyright © 2016 The Apache Software Foundation. All rights reserved.