Uses of Interface
org.apache.activemq.artemis.spi.core.remoting.Connection
Packages that use Connection
Package
Description
-
Uses of Connection in org.apache.activemq.artemis.core.client
Methods in org.apache.activemq.artemis.core.client with parameters of type ConnectionModifier and TypeMethodDescriptionActiveMQClientMessageBundle_impl.connectionTimedOut(Connection transportConnection) ActiveMQClientMessageBundle.connectionTimedOut(Connection transportConnection) -
Uses of Connection in org.apache.activemq.artemis.core.client.impl
Methods in org.apache.activemq.artemis.core.client.impl that return ConnectionModifier and TypeMethodDescriptionprotected ConnectionClientSessionFactoryImpl.createTransportConnection()It will connect to either primary or backup accordingly to the current configurations it will also switch to backup case it can't connect to primary and there's a backup configuredprotected ConnectionClientSessionFactoryImpl.openTransportConnection(Connector connector) Methods in org.apache.activemq.artemis.core.client.impl with parameters of type ConnectionModifier and TypeMethodDescriptionvoidClientSessionFactoryImpl.connectionCreated(ActiveMQComponent component, Connection connection, ClientProtocolManager protocol) -
Uses of Connection in org.apache.activemq.artemis.core.management.impl
Methods in org.apache.activemq.artemis.core.management.impl that return Connection -
Uses of Connection in org.apache.activemq.artemis.core.protocol.core.impl
Methods in org.apache.activemq.artemis.core.protocol.core.impl with parameters of type ConnectionModifier and TypeMethodDescriptionActiveMQClientProtocolManager.connect(Connection transportConnection, long callTimeout, long callFailoverTimeout, List<Interceptor> incomingInterceptors, List<Interceptor> outgoingInterceptors, TopologyResponseHandler topologyResponseHandler) CoreProtocolManager.createConnectionEntry(Acceptor acceptorUsed, Connection connection) protected voidActiveMQClientProtocolManager.sendHandshake(Connection transportConnection) Constructors in org.apache.activemq.artemis.core.protocol.core.impl with parameters of type ConnectionModifierConstructorDescriptionRemotingConnectionImpl(PacketDecoder packetDecoder, Connection transportConnection, long blockingCallTimeout, long blockingCallFailoverTimeout, List<Interceptor> incomingInterceptors, List<Interceptor> outgoingInterceptors, Executor connectionExecutor) Create a client side connectionRemotingConnectionImpl(PacketDecoder packetDecoder, Connection transportConnection, List<Interceptor> incomingInterceptors, List<Interceptor> outgoingInterceptors, SimpleString nodeID, Executor connectionExecutor) Create a server side connection -
Uses of Connection in org.apache.activemq.artemis.core.protocol.hornetq.client
Methods in org.apache.activemq.artemis.core.protocol.hornetq.client with parameters of type ConnectionModifier and TypeMethodDescriptionprotected voidHornetQClientProtocolManager.sendHandshake(Connection transportConnection) -
Uses of Connection in org.apache.activemq.artemis.core.remoting.impl.invm
Classes in org.apache.activemq.artemis.core.remoting.impl.invm that implement ConnectionMethods in org.apache.activemq.artemis.core.remoting.impl.invm that return ConnectionModifier and TypeMethodDescriptionInVMConnector.createConnection()protected ConnectionInVMConnector.internalCreateConnection(BufferHandler handler, ClientConnectionLifeCycleListener listener, ArtemisExecutor serverExecutor) -
Uses of Connection in org.apache.activemq.artemis.core.remoting.impl.netty
Classes in org.apache.activemq.artemis.core.remoting.impl.netty that implement ConnectionMethods in org.apache.activemq.artemis.core.remoting.impl.netty that return ConnectionModifier and TypeMethodDescriptionNettyConnector.createConnection()final ConnectionNettyConnector.createConnection(Consumer<io.netty.channel.ChannelFuture> onConnect) Create and return a connection from this connector. -
Uses of Connection in org.apache.activemq.artemis.core.remoting.server
Methods in org.apache.activemq.artemis.core.remoting.server with parameters of type ConnectionModifier and TypeMethodDescriptionvoidRemotingService.addConnectionEntry(Connection connection, ConnectionEntry entry) -
Uses of Connection in org.apache.activemq.artemis.core.remoting.server.impl
Methods in org.apache.activemq.artemis.core.remoting.server.impl with parameters of type ConnectionModifier and TypeMethodDescriptionvoidRemotingServiceImpl.addConnectionEntry(Connection connection, ConnectionEntry entry) voidRemotingServiceImpl.connectionCreated(ActiveMQComponent component, Connection connection, ProtocolManager protocol) -
Uses of Connection in org.apache.activemq.artemis.core.server
Methods in org.apache.activemq.artemis.core.server with parameters of type ConnectionModifier and TypeMethodDescriptionvoidActiveMQServerLogger_impl.cannotRouteClientConnection(Connection connection) voidActiveMQServerLogger.cannotRouteClientConnection(Connection connection) voidActiveMQServerLogger_impl.routeClientConnection(Connection connection, Target target) voidActiveMQServerLogger.routeClientConnection(Connection connection, Target target) -
Uses of Connection in org.apache.activemq.artemis.core.server.routing
Methods in org.apache.activemq.artemis.core.server.routing that return ConnectionMethods in org.apache.activemq.artemis.core.server.routing with parameters of type ConnectionModifier and TypeMethodDescriptionConnectionRouter.getTarget(Connection connection, String clientID, String username) KeyResolver.resolve(Connection connection, String clientID, String username) -
Uses of Connection in org.apache.activemq.artemis.spi.core.protocol
Fields in org.apache.activemq.artemis.spi.core.protocol declared as ConnectionModifier and TypeFieldDescriptionprotected final ConnectionAbstractRemotingConnection.transportConnectionMethods in org.apache.activemq.artemis.spi.core.protocol that return ConnectionModifier and TypeMethodDescriptionAbstractRemotingConnection.getTransportConnection()RemotingConnection.getTransportConnection()return the underlying Connection.Methods in org.apache.activemq.artemis.spi.core.protocol with parameters of type ConnectionModifier and TypeMethodDescriptionProtocolManager.createConnectionEntry(Acceptor acceptorUsed, Connection connection) Constructors in org.apache.activemq.artemis.spi.core.protocol with parameters of type ConnectionModifierConstructorDescriptionAbstractRemotingConnection(Connection transportConnection, Executor executor) -
Uses of Connection in org.apache.activemq.artemis.spi.core.remoting
Methods in org.apache.activemq.artemis.spi.core.remoting that return ConnectionModifier and TypeMethodDescriptionConnector.createConnection()Create and return a connection from this connector.Methods in org.apache.activemq.artemis.spi.core.remoting with parameters of type ConnectionModifier and TypeMethodDescriptionClientProtocolManager.connect(Connection transportConnection, long callTimeout, long callFailoverTimeout, List<Interceptor> incomingInterceptors, List<Interceptor> outgoingInterceptors, TopologyResponseHandler topologyResponseHandler) voidBaseConnectionLifeCycleListener.connectionCreated(ActiveMQComponent component, Connection connection, ProtocolClass protocol) This method is used both by client connector creation and server connection creation through acceptors.