Uses of Interface
org.apache.activemq.artemis.core.protocol.core.CoreRemotingConnection
-
-
Uses of CoreRemotingConnection in org.apache.activemq.artemis.core.protocol
Methods in org.apache.activemq.artemis.core.protocol with parameters of type CoreRemotingConnection Modifier and Type Method Description PacketClientPacketDecoder. decode(byte packetType, CoreRemotingConnection connection)PacketClientPacketDecoder. decode(ActiveMQBuffer in, CoreRemotingConnection connection)PacketServerPacketDecoder. 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 CoreRemotingConnection Modifier and Type Method Description CoreRemotingConnectionChannel. getConnection()returns theCoreRemotingConnectionbeing used by the channelMethods in org.apache.activemq.artemis.core.protocol.core with parameters of type CoreRemotingConnection Modifier and Type Method Description ActiveMQBufferPacket. 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 CoreRemotingConnection Modifier and Type Class Description classRemotingConnectionImplMethods in org.apache.activemq.artemis.core.protocol.core.impl that return CoreRemotingConnection Modifier and Type Method Description CoreRemotingConnectionChannelImpl. getConnection()Methods in org.apache.activemq.artemis.core.protocol.core.impl with parameters of type CoreRemotingConnection Modifier and Type Method Description protected ActiveMQBufferPacketImpl. createPacket(CoreRemotingConnection connection)PacketPacketDecoder. decode(byte packetType, CoreRemotingConnection connection)abstract PacketPacketDecoder. decode(ActiveMQBuffer in, CoreRemotingConnection connection)ActiveMQBufferPacketImpl. 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 CoreRemotingConnection Constructor Description ActiveMQPacketHandler(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 CoreRemotingConnection Modifier and Type Method Description ActiveMQBufferSessionReceiveMessage_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 CoreRemotingConnection Modifier and Type Method Description voidRemotingService. 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 CoreRemotingConnection Modifier and Type Method Description voidRemotingServiceImpl. 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 CoreRemotingConnection Modifier and Type Method Description CoreRemotingConnectionReplicationManager. 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 CoreRemotingConnection Constructor Description ReplicationManager(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 CoreRemotingConnection Modifier and Type Method Description voidClusterController. 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 CoreRemotingConnection Modifier and Type Method Description voidSharedNothingLiveActivation. startReplication(CoreRemotingConnection rc, ClusterConnection clusterConnection, Pair<TransportConfiguration,TransportConfiguration> pair, boolean isFailBackRequest)
-