Uses of Interface
org.apache.activemq.artemis.spi.core.protocol.RemotingConnection
Packages that use RemotingConnection
Package
Description
-
Uses of RemotingConnection in org.apache.activemq.artemis.api.core
Methods in org.apache.activemq.artemis.api.core with parameters of type RemotingConnectionModifier and TypeMethodDescriptionbooleanBaseInterceptor.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 RemotingConnectionModifier and TypeMethodDescriptionClientSessionFactory.getConnection()Returns the code connection used by this session factory.Methods in org.apache.activemq.artemis.api.core.client with parameters of type RemotingConnectionModifier and TypeMethodDescriptionbooleanTopologyMember.isMember(RemotingConnection connection) Returnstrueif thisTopologyMemberis 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 RemotingConnectionModifier and TypeMethodDescriptionprotected RemotingConnectionClientSessionFactoryImpl.establishNewConnection()ClientSessionFactoryImpl.getConnection()ClientSessionImpl.getConnection()ClientSessionInternal.getConnection()Methods in org.apache.activemq.artemis.core.client.impl with parameters of type RemotingConnectionModifier and TypeMethodDescriptionTopology.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 RemotingConnectionModifierConstructorDescriptionCloseRunnable(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 -
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 RemotingConnectionModifier and TypeMethodDescriptionConnectionView.getField(RemotingConnection connection, String fieldName) 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 RemotingConnectionModifier and TypeMethodDescriptionbooleanConnectionFilterPredicate.test(RemotingConnection connection) -
Uses of RemotingConnection in org.apache.activemq.artemis.core.persistence
Methods in org.apache.activemq.artemis.core.persistence that return types with arguments of type RemotingConnectionModifier and TypeMethodDescriptiondefault Set<RemotingConnection>StorageManager.getUsedConnections() -
Uses of RemotingConnection in org.apache.activemq.artemis.core.persistence.impl.journal
Methods in org.apache.activemq.artemis.core.persistence.impl.journal that return types with arguments of type RemotingConnection -
Uses of RemotingConnection in org.apache.activemq.artemis.core.protocol.core
Subinterfaces of RemotingConnection in org.apache.activemq.artemis.core.protocol.coreModifier and TypeInterfaceDescriptioninterfaceExtension 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 RemotingConnectionMethods in org.apache.activemq.artemis.core.protocol.core.impl that return RemotingConnectionModifier and TypeMethodDescriptionActiveMQClientProtocolManager.connect(Connection transportConnection, long callTimeout, long callFailoverTimeout, List<Interceptor> incomingInterceptors, List<Interceptor> outgoingInterceptors, TopologyResponseHandler topologyResponseHandler) ActiveMQClientProtocolManager.getCurrentConnection()Methods in org.apache.activemq.artemis.core.protocol.core.impl with parameters of type RemotingConnectionModifier and TypeMethodDescriptionvoidCoreProtocolManager.handleBuffer(RemotingConnection connection, ActiveMQBuffer buffer) static StringChannelImpl.invokeInterceptors(Packet packet, List<Interceptor> interceptors, RemotingConnection connection) Returns the name of the interceptor that returnedfalseornullif no interceptors returnedfalse.booleanActiveMQSessionContext.reattachOnNewConnection(RemotingConnection newConnection) voidActiveMQSessionContext.transferConnection(RemotingConnection newConnection) Constructors in org.apache.activemq.artemis.core.protocol.core.impl with parameters of type RemotingConnectionModifierConstructorDescriptionActiveMQSessionContext(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 RemotingConnectionModifier and TypeMethodDescriptionbooleanHQFilterConversionInterceptor.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 RemotingConnectionModifierConstructorDescriptionHornetQClientSessionContext(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 RemotingConnectionModifier and TypeMethodDescriptionstatic 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 RemotingConnectionMethods in org.apache.activemq.artemis.core.remoting.impl.invm with parameters of type RemotingConnectionModifier and TypeMethodDescriptionvoidInVMConnection.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 RemotingConnectionModifier and TypeMethodDescriptionfinal RemotingConnectionNettyConnection.getProtocolConnection()Methods in org.apache.activemq.artemis.core.remoting.impl.netty with parameters of type RemotingConnectionModifier and TypeMethodDescriptionfinal 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 RemotingConnectionModifier and TypeMethodDescriptionRemotingService.getConnection(Object remotingConnectionID) 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 RemotingConnectionMethod parameters in org.apache.activemq.artemis.core.remoting.server with type arguments of type RemotingConnectionModifier and TypeMethodDescriptionvoidRemotingService.prepareStop(boolean criticalError, Set<RemotingConnection> ignoreConnections) The Prepare stop will close all the connections however it will use the one used by storage manager -
Uses of RemotingConnection in org.apache.activemq.artemis.core.remoting.server.impl
Methods in org.apache.activemq.artemis.core.remoting.server.impl that return RemotingConnectionModifier and TypeMethodDescriptionRemotingServiceImpl.getConnection(Object remotingConnectionID) RemotingServiceImpl.removeConnection(Object remotingConnectionID) Methods in org.apache.activemq.artemis.core.remoting.server.impl that return types with arguments of type RemotingConnectionMethod parameters in org.apache.activemq.artemis.core.remoting.server.impl with type arguments of type RemotingConnectionModifier and TypeMethodDescriptionvoidRemotingServiceImpl.prepareStop(boolean criticalError, Set<RemotingConnection> ignoreList) -
Uses of RemotingConnection in org.apache.activemq.artemis.core.security
Methods in org.apache.activemq.artemis.core.security that return RemotingConnectionMethods in org.apache.activemq.artemis.core.security with parameters of type RemotingConnectionModifier and TypeMethodDescriptionSecurityStore.authenticate(String user, String password, RemotingConnection remotingConnection) SecurityStore.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 RemotingConnectionModifier and TypeMethodDescriptionSecurityStoreImpl.authenticate(String user, String password, RemotingConnection connection) SecurityStoreImpl.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 RemotingConnectionMethods in org.apache.activemq.artemis.core.server with parameters of type RemotingConnectionModifier and TypeMethodDescriptionActiveMQServer.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, boolean isLegacyProducer) This is to be used in places where security is bypassed, like internal sessions, broker connections, etc...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, String securityDomain, String validatedUser, boolean isLegacyProducer) voidServerSession.transferConnection(RemotingConnection newConnection) ActiveMQServer.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 RemotingConnectionMethods in org.apache.activemq.artemis.core.server.cluster with parameters of type RemotingConnectionModifier and TypeMethodDescriptionbooleanClusterManager.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 -
Uses of RemotingConnection in org.apache.activemq.artemis.core.server.impl
Fields in org.apache.activemq.artemis.core.server.impl declared as RemotingConnectionModifier and TypeFieldDescriptionprotected RemotingConnectionServerSessionImpl.remotingConnectionMethods in org.apache.activemq.artemis.core.server.impl that return RemotingConnectionMethods in org.apache.activemq.artemis.core.server.impl with parameters of type RemotingConnectionModifier and TypeMethodDescriptionActiveMQServerImpl.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, boolean isLegacyProducer) 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, String securityDomain, String validatedUser, boolean isLegacyProducer) 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, boolean isLegacyProducer) voidServerSessionImpl.transferConnection(RemotingConnection newConnection) ActiveMQServerImpl.validateUser(String username, String password, RemotingConnection connection, String securityDomain) Constructors in org.apache.activemq.artemis.core.server.impl with parameters of type RemotingConnectionModifierConstructorDescriptionServerSessionImpl(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, boolean isLegacyProducer) -
Uses of RemotingConnection in org.apache.activemq.artemis.core.server.plugin
Methods in org.apache.activemq.artemis.core.server.plugin with parameters of type RemotingConnectionModifier and TypeMethodDescriptiondefault 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 RemotingConnectionModifier and TypeMethodDescriptionvoidLoggingActiveMQServerPlugin.afterCreateConnection(RemotingConnection connection) A connection has been created.voidLoggingActiveMQServerPluginLogger_impl.afterCreateConnection(RemotingConnection connection) voidLoggingActiveMQServerPluginLogger.afterCreateConnection(RemotingConnection connection) voidNotificationActiveMQServerPlugin.afterCreateConnection(RemotingConnection connection) voidLoggingActiveMQServerPlugin.afterDestroyConnection(RemotingConnection connection) A connection has been destroyed.voidLoggingActiveMQServerPluginLogger_impl.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_impl.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 RemotingConnectionConstructors in org.apache.activemq.artemis.core.server.routing with parameters of type RemotingConnectionModifierConstructorDescriptionRoutingContext(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 RemotingConnectionModifier and TypeMethodDescriptionbooleanResourceManager.putTransaction(Xid xid, Transaction tx, RemotingConnection remotingConnection) ResourceManager.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 RemotingConnectionModifier and TypeMethodDescriptionbooleanResourceManagerImpl.putTransaction(Xid xid, Transaction tx, RemotingConnection remotingConnection) ResourceManagerImpl.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 RemotingConnectionModifier and TypeClassDescriptionclassAbstractProtocolManager<P,I extends BaseInterceptor<P>, C extends RemotingConnection, R extends RoutingHandler> Classes in org.apache.activemq.artemis.spi.core.protocol that implement RemotingConnectionFields in org.apache.activemq.artemis.spi.core.protocol declared as RemotingConnectionMethods in org.apache.activemq.artemis.spi.core.protocol with parameters of type RemotingConnectionModifier and TypeMethodDescriptionvoidProtocolManager.handleBuffer(RemotingConnection connection, ActiveMQBuffer buffer) Constructors in org.apache.activemq.artemis.spi.core.protocol with parameters of type RemotingConnectionModifierConstructorDescriptionConnectionEntry(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 RemotingConnectionMethods in org.apache.activemq.artemis.spi.core.remoting that return RemotingConnectionModifier and TypeMethodDescriptionClientProtocolManager.connect(Connection transportConnection, long callTimeout, long callFailoverTimeout, List<Interceptor> incomingInterceptors, List<Interceptor> outgoingInterceptors, TopologyResponseHandler topologyResponseHandler) ClientProtocolManager.getCurrentConnection()Connection.getProtocolConnection()SessionContext.getRemotingConnection()Methods in org.apache.activemq.artemis.spi.core.remoting with parameters of type RemotingConnectionModifier and TypeMethodDescriptionvoidTopologyResponseHandler.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 -
Uses of RemotingConnection in org.apache.activemq.artemis.spi.core.security
Methods in org.apache.activemq.artemis.spi.core.security with parameters of type RemotingConnectionModifier and TypeMethodDescriptionActiveMQBasicSecurityManager.authenticate(String userToAuthenticate, String passwordToAuthenticate, RemotingConnection remotingConnection, String securityDomain) ActiveMQJAASSecurityManager.authenticate(String user, String password, RemotingConnection remotingConnection, String securityDomain) ActiveMQSecurityManager5.authenticate(String user, String password, RemotingConnection remotingConnection, String securityDomain) is this a valid user.ActiveMQSecurityManager3.validateUser(String user, String password, RemotingConnection remotingConnection) is this a valid user.ActiveMQSecurityManager4.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.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.ActiveMQSecurityManager4.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 RemotingConnectionModifierConstructorDescriptionJaasCallbackHandler(String username, String password, RemotingConnection remotingConnection)