ClientConsumerImpl(ClientSessionInternal session,
ConsumerContext consumerContext,
org.apache.activemq.artemis.api.core.SimpleString queueName,
org.apache.activemq.artemis.api.core.SimpleString filterString,
boolean browseOnly,
int clientWindowSize,
int ackBatchSize,
TokenBucketLimiter rateLimiter,
Executor executor,
Executor flowControlExecutor,
SessionContext sessionContext,
ClientSession.QueueQuery queueInfo,
ClassLoader contextClassLoader) |
ClientProducerImpl(ClientSessionInternal session,
org.apache.activemq.artemis.api.core.SimpleString address,
TokenBucketLimiter rateLimiter,
boolean blockOnNonDurableSend,
boolean blockOnDurableSend,
boolean autoGroup,
org.apache.activemq.artemis.api.core.SimpleString groupID,
int minLargeMessageSize,
SessionContext sessionContext) |