Modifier and Type | Method and Description |
---|---|
Channel |
DelegatingSession.getChannel() |
Channel |
ClientSessionInternal.getChannel() |
Channel |
ClientSessionImpl.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) |
ClientSessionImpl(ClientSessionFactoryInternal sessionFactory,
String name,
String username,
String password,
boolean xa,
boolean autoCommitSends,
boolean autoCommitAcks,
boolean preAcknowledge,
boolean blockOnAcknowledge,
boolean autoGroup,
int ackBatchSize,
int consumerWindowSize,
int consumerMaxRate,
int confirmationWindowSize,
int producerWindowSize,
int producerMaxRate,
boolean blockOnNonDurableSend,
boolean blockOnDurableSend,
boolean cacheLargeMessageClient,
int minLargeMessageSize,
boolean compressLargeMessages,
int initialMessagePacketSize,
String groupID,
CoreRemotingConnection remotingConnection,
int version,
Channel channel,
Executor executor,
Executor flowControlExecutor) |
ClientSessionPacketHandler(ClientSessionInternal clientSesssion,
Channel channel) |
Modifier and Type | Method and Description |
---|---|
Channel |
ServerSessionPacketHandler.getChannel() |
Channel |
CoreRemotingConnection.getChannel(long channelID,
int confWindowSize)
return 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(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 |
---|---|
Channel |
ReplicationEndpointImpl.getChannel() |
Modifier and Type | Method and Description |
---|---|
void |
ReplicationEndpointImpl.setChannel(Channel channel) |
Modifier and Type | Method and Description |
---|---|
ReplicationEndpoint |
HornetQServer.connectToReplicationEndpoint(Channel channel)
The journal at the backup server has to be equivalent as the journal used on the live node.
|
Modifier and Type | Method and Description |
---|---|
ReplicationEndpoint |
HornetQServerImpl.connectToReplicationEndpoint(Channel channel) |
Copyright © 2012 JBoss by Red Hat. All Rights Reserved.