Package | Description |
---|---|
org.hornetq.core.client.impl | |
org.hornetq.core.server.cluster.impl |
Modifier and Type | Class and Description |
---|---|
class |
ClientSessionImpl |
class |
DelegatingSession
A DelegatingSession
We wrap the real session, so we can add a finalizer on this and close the session
on GC if it has not already been closed
|
Modifier and Type | Method and Description |
---|---|
ClientSessionInternal |
ClientConsumerInternal.getSession() |
ClientSessionInternal |
ClientConsumerImpl.getSession() |
Modifier and Type | Method and Description |
---|---|
void |
ClientSessionFactoryInternal.removeSession(ClientSessionInternal session,
boolean failingOver) |
void |
ClientSessionFactoryImpl.removeSession(ClientSessionInternal session,
boolean failingOver) |
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) |
ClientProducerCreditManagerImpl(ClientSessionInternal session,
int windowSize) |
ClientProducerCreditsImpl(ClientSessionInternal session,
SimpleString address,
int windowSize) |
ClientProducerImpl(ClientSessionInternal session,
SimpleString address,
TokenBucketLimiter rateLimiter,
boolean blockOnNonDurableSend,
boolean blockOnDurableSend,
boolean autoGroup,
SimpleString groupID,
int minLargeMessageSize,
Channel channel) |
ClientSessionPacketHandler(ClientSessionInternal clientSesssion,
Channel channel) |
DelegatingSession(ClientSessionInternal session) |
Modifier and Type | Field and Description |
---|---|
protected ClientSessionInternal |
BridgeImpl.session |
Copyright © 2012 JBoss by Red Hat. All Rights Reserved.