Modifier and Type | Method and Description |
---|---|
boolean |
Interceptor.intercept(Packet packet,
RemotingConnection connection)
Intercepts a packet which is received before it is sent to the channel
|
Modifier and Type | Method and Description |
---|---|
void |
HornetQClientLogger.errorHandlingPacket(Throwable t,
Packet packet) |
Modifier and Type | Method and Description |
---|---|
void |
ClientSessionImpl.commandConfirmed(Packet packet) |
Modifier and Type | Method and Description |
---|---|
Packet |
ServerPacketDecoder.decode(HornetQBuffer in) |
Packet |
ClientPacketDecoder.decode(HornetQBuffer in) |
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.
|
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 |
ServerSessionPacketHandler.handlePacket(Packet packet) |
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. |
boolean |
Channel.send(Packet packet)
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.
|
Modifier and Type | Class and Description |
---|---|
class |
PacketImpl |
Modifier and Type | Method and Description |
---|---|
Packet |
PacketDecoder.decode(byte packetType) |
abstract Packet |
PacketDecoder.decode(HornetQBuffer in) |
Packet |
ChannelImpl.sendBlocking(Packet packet,
byte expectedPacket)
Due to networking issues or server issues the server may take longer to answer than expected..
|
Modifier and Type | Method and Description |
---|---|
void |
ChannelImpl.confirm(Packet packet) |
void |
HornetQPacketHandler.handlePacket(Packet packet) |
void |
ChannelImpl.handlePacket(Packet packet) |
static String |
ChannelImpl.invokeInterceptors(Packet packet,
List<Interceptor> interceptors,
RemotingConnection connection) |
boolean |
ChannelImpl.send(Packet packet) |
boolean |
ChannelImpl.send(Packet packet,
boolean flush,
boolean batch) |
boolean |
ChannelImpl.sendAndFlush(Packet packet) |
boolean |
ChannelImpl.sendBatched(Packet packet) |
Packet |
ChannelImpl.sendBlocking(Packet packet,
byte expectedPacket)
Due to networking issues or server issues the server may take longer to answer than expected..
|
Modifier and Type | Method and Description |
---|---|
void |
ReplicationEndpoint.handlePacket(Packet packet) |
Modifier and Type | Method and Description |
---|---|
void |
HornetQServerLogger.errorHandlingReplicationPacket(Exception e,
Packet packet) |
void |
HornetQServerLogger.invalidPacket(Packet packet) |
void |
HornetQServerLogger.invalidPacketForReplication(Packet packet) |
Modifier and Type | Method and Description |
---|---|
boolean |
ClusterManager.IncomingInterceptorLookingForExceptionMessage.intercept(Packet packet,
RemotingConnection connection) |
Copyright © 2017 JBoss, a division of Red Hat. All rights reserved.