Modifier and Type | Method and Description |
---|---|
void |
ActiveMQClientLogger.errorHandlingPacket(Throwable t,
Packet packet) |
void |
ActiveMQClientLogger_$logger.errorHandlingPacket(Throwable t,
Packet packet) |
Modifier and Type | Method and Description |
---|---|
Packet |
ClientPacketDecoder.decode(ActiveMQBuffer in,
CoreRemotingConnection connection) |
Packet |
ServerPacketDecoder.decode(ActiveMQBuffer in,
CoreRemotingConnection connection) |
Packet |
ClientPacketDecoder.decode(byte packetType,
CoreRemotingConnection connection) |
Modifier and Type | Method and Description |
---|---|
Packet |
Channel.sendBlocking(Packet packet,
byte expectedPacket)
Sends a packet on this channel and then blocks until a response is received or a timeout
occurs.
|
Packet |
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.
|
Modifier and Type | Method and Description |
---|---|
void |
CommandConfirmationHandler.commandConfirmed(Packet packet)
called by channel after a confirmation has been received.
|
void |
Channel.confirm(Packet packet)
sends a confirmation of a packet being received.
|
void |
ChannelHandler.handlePacket(Packet packet)
called by the channel when a packet is received..
|
void |
Channel.handlePacket(Packet packet)
Called by
CoreRemotingConnection when a packet is received. |
void |
ServerSessionPacketHandler.handlePacket(Packet packet) |
void |
ResponseHandler.handleResponse(Packet packet,
Packet response)
called by channel after an async response has been received.
|
boolean |
Channel.send(Packet packet)
Sends a packet on this channel.
|
boolean |
Channel.send(Packet packet,
boolean flushConnection)
Sends a packet on this channel, but request it to be flushed (along with the un-flushed previous ones) only iff
flushConnection is true . |
boolean |
Channel.send(Packet packet,
int reconnectID)
Sends a packet on this channel.
|
boolean |
Channel.sendAndFlush(Packet packet)
Sends a packet on this channel and then blocks until it has been written to the connection.
|
boolean |
Channel.sendBatched(Packet packet)
Sends a packet on this channel using batching algorithm if appropriate
|
Packet |
Channel.sendBlocking(Packet packet,
byte expectedPacket)
Sends a packet on this channel and then blocks until a response is received or a timeout
occurs.
|
Packet |
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.
|
Modifier and Type | Class and Description |
---|---|
class |
PacketImpl |
Modifier and Type | Method and Description |
---|---|
abstract Packet |
PacketDecoder.decode(ActiveMQBuffer in,
CoreRemotingConnection connection) |
Packet |
PacketDecoder.decode(byte packetType,
CoreRemotingConnection connection) |
protected Packet |
ActiveMQClientProtocolManager.newCreateSessionPacket(Version clientVersion,
String name,
String username,
String password,
boolean xa,
boolean autoCommitSends,
boolean autoCommitAcks,
boolean preAcknowledge,
int minLargeMessageSize,
int confirmationWindowSize,
long sessionChannelID) |
Packet |
ResponseCache.remove(long correlationID) |
Packet |
ChannelImpl.sendBlocking(Packet packet,
byte expectedPacket) |
Packet |
ChannelImpl.sendBlocking(Packet packet,
int reconnectID,
byte expectedPacket)
Due to networking issues or server issues the server may take longer to answer than expected..
|
Modifier and Type | Method and Description |
---|---|
boolean |
ResponseCache.add(Packet packet) |
void |
ChannelImpl.confirm(Packet packet) |
void |
ChannelImpl.handleAsyncResponse(Packet packet) |
void |
ChannelImpl.handlePacket(Packet packet) |
void |
ActiveMQPacketHandler.handlePacket(Packet packet) |
void |
ResponseCache.handleResponse(Packet response) |
static String |
ChannelImpl.invokeInterceptors(Packet packet,
List<Interceptor> interceptors,
RemotingConnection connection) |
boolean |
ChannelImpl.send(Packet packet) |
boolean |
ChannelImpl.send(Packet packet,
boolean flushConnection) |
boolean |
ChannelImpl.send(Packet packet,
int reconnectID) |
boolean |
ChannelImpl.sendAndFlush(Packet packet) |
boolean |
ChannelImpl.sendBatched(Packet packet) |
Packet |
ChannelImpl.sendBlocking(Packet packet,
byte expectedPacket) |
Packet |
ChannelImpl.sendBlocking(Packet packet,
int reconnectID,
byte expectedPacket)
Due to networking issues or server issues the server may take longer to answer than expected..
|
Modifier and Type | Method and Description |
---|---|
boolean |
HQFilterConversionInterceptor.intercept(Packet packet,
RemotingConnection connection) |
boolean |
HQPropertiesConversionInterceptor.intercept(Packet packet,
RemotingConnection connection) |
Modifier and Type | Method and Description |
---|---|
protected Packet |
HornetQClientProtocolManager.newCreateSessionPacket(Version clientVersion,
String name,
String username,
String password,
boolean xa,
boolean autoCommitSends,
boolean autoCommitAcks,
boolean preAcknowledge,
int minLargeMessageSize,
int confirmationWindowSize,
long sessionChannelID) |
Modifier and Type | Method and Description |
---|---|
static boolean |
HQPropertiesConverter.isMessagePacket(Packet packet) |
Modifier and Type | Method and Description |
---|---|
void |
ReplicationEndpoint.handlePacket(Packet packet) |
Modifier and Type | Method and Description |
---|---|
void |
ActiveMQServerLogger.errorHandlingReplicationPacket(Exception e,
Packet packet) |
void |
ActiveMQServerLogger_$logger.errorHandlingReplicationPacket(Exception e,
Packet packet) |
void |
ActiveMQServerLogger.invalidPacket(Packet packet) |
void |
ActiveMQServerLogger_$logger.invalidPacket(Packet packet) |
void |
ActiveMQServerLogger.invalidPacketForReplication(Packet packet) |
void |
ActiveMQServerLogger_$logger.invalidPacketForReplication(Packet packet) |
Modifier and Type | Method and Description |
---|---|
boolean |
ClusterManager.IncomingInterceptorLookingForExceptionMessage.intercept(Packet packet,
RemotingConnection connection) |
Modifier and Type | Method and Description |
---|---|
void |
QuorumManager.handleQuorumVote(Channel clusterChannel,
Packet packet) |
Copyright © 2021 JBoss by Red Hat. All rights reserved.