Modifier and Type | Method and Description |
---|---|
boolean |
BaseInterceptor.intercept(P packet,
RemotingConnection connection)
Intercepts a packet which is received before it is sent to the channel
|
Modifier and Type | Method and Description |
---|---|
RemotingConnection |
ClientSessionFactory.getConnection()
Returns the code connection used by this session factory.
|
Modifier and Type | Method and Description |
---|---|
boolean |
TopologyMember.isMember(RemotingConnection connection)
Returns true if this TopologyMember is the target of this remoting connection
|
Modifier and Type | Method and Description |
---|---|
protected RemotingConnection |
ClientSessionFactoryImpl.establishNewConnection() |
RemotingConnection |
ClientSessionFactoryImpl.getConnection() |
RemotingConnection |
ClientSessionImpl.getConnection() |
RemotingConnection |
ClientSessionInternal.getConnection() |
Modifier and Type | Method and Description |
---|---|
void |
ClientSessionImpl.handleFailover(RemotingConnection backupConnection,
ActiveMQException cause) |
void |
ClientSessionInternal.handleFailover(RemotingConnection backupConnection,
ActiveMQException cause) |
boolean |
TopologyMemberImpl.isMember(RemotingConnection connection) |
void |
ClientSessionImpl.preHandleFailover(RemotingConnection connection) |
void |
ClientSessionInternal.preHandleFailover(RemotingConnection connection) |
Constructor and Description |
---|
CloseRunnable(RemotingConnection conn,
String scaleDownTargetNodeID) |
Modifier and Type | Interface and Description |
---|---|
interface |
CoreRemotingConnection
Extension of RemotingConnection for the ActiveMQ Artemis core protocol
|
Modifier and Type | Method and Description |
---|---|
ActiveMQBuffer |
Packet.encode(RemotingConnection connection)
Encodes the packet and returns a
ActiveMQBuffer containing the data |
Modifier and Type | Class and Description |
---|---|
class |
RemotingConnectionImpl |
Modifier and Type | Method and Description |
---|---|
RemotingConnection |
ActiveMQClientProtocolManager.connect(Connection transportConnection,
long callTimeout,
long callFailoverTimeout,
List<Interceptor> incomingInterceptors,
List<Interceptor> outgoingInterceptors,
TopologyResponseHandler topologyResponseHandler) |
RemotingConnection |
ActiveMQClientProtocolManager.getCurrentConnection() |
Modifier and Type | Method and Description |
---|---|
protected ActiveMQBuffer |
PacketImpl.createPacket(RemotingConnection connection) |
ActiveMQBuffer |
PacketImpl.encode(RemotingConnection connection) |
static String |
ChannelImpl.invokeInterceptors(Packet packet,
List<Interceptor> interceptors,
RemotingConnection connection) |
boolean |
ActiveMQSessionContext.reattachOnNewConnection(RemotingConnection newConnection) |
Constructor and Description |
---|
ActiveMQSessionContext(String name,
RemotingConnection remotingConnection,
Channel sessionChannel,
int serverVersion,
int confirmationWindow) |
Modifier and Type | Method and Description |
---|---|
ActiveMQBuffer |
SessionContinuationMessage.encode(RemotingConnection connection) |
ActiveMQBuffer |
SessionSendMessage.encode(RemotingConnection connection) |
ActiveMQBuffer |
SessionReceiveMessage.encode(RemotingConnection connection) |
Modifier and Type | Method and Description |
---|---|
RemotingConnection |
NettyConnection.getProtocolConnection() |
Modifier and Type | Method and Description |
---|---|
void |
NettyConnection.setProtocolConnection(RemotingConnection protocolConnection) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractRemotingConnection |
Modifier and Type | Field and Description |
---|---|
RemotingConnection |
ConnectionEntry.connection |
Constructor and Description |
---|
ConnectionEntry(RemotingConnection connection,
Executor connectionExecutor,
long lastCheck,
long ttl) |
Modifier and Type | Field and Description |
---|---|
protected RemotingConnection |
SessionContext.remotingConnection |
Modifier and Type | Method and Description |
---|---|
RemotingConnection |
ClientProtocolManager.connect(Connection transportConnection,
long callTimeout,
long callFailoverTimeout,
List<Interceptor> incomingInterceptors,
List<Interceptor> outgoingInterceptors,
TopologyResponseHandler topologyResponseHandler) |
RemotingConnection |
ClientProtocolManager.getCurrentConnection() |
RemotingConnection |
Connection.getProtocolConnection() |
RemotingConnection |
SessionContext.getRemotingConnection() |
Modifier and Type | Method and Description |
---|---|
void |
TopologyResponseHandler.nodeDisconnected(RemotingConnection conn,
String nodeID,
String scaleDownTargetNodeID) |
abstract boolean |
SessionContext.reattachOnNewConnection(RemotingConnection newConnection)
it will eather reattach or reconnect, preferably reattaching it.
|
void |
Connection.setProtocolConnection(RemotingConnection connection) |
Constructor and Description |
---|
SessionContext(RemotingConnection remotingConnection) |
Copyright © 2018 The Apache Software Foundation. All Rights Reserved.