Uses of Interface
org.apache.activemq.artemis.core.protocol.core.Packet
Packages that use Packet
Package
Description
-
Uses of Packet in org.apache.activemq.artemis.core.protocol
Methods in org.apache.activemq.artemis.core.protocol that return PacketModifier and TypeMethodDescriptionClientPacketDecoder.decode(byte packetType, CoreRemotingConnection connection) ClientPacketDecoder.decode(ActiveMQBuffer in, CoreRemotingConnection connection) ServerPacketDecoder.decode(ActiveMQBuffer in, CoreRemotingConnection connection) -
Uses of Packet in org.apache.activemq.artemis.core.protocol.core
Methods in org.apache.activemq.artemis.core.protocol.core that return PacketModifier and TypeMethodDescriptionChannel.sendBlocking(Packet packet, byte expectedPacket) Sends a packet on this channel and then blocks until a response is received or a timeout occurs.Channel.sendBlocking(Packet packet, int reconnectID, byte expectedPacket) Sends a packet on this channel and then blocks until a response is received or a timeout occurs.Channel.sendBlocking(Packet packet, int reconnectID, byte expectedPacket, long timeout, boolean failOnTimeout) Methods in org.apache.activemq.artemis.core.protocol.core with parameters of type PacketModifier and TypeMethodDescriptionvoidCommandConfirmationHandler.commandConfirmed(Packet packet) called by channel after a confirmation has been received.voidsends a confirmation of a packet being received.voidChannel.handlePacket(Packet packet) Called byCoreRemotingConnectionwhen a packet is received.voidChannelHandler.handlePacket(Packet packet) called by the channel when a packet is received..voidServerSessionPacketHandler.handlePacket(Packet packet) voidResponseHandler.handleResponse(Packet packet, Packet response) called by channel after an async response has been received.booleanSends a packet on this channel.booleanSends a packet on this channel, but request it to be flushed (along with the un-flushed previous ones) only iffflushConnectionistrue.booleanSends a packet on this channel.booleanChannel.sendAndFlush(Packet packet) Sends a packet on this channel and then blocks until it has been written to the connection.booleanChannel.sendBatched(Packet packet) Sends a packet on this channel using batching algorithm if appropriateChannel.sendBlocking(Packet packet, byte expectedPacket) Sends a packet on this channel and then blocks until a response is received or a timeout occurs.Channel.sendBlocking(Packet packet, int reconnectID, byte expectedPacket) Sends a packet on this channel and then blocks until a response is received or a timeout occurs.Channel.sendBlocking(Packet packet, int reconnectID, byte expectedPacket, long timeout, boolean failOnTimeout) -
Uses of Packet in org.apache.activemq.artemis.core.protocol.core.impl
Classes in org.apache.activemq.artemis.core.protocol.core.impl that implement PacketMethods in org.apache.activemq.artemis.core.protocol.core.impl that return PacketModifier and TypeMethodDescriptionPacketDecoder.decode(byte packetType, CoreRemotingConnection connection) abstract PacketPacketDecoder.decode(ActiveMQBuffer in, CoreRemotingConnection connection) protected PacketActiveMQClientProtocolManager.newCreateSessionPacket(int clientVersion, String name, String username, String password, boolean xa, boolean autoCommitSends, boolean autoCommitAcks, boolean preAcknowledge, int minLargeMessageSize, int confirmationWindowSize, long sessionChannelID, String clientID) ResponseCache.remove(long correlationID) ChannelImpl.sendBlocking(Packet packet, byte expectedPacket) ChannelImpl.sendBlocking(Packet packet, int reconnectID, byte expectedPacket) ChannelImpl.sendBlocking(Packet packet, int reconnectID, byte expectedPacket, long timeout, boolean failOnTimeout) Due to networking issues or server issues the server may take longer to answer than expected.. the client may timeout the call throwing an exception and the client could eventually retry another call, but the server could then answer a previous command issuing a class-cast-exception.Methods in org.apache.activemq.artemis.core.protocol.core.impl with parameters of type PacketModifier and TypeMethodDescriptionbooleanvoidvoidChannelImpl.handleAsyncResponse(Packet packet) voidActiveMQPacketHandler.handlePacket(Packet packet) voidChannelImpl.handlePacket(Packet packet) voidResponseCache.handleResponse(Packet response) static StringChannelImpl.invokeInterceptors(Packet packet, List<Interceptor> interceptors, RemotingConnection connection) Returns the name of the interceptor that returnedfalseornullif no interceptors returnedfalse.booleanbooleanbooleanbooleanChannelImpl.sendAndFlush(Packet packet) booleanChannelImpl.sendBatched(Packet packet) ChannelImpl.sendBlocking(Packet packet, byte expectedPacket) ChannelImpl.sendBlocking(Packet packet, int reconnectID, byte expectedPacket) ChannelImpl.sendBlocking(Packet packet, int reconnectID, byte expectedPacket, long timeout, boolean failOnTimeout) Due to networking issues or server issues the server may take longer to answer than expected.. the client may timeout the call throwing an exception and the client could eventually retry another call, but the server could then answer a previous command issuing a class-cast-exception. -
Uses of Packet in org.apache.activemq.artemis.core.protocol.core.impl.wireformat
Classes in org.apache.activemq.artemis.core.protocol.core.impl.wireformat that implement PacketModifier and TypeClassDescriptionclassclassfinal classRegisters a given backup-server as the replicating backup of a primary server (i.e. a regular ActiveMQ).final classInforms the Backup trying to start replicating of an error.classclassclassclassclassclassclassclassclassclassclassclassclassclassclassclassclassclassclassclassclassclassclassclassclassclassclassclassclassclassclassfinal classPing is sent on the client side byClientSessionFactoryImpl.classclassclassclassclassclassfinal classclassfinal classfinal classclassclassclassfinal classclassclassfinal classfinal classMessage indicating that the primary is stopping (a scheduled stop).classfinal classclassThis message may signal start or end of the replication synchronization.final classMessage is used to syncSequentialFiles to a backup server.classclassclassclassA SessionAddMetaDataMessageclassA SessionAddMetaDataMessageclassclassclassclassclassclassclassclassclassclassclassclassclassclassclassclassclassclassclassclassclassclassclassclassclassclassclassclassclassclassclassclassclassclassclassSessionSend Message for the 1.x branchclassclassclassclassto be called after a failure on an XA Sessionclassclassclassclassclassclassclassclassclassclassclassclassclassclassclassclass -
Uses of Packet in org.apache.activemq.artemis.core.protocol.hornetq
Methods in org.apache.activemq.artemis.core.protocol.hornetq with parameters of type PacketModifier and TypeMethodDescriptionbooleanHQFilterConversionInterceptor.intercept(Packet packet, RemotingConnection connection) booleanHQPropertiesConversionInterceptor.intercept(Packet packet, RemotingConnection connection) -
Uses of Packet in org.apache.activemq.artemis.core.protocol.hornetq.client
Methods in org.apache.activemq.artemis.core.protocol.hornetq.client that return PacketModifier and TypeMethodDescriptionprotected PacketHornetQClientProtocolManager.newCreateSessionPacket(int clientVersion, String name, String username, String password, boolean xa, boolean autoCommitSends, boolean autoCommitAcks, boolean preAcknowledge, int minLargeMessageSize, int confirmationWindowSize, long sessionChannelID, String clientID) -
Uses of Packet in org.apache.activemq.artemis.core.protocol.hornetq.util
Methods in org.apache.activemq.artemis.core.protocol.hornetq.util with parameters of type PacketModifier and TypeMethodDescriptionstatic booleanHQPropertiesConverter.isMessagePacket(Packet packet) -
Uses of Packet in org.apache.activemq.artemis.core.replication
Methods in org.apache.activemq.artemis.core.replication with parameters of type Packet -
Uses of Packet in org.apache.activemq.artemis.core.server
Methods in org.apache.activemq.artemis.core.server with parameters of type PacketModifier and TypeMethodDescriptionvoidActiveMQServerLogger_impl.errorHandlingReplicationPacket(Packet packet, Exception e) voidActiveMQServerLogger.errorHandlingReplicationPacket(Packet packet, Exception e) voidActiveMQServerLogger_impl.invalidPacket(Packet packet) voidActiveMQServerLogger.invalidPacket(Packet packet) voidActiveMQServerLogger_impl.invalidPacketForReplication(Packet packet) voidActiveMQServerLogger.invalidPacketForReplication(Packet packet) -
Uses of Packet in org.apache.activemq.artemis.core.server.cluster
Methods in org.apache.activemq.artemis.core.server.cluster with parameters of type PacketModifier and TypeMethodDescriptionbooleanClusterManager.IncomingInterceptorLookingForExceptionMessage.intercept(Packet packet, RemotingConnection connection) -
Uses of Packet in org.apache.activemq.artemis.core.server.cluster.quorum
Methods in org.apache.activemq.artemis.core.server.cluster.quorum with parameters of type PacketModifier and TypeMethodDescriptionvoidQuorumManager.handleQuorumVote(Channel clusterChannel, Packet packet)