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 |
---|---|
TopologyMemberImpl |
Topology.getMember(RemotingConnection rc) |
boolean |
ClientSessionImpl.handleFailover(RemotingConnection backupConnection,
ActiveMQException cause) |
boolean |
ClientSessionInternal.handleFailover(RemotingConnection backupConnection,
ActiveMQException cause) |
boolean |
TopologyMemberImpl.isMember(RemotingConnection connection)
We only need to check if the connection point to the same node,
don't need to compare the whole params map.
|
void |
ClientSessionImpl.preHandleFailover(RemotingConnection connection) |
void |
ClientSessionInternal.preHandleFailover(RemotingConnection connection) |
Constructor and Description |
---|
CloseRunnable(RemotingConnection conn,
String scaleDownTargetNodeID) |
Modifier and Type | Class and Description |
---|---|
class |
ManagementRemotingConnection |
Modifier and Type | Method and Description |
---|---|
Object |
ConnectionView.getField(RemotingConnection connection,
String fieldName) |
JsonObjectBuilder |
ConnectionView.toJson(RemotingConnection connection) |
Modifier and Type | Method and Description |
---|---|
boolean |
ConnectionFilterPredicate.test(RemotingConnection connection) |
Modifier and Type | Interface and Description |
---|---|
interface |
CoreRemotingConnection
Extension of RemotingConnection for the ActiveMQ Artemis core protocol
|
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 |
---|---|
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 |
---|---|
boolean |
HQFilterConversionInterceptor.intercept(Packet packet,
RemotingConnection connection) |
boolean |
HQPropertiesConversionInterceptor.intercept(Packet packet,
RemotingConnection connection) |
Constructor and Description |
---|
HornetQClientSessionContext(String name,
RemotingConnection remotingConnection,
Channel sessionChannel,
int serverVersion,
int confirmationWindow) |
Modifier and Type | Method and Description |
---|---|
static X509Certificate[] |
CertificateUtil.getCertsFromConnection(RemotingConnection remotingConnection) |
static Principal |
CertificateUtil.getPeerPrincipalFromConnection(RemotingConnection remotingConnection) |
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 |
---|---|
String |
SecurityStore.authenticate(String user,
String password,
RemotingConnection remotingConnection) |
Modifier and Type | Method and Description |
---|---|
String |
SecurityStoreImpl.authenticate(String user,
String password,
RemotingConnection connection) |
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,
OperationContext context,
Map<SimpleString,RoutingType> prefixes) |
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,
OperationContext context,
Map<SimpleString,RoutingType> prefixes) |
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,
Map<SimpleString,RoutingType> prefixes) |
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,
PagingManager pagingManager,
Map<SimpleString,RoutingType> prefixes) |
Modifier and Type | Method and Description |
---|---|
default void |
ActiveMQServerConnectionPlugin.afterCreateConnection(RemotingConnection connection)
A connection has been created.
|
default void |
ActiveMQServerConnectionPlugin.afterDestroyConnection(RemotingConnection connection)
A connection has been destroyed.
|
default void |
ActiveMQServerSessionPlugin.beforeCreateSession(String name,
String username,
int minLargeMessageSize,
RemotingConnection connection,
boolean autoCommitSends,
boolean autoCommitAcks,
boolean preAcknowledge,
boolean xa,
String defaultAddress,
SessionCallback callback,
boolean autoCreateQueues,
OperationContext context,
Map<SimpleString,RoutingType> prefixes)
Before a session is created.
|
Modifier and Type | Method and Description |
---|---|
void |
LoggingActiveMQServerPlugin.afterCreateConnection(RemotingConnection connection)
A connection has been created.
|
void |
LoggingActiveMQServerPluginLogger.afterCreateConnection(RemotingConnection connection) |
void |
NotificationActiveMQServerPlugin.afterCreateConnection(RemotingConnection connection) |
void |
LoggingActiveMQServerPlugin.afterDestroyConnection(RemotingConnection connection)
A connection has been destroyed.
|
void |
LoggingActiveMQServerPluginLogger.afterDestroyConnection(RemotingConnection connection) |
void |
NotificationActiveMQServerPlugin.afterDestroyConnection(RemotingConnection connection) |
void |
LoggingActiveMQServerPluginLogger.beforeCreateSession(String name,
String username,
int minLargeMessageSize,
RemotingConnection connection,
boolean autoCommitSends,
boolean autoCommitAcks,
boolean preAcknowledge,
boolean xa,
String publicAddress,
OperationContext context) |
void |
LoggingActiveMQServerPlugin.beforeCreateSession(String name,
String username,
int minLargeMessageSize,
RemotingConnection connection,
boolean autoCommitSends,
boolean autoCommitAcks,
boolean preAcknowledge,
boolean xa,
String publicAddress,
SessionCallback callback,
boolean autoCreateQueues,
OperationContext context,
Map<SimpleString,RoutingType> prefixes)
Before a session is created.
|
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 either 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.validateUser(String user,
String password,
RemotingConnection remotingConnection) |
String |
ActiveMQSecurityManager3.validateUser(String user,
String password,
RemotingConnection remotingConnection)
is this a valid user.
|
String |
ActiveMQJAASSecurityManager.validateUserAndRole(String user,
String password,
Set<Role> roles,
CheckType checkType,
String address,
RemotingConnection remotingConnection) |
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.
|
String |
ActiveMQSecurityManager3.validateUserAndRole(String user,
String password,
Set<Role> roles,
CheckType checkType,
String address,
RemotingConnection remotingConnection)
Determine whether the given user is valid and whether they have
the correct role for the given destination address.
|
Constructor and Description |
---|
JaasCallbackHandler(String username,
String password,
RemotingConnection remotingConnection) |
Copyright © 2020 JBoss by Red Hat. All rights reserved.