Uses of Interface
org.apache.activemq.artemis.core.protocol.core.CoreRemotingConnection
Packages that use CoreRemotingConnection
Package
Description
-
Uses of CoreRemotingConnection in org.apache.activemq.artemis.core.protocol
Methods in org.apache.activemq.artemis.core.protocol with parameters of type CoreRemotingConnectionModifier and TypeMethodDescriptionClientPacketDecoder.decode(byte packetType, CoreRemotingConnection connection) ClientPacketDecoder.decode(ActiveMQBuffer in, CoreRemotingConnection connection) ServerPacketDecoder.decode(ActiveMQBuffer in, CoreRemotingConnection connection) -
Uses of CoreRemotingConnection in org.apache.activemq.artemis.core.protocol.core
Methods in org.apache.activemq.artemis.core.protocol.core that return CoreRemotingConnectionModifier and TypeMethodDescriptionChannel.getConnection()Returns theCoreRemotingConnectionbeing used by the channel.Methods in org.apache.activemq.artemis.core.protocol.core with parameters of type CoreRemotingConnectionModifier and TypeMethodDescriptionPacket.encode(CoreRemotingConnection connection) Encodes the packet and returns aActiveMQBuffercontaining the datavoidChannel.transferConnection(CoreRemotingConnection newConnection) Transfers the connection used by this channel to the one specified.intServerSessionPacketHandler.transferConnection(CoreRemotingConnection newConnection, int lastReceivedCommandID) -
Uses of CoreRemotingConnection in org.apache.activemq.artemis.core.protocol.core.impl
Classes in org.apache.activemq.artemis.core.protocol.core.impl that implement CoreRemotingConnectionMethods in org.apache.activemq.artemis.core.protocol.core.impl that return CoreRemotingConnectionMethods in org.apache.activemq.artemis.core.protocol.core.impl with parameters of type CoreRemotingConnectionModifier and TypeMethodDescriptionprotected ActiveMQBufferPacketImpl.createPacket(CoreRemotingConnection connection) PacketDecoder.decode(byte packetType, CoreRemotingConnection connection) abstract PacketPacketDecoder.decode(ActiveMQBuffer in, CoreRemotingConnection connection) PacketImpl.encode(CoreRemotingConnection connection) voidPacketImpl.encodeRest(ActiveMQBuffer buffer, CoreRemotingConnection coreRemotingConnection) booleanActiveMQRoutingHandler.route(CoreRemotingConnection connection, CreateSessionMessage message) voidChannelImpl.transferConnection(CoreRemotingConnection newConnection) Constructors in org.apache.activemq.artemis.core.protocol.core.impl with parameters of type CoreRemotingConnectionModifierConstructorDescriptionActiveMQPacketHandler(CoreProtocolManager protocolManager, ActiveMQServer server, Channel channel1, CoreRemotingConnection connection) ActiveMQRoutingContext(CoreRemotingConnection connection, CreateSessionMessage message) ChannelImpl(CoreRemotingConnection connection, long id, int confWindowSize, List<Interceptor> interceptors) -
Uses of CoreRemotingConnection in org.apache.activemq.artemis.core.protocol.core.impl.wireformat
Methods in org.apache.activemq.artemis.core.protocol.core.impl.wireformat with parameters of type CoreRemotingConnectionModifier and TypeMethodDescriptionSessionReceiveMessage_1X.encode(CoreRemotingConnection connection) voidSessionCreateConsumerMessage.encodeRest(ActiveMQBuffer buffer, CoreRemotingConnection coreRemotingConnection) -
Uses of CoreRemotingConnection in org.apache.activemq.artemis.core.remoting.server
Methods in org.apache.activemq.artemis.core.remoting.server with parameters of type CoreRemotingConnectionModifier and TypeMethodDescriptionvoidRemotingService.freeze(String scaleDownNodeID, CoreRemotingConnection remotingConnection) Freezes and then disconnects all connections except the given one and tells the client where else it might connect (only applicable if server is in a cluster and uses scaleDown-on-failover=true). -
Uses of CoreRemotingConnection in org.apache.activemq.artemis.core.remoting.server.impl
Methods in org.apache.activemq.artemis.core.remoting.server.impl with parameters of type CoreRemotingConnectionModifier and TypeMethodDescriptionvoidRemotingServiceImpl.freeze(String scaleDownNodeID, CoreRemotingConnection connectionToKeepOpen) -
Uses of CoreRemotingConnection in org.apache.activemq.artemis.core.replication
Methods in org.apache.activemq.artemis.core.replication that return CoreRemotingConnectionModifier and TypeMethodDescriptionReplicationManager.getBackupTransportConnection()Used while stopping the server to ensure that we freeze communications with the backup.Constructors in org.apache.activemq.artemis.core.replication with parameters of type CoreRemotingConnectionModifierConstructorDescriptionReplicationManager(ActiveMQServer server, CoreRemotingConnection remotingConnection, long timeout, long initialReplicationSyncTimeout, ExecutorFactory ioExecutorFactory) -
Uses of CoreRemotingConnection in org.apache.activemq.artemis.core.server.cluster
Methods in org.apache.activemq.artemis.core.server.cluster with parameters of type CoreRemotingConnectionModifier and TypeMethodDescriptionvoidClusterController.addClusterChannelHandler(Channel channel, Acceptor acceptorUsed, CoreRemotingConnection remotingConnection, Activation activation) used to set a channel handler on the connection that can be used by the cluster controlvoidClusterManager.addClusterChannelHandler(Channel channel, Acceptor acceptorUsed, CoreRemotingConnection remotingConnection, Activation activation) -
Uses of CoreRemotingConnection in org.apache.activemq.artemis.core.server.impl
Methods in org.apache.activemq.artemis.core.server.impl with parameters of type CoreRemotingConnectionModifier and TypeMethodDescriptionvoidSharedNothingPrimaryActivation.startReplication(CoreRemotingConnection rc, ClusterConnection clusterConnection, Pair<TransportConfiguration, TransportConfiguration> pair, boolean isFailBackRequest)