Modifier and Type | Class and Description |
---|---|
class |
ClientConsumerImpl |
Modifier and Type | Method and Description |
---|---|
Set<ClientConsumerInternal> |
ClientSessionImpl.cloneConsumers()
Not part of the interface, used on tests only
|
Modifier and Type | Method and Description |
---|---|
void |
ClientSessionInternal.addConsumer(ClientConsumerInternal consumer) |
void |
ClientSessionImpl.addConsumer(ClientConsumerInternal consumer) |
void |
ClientMessageInternal.onReceipt(ClientConsumerInternal consumer) |
void |
ClientMessageImpl.onReceipt(ClientConsumerInternal consumer) |
void |
ClientSessionInternal.removeConsumer(ClientConsumerInternal consumer) |
void |
ClientSessionImpl.removeConsumer(ClientConsumerInternal consumer) |
Constructor and Description |
---|
LargeMessageControllerImpl(ClientConsumerInternal consumerInternal,
long totalSize,
long readTimeout) |
LargeMessageControllerImpl(ClientConsumerInternal consumerInternal,
long totalSize,
long readTimeout,
File cachedFile) |
LargeMessageControllerImpl(ClientConsumerInternal consumerInternal,
long totalSize,
long readTimeout,
File cachedFile,
int bufferSize) |
Modifier and Type | Method and Description |
---|---|
ClientConsumerInternal |
ActiveMQSessionContext.createConsumer(SimpleString queueName,
SimpleString filterString,
int windowSize,
int maxRate,
int ackBatchSize,
boolean browseOnly,
Executor executor,
Executor flowControlExecutor) |
Modifier and Type | Method and Description |
---|---|
void |
ActiveMQSessionContext.recreateConsumerOnServer(ClientConsumerInternal consumerInternal,
long consumerId,
boolean isSessionStarted) |
Modifier and Type | Method and Description |
---|---|
ClientConsumerInternal |
HornetQClientSessionContext.createConsumer(SimpleString queueName,
SimpleString filterString,
int windowSize,
int maxRate,
int ackBatchSize,
boolean browseOnly,
Executor executor,
Executor flowControlExecutor) |
Modifier and Type | Method and Description |
---|---|
abstract ClientConsumerInternal |
SessionContext.createConsumer(SimpleString queueName,
SimpleString filterString,
int windowSize,
int maxRate,
int ackBatchSize,
boolean browseOnly,
Executor executor,
Executor flowControlExecutor) |
Modifier and Type | Method and Description |
---|---|
abstract void |
SessionContext.recreateConsumerOnServer(ClientConsumerInternal consumerInternal,
long consumerId,
boolean isSessionStarted) |
Copyright © 2018 JBoss by Red Hat. All rights reserved.