Package | Description |
---|---|
org.hornetq.core.client.impl |
Modifier and Type | Class and Description |
---|---|
class |
ClientConsumerImpl |
Modifier and Type | Method and Description |
---|---|
void |
ClientSessionInternal.addConsumer(ClientConsumerInternal consumer) |
void |
DelegatingSession.addConsumer(ClientConsumerInternal consumer) |
void |
ClientMessageInternal.onReceipt(ClientConsumerInternal consumer) |
void |
ClientMessageImpl.onReceipt(ClientConsumerInternal consumer) |
void |
ClientSessionInternal.removeConsumer(ClientConsumerInternal consumer) |
void |
DelegatingSession.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) |
Copyright © 2015 JBoss, a division of Red Hat. All Rights Reserved.