Uses of Interface
org.apache.activemq.artemis.spi.core.protocol.RemotingConnection
-
-
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 Description booleanBaseInterceptor. 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 Description RemotingConnectionClientSessionFactory. 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 Description booleanTopologyMember. 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 Description protected RemotingConnectionClientSessionFactoryImpl. establishNewConnection()RemotingConnectionClientSessionFactoryImpl. getConnection()RemotingConnectionClientSessionImpl. getConnection()RemotingConnectionClientSessionInternal. getConnection()Methods in org.apache.activemq.artemis.core.client.impl with parameters of type RemotingConnection Modifier and Type Method Description TopologyMemberImplTopology. getMember(RemotingConnection rc)booleanClientSessionImpl. handleFailover(RemotingConnection backupConnection, ActiveMQException cause)booleanClientSessionInternal. handleFailover(RemotingConnection backupConnection, ActiveMQException cause)booleanTopologyMemberImpl. 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.voidClientSessionImpl. postHandleFailover(RemotingConnection connection, boolean successful)voidClientSessionInternal. postHandleFailover(RemotingConnection connection, boolean successful)voidClientSessionImpl. preHandleFailover(RemotingConnection connection)voidClientSessionInternal. preHandleFailover(RemotingConnection connection)Constructors in org.apache.activemq.artemis.core.client.impl with parameters of type RemotingConnection Constructor Description CloseRunnable(RemotingConnection conn, DisconnectReason reason, String targetNodeID) -
Uses of RemotingConnection in org.apache.activemq.artemis.core.management.impl
Classes in org.apache.activemq.artemis.core.management.impl that implement RemotingConnection Modifier and Type Class Description classManagementRemotingConnection -
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 Description ObjectConnectionView. getField(RemotingConnection connection, String fieldName)JsonObjectBuilderConnectionView. 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 Description booleanConnectionFilterPredicate. 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 Description interfaceCoreRemotingConnectionExtension 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 Description classRemotingConnectionImplMethods in org.apache.activemq.artemis.core.protocol.core.impl that return RemotingConnection Modifier and Type Method Description RemotingConnectionActiveMQClientProtocolManager. connect(Connection transportConnection, long callTimeout, long callFailoverTimeout, List<Interceptor> incomingInterceptors, List<Interceptor> outgoingInterceptors, TopologyResponseHandler topologyResponseHandler)RemotingConnectionActiveMQClientProtocolManager. getCurrentConnection()Methods in org.apache.activemq.artemis.core.protocol.core.impl with parameters of type RemotingConnection Modifier and Type Method Description voidCoreProtocolManager. handleBuffer(RemotingConnection connection, ActiveMQBuffer buffer)static StringChannelImpl. invokeInterceptors(Packet packet, List<Interceptor> interceptors, RemotingConnection connection)booleanActiveMQSessionContext. reattachOnNewConnection(RemotingConnection newConnection)voidActiveMQSessionContext. transferConnection(RemotingConnection newConnection)Constructors in org.apache.activemq.artemis.core.protocol.core.impl with parameters of type RemotingConnection Constructor 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 Description booleanHQFilterConversionInterceptor. intercept(Packet packet, RemotingConnection connection)booleanHQPropertiesConversionInterceptor. 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 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 Description static X509Certificate[]CertificateUtil. getCertsFromConnection(RemotingConnection remotingConnection)static StringCertificateUtil. getCertSubjectDN(RemotingConnection connection)static PrincipalCertificateUtil. 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 Description RemotingConnectionInVMConnection. getProtocolConnection()Methods in org.apache.activemq.artemis.core.remoting.impl.invm with parameters of type RemotingConnection Modifier and Type Method Description voidInVMConnection. 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 Description RemotingConnectionNettyConnection. getProtocolConnection()Methods in org.apache.activemq.artemis.core.remoting.impl.netty with parameters of type RemotingConnection Modifier and Type Method Description voidNettyConnection. 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 Description RemotingConnectionRemotingService. 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 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 Description RemotingConnectionRemotingServiceImpl. 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 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 Description RemotingConnectionSecurityAuth. getRemotingConnection()Methods in org.apache.activemq.artemis.core.security with parameters of type RemotingConnection Modifier and Type Method Description StringSecurityStore. authenticate(String user, String password, RemotingConnection remotingConnection)StringSecurityStore. authenticate(String user, String password, RemotingConnection remotingConnection, String securityDomain) -
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 Description StringSecurityStoreImpl. authenticate(String user, String password, RemotingConnection connection)StringSecurityStoreImpl. authenticate(String user, String password, RemotingConnection connection, String securityDomain) -
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 Description RemotingConnectionServerSession. getRemotingConnection()Methods in org.apache.activemq.artemis.core.server with parameters of type RemotingConnection Modifier and Type Method Description ServerSessionActiveMQServer. createInternalSession(String name, int minLargeMessageSize, RemotingConnection remotingConnection, boolean autoCommitSends, boolean autoCommitAcks, boolean preAcknowledge, boolean xa, String defaultAddress, SessionCallback callback, boolean autoCreateQueues, OperationContext context, Map<SimpleString,RoutingType> prefixes, String securityDomain)This is to be used in places where security is bypassed, like internal sessions, broker connections, etc...ServerSessionActiveMQServer. 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, String securityDomain, String validatedUser)voidServerSession. transferConnection(RemotingConnection newConnection)StringActiveMQServer. validateUser(String username, String password, RemotingConnection connection, String securityDomain) -
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 Description RemotingConnectionBridge. getForwardingConnection()Methods in org.apache.activemq.artemis.core.server.cluster with parameters of type RemotingConnection Modifier and Type Method Description booleanClusterManager.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 Description RemotingConnectionBridgeImpl. 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 Description protected RemotingConnectionServerSessionImpl. remotingConnectionMethods in org.apache.activemq.artemis.core.server.impl that return RemotingConnection Modifier and Type Method Description RemotingConnectionServerSessionImpl. getRemotingConnection()Methods in org.apache.activemq.artemis.core.server.impl with parameters of type RemotingConnection Modifier and Type Method Description ServerSessionActiveMQServerImpl. createInternalSession(String name, int minLargeMessageSize, RemotingConnection connection, boolean autoCommitSends, boolean autoCommitAcks, boolean preAcknowledge, boolean xa, String defaultAddress, SessionCallback callback, boolean autoCreateQueues, OperationContext context, Map<SimpleString,RoutingType> prefixes, String securityDomain)ServerSessionActiveMQServerImpl. 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, String securityDomain, String validatedUser)protected ServerSessionImplActiveMQServerImpl. 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 autoCreateQueues, Map<SimpleString,RoutingType> prefixes, String securityDomain)voidServerSessionImpl. transferConnection(RemotingConnection newConnection)StringActiveMQServerImpl. validateUser(String username, String password, RemotingConnection connection, String securityDomain)Constructors in org.apache.activemq.artemis.core.server.impl with parameters of type RemotingConnection Constructor 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, String securityDomain) -
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 Description default voidActiveMQServerConnectionPlugin. afterCreateConnection(RemotingConnection connection)A connection has been created.default voidActiveMQServerConnectionPlugin. afterDestroyConnection(RemotingConnection connection)A connection has been destroyed.default voidActiveMQServerResourcePlugin. afterPutTransaction(Xid xid, Transaction tx, RemotingConnection remotingConnection)After a transaction is putdefault voidActiveMQServerResourcePlugin. afterRemoveTransaction(Xid xid, RemotingConnection remotingConnection)After a transaction is removeddefault voidActiveMQServerSessionPlugin. 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.default voidActiveMQServerResourcePlugin. beforePutTransaction(Xid xid, Transaction tx, RemotingConnection remotingConnection)Before a transaction is putdefault voidActiveMQServerResourcePlugin. beforeRemoveTransaction(Xid xid, RemotingConnection remotingConnection)Before a transaction is removed -
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 Description voidLoggingActiveMQServerPlugin. afterCreateConnection(RemotingConnection connection)A connection has been created.voidLoggingActiveMQServerPluginLogger_$logger. afterCreateConnection(RemotingConnection connection)voidLoggingActiveMQServerPluginLogger. afterCreateConnection(RemotingConnection connection)voidNotificationActiveMQServerPlugin. afterCreateConnection(RemotingConnection connection)voidLoggingActiveMQServerPlugin. afterDestroyConnection(RemotingConnection connection)A connection has been destroyed.voidLoggingActiveMQServerPluginLogger_$logger. afterDestroyConnection(RemotingConnection connection)voidLoggingActiveMQServerPluginLogger. afterDestroyConnection(RemotingConnection connection)voidNotificationActiveMQServerPlugin. afterDestroyConnection(RemotingConnection connection)voidLoggingActiveMQServerPlugin. 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.voidLoggingActiveMQServerPluginLogger_$logger. beforeCreateSession(String name, String username, int minLargeMessageSize, RemotingConnection connection, boolean autoCommitSends, boolean autoCommitAcks, boolean preAcknowledge, boolean xa, String publicAddress)voidLoggingActiveMQServerPluginLogger. beforeCreateSession(String name, String username, int minLargeMessageSize, RemotingConnection connection, boolean autoCommitSends, boolean autoCommitAcks, boolean preAcknowledge, boolean xa, String publicAddress) -
Uses of RemotingConnection in org.apache.activemq.artemis.core.server.routing
Methods in org.apache.activemq.artemis.core.server.routing that return RemotingConnection Modifier and Type Method Description RemotingConnectionRoutingContext. getConnection()Constructors in org.apache.activemq.artemis.core.server.routing with parameters of type RemotingConnection Constructor Description RoutingContext(RemotingConnection connection, String clientID, String username) -
Uses of RemotingConnection in org.apache.activemq.artemis.core.transaction
Methods in org.apache.activemq.artemis.core.transaction with parameters of type RemotingConnection Modifier and Type Method Description booleanResourceManager. putTransaction(Xid xid, Transaction tx, RemotingConnection remotingConnection)TransactionResourceManager. removeTransaction(Xid xid, RemotingConnection remotingConnection) -
Uses of RemotingConnection in org.apache.activemq.artemis.core.transaction.impl
Methods in org.apache.activemq.artemis.core.transaction.impl with parameters of type RemotingConnection Modifier and Type Method Description booleanResourceManagerImpl. putTransaction(Xid xid, Transaction tx, RemotingConnection remotingConnection)TransactionResourceManagerImpl. removeTransaction(Xid xid, RemotingConnection remotingConnection) -
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 Description classAbstractProtocolManager<P,I extends BaseInterceptor<P>,C extends RemotingConnection,R extends RoutingHandler>Classes in org.apache.activemq.artemis.spi.core.protocol that implement RemotingConnection Modifier and Type Class Description classAbstractRemotingConnectionFields in org.apache.activemq.artemis.spi.core.protocol declared as RemotingConnection Modifier and Type Field Description RemotingConnectionConnectionEntry. connectionMethods in org.apache.activemq.artemis.spi.core.protocol with parameters of type RemotingConnection Modifier and Type Method Description voidProtocolManager. handleBuffer(RemotingConnection connection, ActiveMQBuffer buffer)Constructors in org.apache.activemq.artemis.spi.core.protocol with parameters of type RemotingConnection Constructor 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 Description protected RemotingConnectionSessionContext. remotingConnectionMethods in org.apache.activemq.artemis.spi.core.remoting that return RemotingConnection Modifier and Type Method Description RemotingConnectionClientProtocolManager. connect(Connection transportConnection, long callTimeout, long callFailoverTimeout, List<Interceptor> incomingInterceptors, List<Interceptor> outgoingInterceptors, TopologyResponseHandler topologyResponseHandler)RemotingConnectionClientProtocolManager. getCurrentConnection()RemotingConnectionConnection. getProtocolConnection()RemotingConnectionSessionContext. getRemotingConnection()Methods in org.apache.activemq.artemis.spi.core.remoting with parameters of type RemotingConnection Modifier and Type Method Description voidTopologyResponseHandler. nodeDisconnected(RemotingConnection conn, String nodeID, DisconnectReason reason, String targetNodeID, TransportConfiguration tagetConnector)abstract booleanSessionContext. reattachOnNewConnection(RemotingConnection newConnection)it will either reattach or reconnect, preferably reattaching it.voidConnection. setProtocolConnection(RemotingConnection connection)abstract voidSessionContext. transferConnection(RemotingConnection newConnection)Transfers the session context to the given newConnection on the client-sideConstructors in org.apache.activemq.artemis.spi.core.remoting with parameters of type RemotingConnection Constructor 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 Description SubjectActiveMQBasicSecurityManager. authenticate(String userToAuthenticate, String passwordToAuthenticate, RemotingConnection remotingConnection, String securityDomain)SubjectActiveMQJAASSecurityManager. authenticate(String user, String password, RemotingConnection remotingConnection, String securityDomain)SubjectActiveMQSecurityManager5. authenticate(String user, String password, RemotingConnection remotingConnection, String securityDomain)is this a valid user.StringActiveMQSecurityManager3. validateUser(String user, String password, RemotingConnection remotingConnection)is this a valid user.StringActiveMQSecurityManager4. validateUser(String user, String password, RemotingConnection remotingConnection, String securityDomain)is this a valid user.booleanActiveMQSecurityManager2. 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.StringActiveMQSecurityManager3. 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.StringActiveMQSecurityManager4. validateUserAndRole(String user, String password, Set<Role> roles, CheckType checkType, String address, RemotingConnection remotingConnection, String securityDomain)Determine whether the given user is valid and whether they have the correct role for the given destination address. -
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 Description JaasCallbackHandler(String username, String password, RemotingConnection remotingConnection)
-