Uses of Interface
org.apache.activemq.artemis.spi.core.protocol.RemotingConnection

Packages that use RemotingConnection

Package	Description
org.apache.activemq.artemis.api.core
org.apache.activemq.artemis.api.core.client
org.apache.activemq.artemis.core.client.impl
org.apache.activemq.artemis.core.management.impl.view
org.apache.activemq.artemis.core.management.impl.view.predicate
org.apache.activemq.artemis.core.protocol.core
org.apache.activemq.artemis.core.protocol.core.impl
org.apache.activemq.artemis.core.protocol.hornetq
org.apache.activemq.artemis.core.protocol.hornetq.client
org.apache.activemq.artemis.core.remoting
org.apache.activemq.artemis.core.remoting.impl.invm
org.apache.activemq.artemis.core.remoting.impl.netty
org.apache.activemq.artemis.core.remoting.server
org.apache.activemq.artemis.core.remoting.server.impl
org.apache.activemq.artemis.core.security
org.apache.activemq.artemis.core.security.impl
org.apache.activemq.artemis.core.server
org.apache.activemq.artemis.core.server.cluster
org.apache.activemq.artemis.core.server.cluster.impl
org.apache.activemq.artemis.core.server.impl
org.apache.activemq.artemis.core.server.plugin
org.apache.activemq.artemis.core.server.plugin.impl
org.apache.activemq.artemis.spi.core.protocol
org.apache.activemq.artemis.spi.core.remoting
org.apache.activemq.artemis.spi.core.security
org.apache.activemq.artemis.spi.core.security.jaas

Uses of RemotingConnection in org.apache.activemq.artemis.api.core

Methods in org.apache.activemq.artemis.api.core with parameters of type RemotingConnection

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

Uses of RemotingConnection in org.apache.activemq.artemis.api.core.client

Methods in org.apache.activemq.artemis.api.core.client that return RemotingConnection

Modifier and Type	Method and Description
RemotingConnection	ClientSessionFactory.getConnection() Returns the code connection used by this session factory.

Methods in org.apache.activemq.artemis.api.core.client with parameters of type RemotingConnection

Modifier and Type	Method and Description
boolean	TopologyMember.isMember(RemotingConnection connection) Returns true if this TopologyMember is the target of this remoting connection

Uses of RemotingConnection in org.apache.activemq.artemis.core.client.impl

Methods in org.apache.activemq.artemis.core.client.impl that return RemotingConnection

Modifier and Type	Method and Description
protected RemotingConnection	ClientSessionFactoryImpl.establishNewConnection()
RemotingConnection	ClientSessionInternal.getConnection()
RemotingConnection	ClientSessionImpl.getConnection()
RemotingConnection	ClientSessionFactoryImpl.getConnection()

Methods in org.apache.activemq.artemis.core.client.impl with parameters of type RemotingConnection

Modifier and Type	Method and Description
TopologyMemberImpl	Topology.getMember(RemotingConnection rc)
void	ClientSessionInternal.handleFailover(RemotingConnection backupConnection, ActiveMQException cause)
void	ClientSessionImpl.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	ClientSessionInternal.preHandleFailover(RemotingConnection connection)
void	ClientSessionImpl.preHandleFailover(RemotingConnection connection)

Constructors in org.apache.activemq.artemis.core.client.impl with parameters of type RemotingConnection

Constructor and Description
CloseRunnable(RemotingConnection conn, String scaleDownTargetNodeID)

Uses of RemotingConnection in org.apache.activemq.artemis.core.management.impl.view

Methods in org.apache.activemq.artemis.core.management.impl.view with parameters of type RemotingConnection

Modifier and Type	Method and Description
Object	ConnectionView.getField(RemotingConnection connection, String fieldName)
JsonObjectBuilder	ConnectionView.toJson(RemotingConnection connection)

Uses of RemotingConnection in org.apache.activemq.artemis.core.management.impl.view.predicate

Methods in org.apache.activemq.artemis.core.management.impl.view.predicate with parameters of type RemotingConnection

Modifier and Type	Method and Description
boolean	ConnectionFilterPredicate.test(RemotingConnection connection)

Uses of RemotingConnection in org.apache.activemq.artemis.core.protocol.core

Subinterfaces of RemotingConnection in org.apache.activemq.artemis.core.protocol.core

Modifier and Type	Interface and Description
interface	CoreRemotingConnection Extension of RemotingConnection for the ActiveMQ Artemis core protocol

Uses of RemotingConnection in org.apache.activemq.artemis.core.protocol.core.impl

Classes in org.apache.activemq.artemis.core.protocol.core.impl that implement RemotingConnection

Modifier and Type	Class and Description
class	RemotingConnectionImpl

Methods in org.apache.activemq.artemis.core.protocol.core.impl that return RemotingConnection

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()

Methods in org.apache.activemq.artemis.core.protocol.core.impl with parameters of type RemotingConnection

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)

Constructors in org.apache.activemq.artemis.core.protocol.core.impl with parameters of type RemotingConnection

Constructor and Description
ActiveMQSessionContext(String name, RemotingConnection remotingConnection, Channel sessionChannel, int serverVersion, int confirmationWindow)
CoreSessionCallback(String name, ProtocolManager protocolManager, Channel channel, RemotingConnection connection)

Uses of RemotingConnection in org.apache.activemq.artemis.core.protocol.hornetq

Methods in org.apache.activemq.artemis.core.protocol.hornetq with parameters of type RemotingConnection

Modifier and Type	Method and Description
boolean	HQPropertiesConversionInterceptor.intercept(Packet packet, RemotingConnection connection)

Uses of RemotingConnection in org.apache.activemq.artemis.core.protocol.hornetq.client

Constructors in org.apache.activemq.artemis.core.protocol.hornetq.client with parameters of type RemotingConnection

Constructor and Description
HornetQClientSessionContext(String name, RemotingConnection remotingConnection, Channel sessionChannel, int serverVersion, int confirmationWindow)

Uses of RemotingConnection in org.apache.activemq.artemis.core.remoting

Methods in org.apache.activemq.artemis.core.remoting with parameters of type RemotingConnection

Modifier and Type	Method and Description
static X509Certificate[]	CertificateUtil.getCertsFromConnection(RemotingConnection remotingConnection)
static Principal	CertificateUtil.getPeerPrincipalFromConnection(RemotingConnection remotingConnection)

Uses of RemotingConnection in org.apache.activemq.artemis.core.remoting.impl.invm

Methods in org.apache.activemq.artemis.core.remoting.impl.invm that return RemotingConnection

Modifier and Type	Method and Description
RemotingConnection	InVMConnection.getProtocolConnection()

Methods in org.apache.activemq.artemis.core.remoting.impl.invm with parameters of type RemotingConnection

Modifier and Type	Method and Description
void	InVMConnection.setProtocolConnection(RemotingConnection connection)

Uses of RemotingConnection in org.apache.activemq.artemis.core.remoting.impl.netty

Methods in org.apache.activemq.artemis.core.remoting.impl.netty that return RemotingConnection

Modifier and Type	Method and Description
RemotingConnection	NettyConnection.getProtocolConnection()

Methods in org.apache.activemq.artemis.core.remoting.impl.netty with parameters of type RemotingConnection

Modifier and Type	Method and Description
void	NettyConnection.setProtocolConnection(RemotingConnection protocolConnection)

Uses of RemotingConnection in org.apache.activemq.artemis.core.remoting.server

Methods in org.apache.activemq.artemis.core.remoting.server that return RemotingConnection

Modifier and Type	Method and Description
RemotingConnection	RemotingService.removeConnection(Object remotingConnectionID) Remove a connection from the connections held by the remoting service.

Methods in org.apache.activemq.artemis.core.remoting.server that return types with arguments of type RemotingConnection

Modifier and Type	Method and Description
Set<RemotingConnection>	RemotingService.getConnections()

Uses of RemotingConnection in org.apache.activemq.artemis.core.remoting.server.impl

Methods in org.apache.activemq.artemis.core.remoting.server.impl that return RemotingConnection

Modifier and Type	Method and Description
RemotingConnection	RemotingServiceImpl.removeConnection(Object remotingConnectionID)

Methods in org.apache.activemq.artemis.core.remoting.server.impl that return types with arguments of type RemotingConnection

Modifier and Type	Method and Description
Set<RemotingConnection>	RemotingServiceImpl.getConnections()

Uses of RemotingConnection in org.apache.activemq.artemis.core.security

Methods in org.apache.activemq.artemis.core.security that return RemotingConnection

Modifier and Type	Method and Description
RemotingConnection	SecurityAuth.getRemotingConnection()

Methods in org.apache.activemq.artemis.core.security with parameters of type RemotingConnection

Modifier and Type	Method and Description
String	SecurityStore.authenticate(String user, String password, RemotingConnection remotingConnection)

Uses of RemotingConnection in org.apache.activemq.artemis.core.security.impl

Methods in org.apache.activemq.artemis.core.security.impl with parameters of type RemotingConnection

Modifier and Type	Method and Description
String	SecurityStoreImpl.authenticate(String user, String password, RemotingConnection connection)

Uses of RemotingConnection in org.apache.activemq.artemis.core.server

Methods in org.apache.activemq.artemis.core.server that return RemotingConnection

Modifier and Type	Method and Description
RemotingConnection	ServerSession.getRemotingConnection()

Methods in org.apache.activemq.artemis.core.server with parameters of type RemotingConnection

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)

Uses of RemotingConnection in org.apache.activemq.artemis.core.server.cluster

Methods in org.apache.activemq.artemis.core.server.cluster that return RemotingConnection

Modifier and Type	Method and Description
RemotingConnection	Bridge.getForwardingConnection()

Methods in org.apache.activemq.artemis.core.server.cluster with parameters of type RemotingConnection

Modifier and Type	Method and Description
boolean	ClusterManager.IncomingInterceptorLookingForExceptionMessage.intercept(Packet packet, RemotingConnection connection)

Uses of RemotingConnection in org.apache.activemq.artemis.core.server.cluster.impl

Methods in org.apache.activemq.artemis.core.server.cluster.impl that return RemotingConnection

Modifier and Type	Method and Description
RemotingConnection	BridgeImpl.getForwardingConnection()

Uses of RemotingConnection in org.apache.activemq.artemis.core.server.impl

Fields in org.apache.activemq.artemis.core.server.impl declared as RemotingConnection

Modifier and Type	Field and Description
protected RemotingConnection	ServerSessionImpl.remotingConnection

Methods in org.apache.activemq.artemis.core.server.impl that return RemotingConnection

Modifier and Type	Method and Description
RemotingConnection	ServerSessionImpl.getRemotingConnection()

Methods in org.apache.activemq.artemis.core.server.impl with parameters of type RemotingConnection

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)

Constructors in org.apache.activemq.artemis.core.server.impl with parameters of type RemotingConnection

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)

Uses of RemotingConnection in org.apache.activemq.artemis.core.server.plugin

Methods in org.apache.activemq.artemis.core.server.plugin with parameters of type RemotingConnection

Modifier and Type	Method and Description
default void	ActiveMQServerPlugin.afterCreateConnection(RemotingConnection connection) A connection has been created.
default void	ActiveMQServerPlugin.afterDestroyConnection(RemotingConnection connection) A connection has been destroyed.
default void	ActiveMQServerPlugin.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.

Uses of RemotingConnection in org.apache.activemq.artemis.core.server.plugin.impl

Methods in org.apache.activemq.artemis.core.server.plugin.impl with parameters of type RemotingConnection

Modifier and Type	Method and Description
void	NotificationActiveMQServerPlugin.afterCreateConnection(RemotingConnection connection)
void	LoggingActiveMQServerPluginLogger.afterCreateConnection(RemotingConnection connection)
void	LoggingActiveMQServerPlugin.afterCreateConnection(RemotingConnection connection) A connection has been created.
void	NotificationActiveMQServerPlugin.afterDestroyConnection(RemotingConnection connection)
void	LoggingActiveMQServerPluginLogger.afterDestroyConnection(RemotingConnection connection)
void	LoggingActiveMQServerPlugin.afterDestroyConnection(RemotingConnection connection) A connection has been destroyed.
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.

Uses of RemotingConnection in org.apache.activemq.artemis.spi.core.protocol

Classes in org.apache.activemq.artemis.spi.core.protocol with type parameters of type RemotingConnection

Modifier and Type	Class and Description
class	AbstractProtocolManager<P,I extends BaseInterceptor<P>,C extends RemotingConnection>

Classes in org.apache.activemq.artemis.spi.core.protocol that implement RemotingConnection

Modifier and Type	Class and Description
class	AbstractRemotingConnection

Fields in org.apache.activemq.artemis.spi.core.protocol declared as RemotingConnection

Modifier and Type	Field and Description
RemotingConnection	ConnectionEntry.connection

Methods in org.apache.activemq.artemis.spi.core.protocol with parameters of type RemotingConnection

Modifier and Type	Method and Description
void	ProtocolManager.handleBuffer(RemotingConnection connection, ActiveMQBuffer buffer)

Constructors in org.apache.activemq.artemis.spi.core.protocol with parameters of type RemotingConnection

Constructor and Description
ConnectionEntry(RemotingConnection connection, Executor connectionExecutor, long lastCheck, long ttl)

Uses of RemotingConnection in org.apache.activemq.artemis.spi.core.remoting

Fields in org.apache.activemq.artemis.spi.core.remoting declared as RemotingConnection

Modifier and Type	Field and Description
protected RemotingConnection	SessionContext.remotingConnection

Methods in org.apache.activemq.artemis.spi.core.remoting that return 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()

Methods in org.apache.activemq.artemis.spi.core.remoting with parameters of type RemotingConnection

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)

Constructors in org.apache.activemq.artemis.spi.core.remoting with parameters of type RemotingConnection

Constructor and Description
SessionContext(RemotingConnection remotingConnection)

Uses of RemotingConnection in org.apache.activemq.artemis.spi.core.security

Methods in org.apache.activemq.artemis.spi.core.security with parameters of type RemotingConnection

Modifier and Type	Method and Description
String	ActiveMQSecurityManager3.validateUser(String user, String password, RemotingConnection remotingConnection) is this a valid user.
String	ActiveMQJAASSecurityManager.validateUser(String user, String password, RemotingConnection remotingConnection)
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.
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	ActiveMQJAASSecurityManager.validateUserAndRole(String user, String password, Set<Role> roles, CheckType checkType, String address, RemotingConnection remotingConnection)

Uses of RemotingConnection in org.apache.activemq.artemis.spi.core.security.jaas

Constructors in org.apache.activemq.artemis.spi.core.security.jaas with parameters of type RemotingConnection

Constructor and Description
JaasCallbackHandler(String username, String password, RemotingConnection remotingConnection)