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 |
ClientSessionImpl.getConnection() |
RemotingConnection |
ClientSessionFactoryImpl.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 |
---|---|
ActiveMQBuffer |
PacketImpl.encode(RemotingConnection connection) |
void |
CoreProtocolManager.handleBuffer(RemotingConnection connection,
ActiveMQBuffer buffer) |
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) |
CoreSessionCallback(String name,
ProtocolManager protocolManager,
Channel channel,
RemotingConnection connection) |
Modifier and Type | Method and Description |
---|---|
ActiveMQBuffer |
SessionSendMessage.encode(RemotingConnection connection) |
ActiveMQBuffer |
SessionReceiveMessage.encode(RemotingConnection connection) |
Modifier and Type | Method and Description |
---|---|
boolean |
HQPropertiesConversionInterceptor.intercept(Packet packet,
RemotingConnection connection) |
Constructor and Description |
---|
HornetQClientSessionContext(String name,
RemotingConnection remotingConnection,
Channel sessionChannel,
int serverVersion,
int confirmationWindow) |
Modifier and Type | Class and Description |
---|---|
class |
ActiveMQProtonRemotingConnection
This is a Server's Connection representation used by ActiveMQ Artemis.
|
Modifier and Type | Method and Description |
---|---|
void |
ProtonProtocolManager.handleBuffer(RemotingConnection connection,
ActiveMQBuffer buffer) |
Modifier and Type | Class and Description |
---|---|
class |
StompConnection |
Modifier and Type | Method and Description |
---|---|
RemotingConnection |
StompSession.getConnection() |
Modifier and Type | Method and Description |
---|---|
void |
StompProtocolManager.handleBuffer(RemotingConnection connection,
ActiveMQBuffer buffer) |
Modifier and Type | Method and Description |
---|---|
RemotingConnection |
InVMConnection.getProtocolConnection() |
Modifier and Type | Method and Description |
---|---|
void |
InVMConnection.setProtocolConnection(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 | Method and Description |
---|---|
RemotingConnection |
RemotingService.removeConnection(Object remotingConnectionID)
Remove a connection from the connections held by the remoting service.
|
Modifier and Type | Method and Description |
---|---|
Set<RemotingConnection> |
RemotingService.getConnections() |
Modifier and Type | Method and Description |
---|---|
RemotingConnection |
RemotingServiceImpl.removeConnection(Object remotingConnectionID) |
Modifier and Type | Method and Description |
---|---|
Set<RemotingConnection> |
RemotingServiceImpl.getConnections() |
Modifier and Type | Method and Description |
---|---|
RemotingConnection |
SecurityAuth.getRemotingConnection() |
Modifier and Type | Method and Description |
---|---|
RemotingConnection |
ServerSession.getRemotingConnection() |
Modifier and Type | Method and Description |
---|---|
ServerSession |
ActiveMQServer.createSession(String name,
String username,
String password,
int minLargeMessageSize,
RemotingConnection remotingConnection,
boolean autoCommitSends,
boolean autoCommitAcks,
boolean preAcknowledge,
boolean xa,
String defaultAddress,
SessionCallback callback,
boolean autoCreateQueues) |
Modifier and Type | Method and Description |
---|---|
RemotingConnection |
Bridge.getForwardingConnection() |
Modifier and Type | Method and Description |
---|---|
boolean |
ClusterManager.IncomingInterceptorLookingForExceptionMessage.intercept(Packet packet,
RemotingConnection connection) |
Modifier and Type | Method and Description |
---|---|
RemotingConnection |
BridgeImpl.getForwardingConnection() |
Modifier and Type | Field and Description |
---|---|
protected RemotingConnection |
ServerSessionImpl.remotingConnection |
Modifier and Type | Method and Description |
---|---|
RemotingConnection |
ServerSessionImpl.getRemotingConnection() |
Modifier and Type | Method and Description |
---|---|
ServerSession |
ActiveMQServerImpl.createSession(String name,
String username,
String password,
int minLargeMessageSize,
RemotingConnection connection,
boolean autoCommitSends,
boolean autoCommitAcks,
boolean preAcknowledge,
boolean xa,
String defaultAddress,
SessionCallback callback,
boolean autoCreateQueues) |
protected ServerSessionImpl |
ActiveMQServerImpl.internalCreateSession(String name,
String username,
String password,
String validatedUser,
int minLargeMessageSize,
RemotingConnection connection,
boolean autoCommitSends,
boolean autoCommitAcks,
boolean preAcknowledge,
boolean xa,
String defaultAddress,
SessionCallback callback,
OperationContext context,
boolean autoCreateJMSQueues) |
Constructor and Description |
---|
ServerSessionImpl(String name,
String username,
String password,
String validatedUser,
int minLargeMessageSize,
boolean autoCommitSends,
boolean autoCommitAcks,
boolean preAcknowledge,
boolean strictUpdateDeliveryCount,
boolean xa,
RemotingConnection remotingConnection,
StorageManager storageManager,
PostOffice postOffice,
ResourceManager resourceManager,
SecurityStore securityStore,
ManagementService managementService,
ActiveMQServer server,
SimpleString managementAddress,
SimpleString defaultAddress,
SessionCallback callback,
OperationContext context,
QueueCreator queueCreator) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractProtocolManager<P,I extends BaseInterceptor<P>,C extends RemotingConnection> |
Modifier and Type | Class and Description |
---|---|
class |
AbstractRemotingConnection |
Modifier and Type | Field and Description |
---|---|
RemotingConnection |
ConnectionEntry.connection |
Modifier and Type | Method and Description |
---|---|
void |
ProtocolManager.handleBuffer(RemotingConnection connection,
ActiveMQBuffer buffer) |
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) |
Modifier and Type | Method and Description |
---|---|
String |
ActiveMQJAASSecurityManager.validateUserAndRole(String user,
String password,
Set<Role> roles,
CheckType checkType,
String address,
RemotingConnection connection) |
String |
ActiveMQSecurityManager3.validateUserAndRole(String user,
String password,
Set<Role> roles,
CheckType checkType,
String address,
RemotingConnection connection)
Determine whether the given user is valid and whether they have
the correct role for the given destination address.
|
boolean |
ActiveMQSecurityManager2.validateUserAndRole(String user,
String password,
Set<Role> roles,
CheckType checkType,
String address,
RemotingConnection connection)
Determine whether the given user is valid and whether they have
the correct role for the given destination address.
|
Copyright © 2016 The Apache Software Foundation. All rights reserved.