Modifier and Type | Method and Description |
---|---|
ConsumerContext |
ClientConsumer.getConsumerContext()
The server's ID associated with this consumer.
|
Modifier and Type | Method and Description |
---|---|
ConsumerContext |
ClientConsumerImpl.getConsumerContext() |
Modifier and Type | Method and Description |
---|---|
void |
ClientSessionInternal.handleConsumerDisconnect(ConsumerContext consumerContext) |
void |
ClientSessionImpl.handleConsumerDisconnect(ConsumerContext context) |
void |
ClientSessionInternal.handleReceiveContinuation(ConsumerContext consumerID,
byte[] chunk,
int flowControlSize,
boolean isContinues) |
void |
ClientSessionImpl.handleReceiveContinuation(ConsumerContext consumerID,
byte[] chunk,
int flowControlSize,
boolean isContinues) |
void |
ClientSessionInternal.handleReceiveLargeMessage(ConsumerContext consumerID,
ClientLargeMessageInternal clientLargeMessage,
long largeMessageSize) |
void |
ClientSessionImpl.handleReceiveLargeMessage(ConsumerContext consumerID,
ClientLargeMessageInternal clientLargeMessage,
long largeMessageSize) |
void |
ClientSessionInternal.handleReceiveMessage(ConsumerContext consumerID,
ClientMessageInternal message) |
void |
ClientSessionImpl.handleReceiveMessage(ConsumerContext consumerID,
ClientMessageInternal message) |
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) |
Modifier and Type | Class and Description |
---|---|
class |
ActiveMQConsumerContext |
Modifier and Type | Method and Description |
---|---|
protected void |
SessionContext.handleReceiveContinuation(ConsumerContext consumerID,
byte[] chunk,
int flowControlSize,
boolean isContinues) |
protected void |
SessionContext.handleReceiveLargeMessage(ConsumerContext consumerID,
ClientLargeMessageInternal clientLargeMessage,
long largeMessageSize) |
protected void |
SessionContext.handleReceiveMessage(ConsumerContext consumerID,
ClientMessageInternal message) |
Copyright © 2018 JBoss by Red Hat. All rights reserved.