Modifier and Type | Method and Description |
---|---|
Packet |
ClientPacketDecoder.decode(ActiveMQBuffer in,
CoreRemotingConnection connection) |
Packet |
ServerPacketDecoder.decode(ActiveMQBuffer in,
CoreRemotingConnection connection) |
Packet |
ClientPacketDecoder.decode(byte packetType,
CoreRemotingConnection connection) |
Modifier and Type | Method and Description |
---|---|
CoreRemotingConnection |
Channel.getConnection()
returns the
CoreRemotingConnection being used by the channel |
Modifier and Type | Method and Description |
---|---|
ActiveMQBuffer |
Packet.encode(CoreRemotingConnection connection)
Encodes the packet and returns a
ActiveMQBuffer containing the data |
void |
Channel.transferConnection(CoreRemotingConnection newConnection)
Transfers the connection used by this channel to the one specified.
|
int |
ServerSessionPacketHandler.transferConnection(CoreRemotingConnection newConnection,
int lastReceivedCommandID) |
Modifier and Type | Class and Description |
---|---|
class |
RemotingConnectionImpl |
Modifier and Type | Method and Description |
---|---|
CoreRemotingConnection |
ChannelImpl.getConnection() |
Modifier and Type | Method and Description |
---|---|
protected ActiveMQBuffer |
PacketImpl.createPacket(CoreRemotingConnection connection) |
abstract Packet |
PacketDecoder.decode(ActiveMQBuffer in,
CoreRemotingConnection connection) |
Packet |
PacketDecoder.decode(byte packetType,
CoreRemotingConnection connection) |
ActiveMQBuffer |
PacketImpl.encode(CoreRemotingConnection connection) |
void |
PacketImpl.encodeRest(ActiveMQBuffer buffer,
CoreRemotingConnection coreRemotingConnection) |
void |
ChannelImpl.transferConnection(CoreRemotingConnection newConnection) |
Constructor and Description |
---|
ActiveMQPacketHandler(CoreProtocolManager protocolManager,
ActiveMQServer server,
Channel channel1,
CoreRemotingConnection connection) |
ChannelImpl(CoreRemotingConnection connection,
long id,
int confWindowSize,
List<Interceptor> interceptors) |
Modifier and Type | Method and Description |
---|---|
ActiveMQBuffer |
SessionReceiveMessage_1X.encode(CoreRemotingConnection connection) |
void |
SessionCreateConsumerMessage.encodeRest(ActiveMQBuffer buffer,
CoreRemotingConnection coreRemotingConnection) |
Modifier and Type | Method and Description |
---|---|
void |
RemotingService.freeze(String scaleDownNodeID,
CoreRemotingConnection remotingConnection)
Freezes and then disconnects all connections except the given one and tells the client where else
it might connect (only applicable if server is in a cluster and uses scaleDown-on-failover=true).
|
Modifier and Type | Method and Description |
---|---|
void |
RemotingServiceImpl.freeze(String scaleDownNodeID,
CoreRemotingConnection connectionToKeepOpen) |
Modifier and Type | Method and Description |
---|---|
CoreRemotingConnection |
ReplicationManager.getBackupTransportConnection()
Used while stopping the server to ensure that we freeze communications with the backup.
|
Constructor and Description |
---|
ReplicationManager(ActiveMQServer server,
CoreRemotingConnection remotingConnection,
long timeout,
long initialReplicationSyncTimeout,
ExecutorFactory ioExecutorFactory) |
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 |
---|---|
void |
SharedNothingLiveActivation.startReplication(CoreRemotingConnection rc,
ClusterConnection clusterConnection,
Pair<TransportConfiguration,TransportConfiguration> pair,
boolean isFailBackRequest) |
Copyright © 2021 JBoss by Red Hat. All rights reserved.