| Package | Description |
|---|---|
| org.hornetq.core.client.impl | |
| org.hornetq.utils |
Utilities and helper classes.
|
| Constructor and Description |
|---|
ClientConsumerImpl(ClientSessionInternal session,
long id,
SimpleString queueName,
SimpleString filterString,
boolean browseOnly,
int clientWindowSize,
int ackBatchSize,
TokenBucketLimiter rateLimiter,
Executor executor,
Executor flowControlExecutor,
Channel channel,
SessionQueueQueryResponseMessage queueInfo,
ClassLoader contextClassLoader) |
ClientProducerImpl(ClientSessionInternal session,
SimpleString address,
TokenBucketLimiter rateLimiter,
boolean blockOnNonDurableSend,
boolean blockOnDurableSend,
boolean autoGroup,
SimpleString groupID,
int minLargeMessageSize,
Channel channel) |
| Modifier and Type | Class and Description |
|---|---|
class |
TokenBucketLimiterImpl
A TokenBucketLimiterImpl
|
Copyright © 2012 JBoss by Red Hat. All Rights Reserved.