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(ActiveMQServer server,
CoreProtocolManager manager,
ServerSession session,
StorageManager storageManager,
Channel channel) |
Modifier and Type | Class and Description |
---|---|
class |
ChannelImpl |
Modifier and Type | Method and Description |
---|---|
Channel |
RemotingConnectionImpl.getChannel(long channelID,
int confWindowSize) |
Channel |
ActiveMQClientProtocolManager.getChannel0() |
Channel |
ActiveMQClientProtocolManager.getChannel1() |
protected Channel |
ActiveMQSessionContext.getSessionChannel() |
Modifier and Type | Method and Description |
---|---|
protected SessionContext |
ActiveMQClientProtocolManager.newSessionContext(String name,
int confirmationWindowSize,
Channel sessionChannel,
CreateSessionResponseMessage response) |
void |
RemotingConnectionImpl.putChannel(long channelID,
Channel channel) |
Constructor and Description |
---|
ActiveMQPacketHandler(CoreProtocolManager protocolManager,
ActiveMQServer server,
Channel channel1,
CoreRemotingConnection connection) |
ActiveMQSessionContext(String name,
RemotingConnection remotingConnection,
Channel sessionChannel,
int serverVersion,
int confirmationWindow) |
CoreSessionCallback(String name,
ProtocolManager protocolManager,
Channel channel,
RemotingConnection connection) |
Modifier and Type | Method and Description |
---|---|
protected SessionContext |
HornetQClientProtocolManager.newSessionContext(String name,
int confirmationWindowSize,
Channel sessionChannel,
CreateSessionResponseMessage response) |
Constructor and Description |
---|
HornetQClientSessionContext(String name,
RemotingConnection remotingConnection,
Channel sessionChannel,
int serverVersion,
int confirmationWindow) |
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 |
ClusterControl.createReplicationChannel()
create a replication channel
|
Modifier and Type | Method and Description |
---|---|
void |
ClusterController.addClusterChannelHandler(Channel channel,
Acceptor acceptorUsed,
CoreRemotingConnection remotingConnection,
Activation activation)
used to set a channel handler on the connection that can be used by the cluster control
|
void |
ClusterManager.addClusterChannelHandler(Channel channel,
Acceptor acceptorUsed,
CoreRemotingConnection remotingConnection,
Activation activation) |
Modifier and Type | Method and Description |
---|---|
ChannelHandler |
Activation.getActivationChannelHandler(Channel channel,
Acceptor acceptorUsed) |
ChannelHandler |
ColocatedActivation.getActivationChannelHandler(Channel channel,
Acceptor acceptorUsed) |
ChannelHandler |
SharedNothingLiveActivation.getActivationChannelHandler(Channel channel,
Acceptor acceptorUsed) |
Copyright © 2019 JBoss by Red Hat. All rights reserved.