Package | Description |
---|---|
org.hornetq.core.client.impl | |
org.hornetq.core.protocol.core | |
org.hornetq.core.protocol.core.impl | |
org.hornetq.core.replication | |
org.hornetq.core.server.cluster |
Modifier and Type | Method and Description |
---|---|
Channel |
ClientSessionImpl.getChannel() |
Channel |
DelegatingSession.getChannel() |
Channel |
ClientSessionInternal.getChannel() |
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 | Method and Description |
---|---|
Channel |
ServerSessionPacketHandler.getChannel() |
Channel |
CoreRemotingConnection.getChannel(long channelID,
int confWindowSize)
Returns the channel with the channel id specified.
|
Modifier and Type | Method and Description |
---|---|
void |
CoreRemotingConnection.putChannel(long channelID,
Channel channel)
add the channel with the specified channel id
|
Constructor and Description |
---|
ServerSessionPacketHandler(ServerSession session,
StorageManager storageManager,
Channel channel) |
Modifier and Type | Class and Description |
---|---|
class |
ChannelImpl
A ChannelImpl
|
Modifier and Type | Method and Description |
---|---|
Channel |
RemotingConnectionImpl.getChannel(long channelID,
int confWindowSize) |
Modifier and Type | Method and Description |
---|---|
void |
RemotingConnectionImpl.putChannel(long channelID,
Channel channel) |
Constructor and Description |
---|
CoreSessionCallback(String name,
ProtocolManager protocolManager,
Channel channel) |
HornetQPacketHandler(org.hornetq.core.protocol.core.impl.CoreProtocolManager protocolManager,
HornetQServer server,
Channel channel1,
CoreRemotingConnection connection) |
Modifier and Type | Method and Description |
---|---|
Channel |
ReplicationEndpoint.getChannel() |
Modifier and Type | Method and Description |
---|---|
void |
ReplicationEndpoint.setChannel(Channel channel) |
Modifier and Type | Method and Description |
---|---|
void |
ClusterManager.announceReplicatingBackupToLive(Channel liveChannel,
boolean attemptingFailBack)
XXX HORNETQ-720
|
Copyright © 2017 JBoss, a division of Red Hat. All Rights Reserved.