Package | Description |
---|---|
org.hornetq.api.core |
Core Messaging API.
|
org.hornetq.core.client.impl | |
org.hornetq.core.protocol.core | |
org.hornetq.core.protocol.core.impl | |
org.hornetq.core.protocol.core.impl.wireformat | |
org.hornetq.core.replication.impl |
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 |
ClientSessionImpl.commandConfirmed(Packet packet) |
void |
ClientSessionPacketHandler.handlePacket(Packet packet) |
Modifier and Type | Method and Description |
---|---|
Packet |
Channel.sendBlocking(Packet packet)
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. |
void |
Channel.send(Packet packet)
sends a packet on this channel.
|
void |
Channel.sendAndFlush(Packet packet)
sends a packet on this channel and then blocks until it has been written to the connection.
|
void |
Channel.sendBatched(Packet packet)
sends a packet on this channel using batching algorithm if appropriate
|
Packet |
Channel.sendBlocking(Packet packet)
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(HornetQBuffer in) |
Packet |
ChannelImpl.sendBlocking(Packet packet) |
Modifier and Type | Method and Description |
---|---|
void |
ChannelImpl.confirm(Packet packet) |
void |
HornetQPacketHandler.handlePacket(Packet packet) |
void |
ChannelImpl.handlePacket(Packet packet) |
void |
ChannelImpl.send(Packet packet) |
void |
ChannelImpl.send(Packet packet,
boolean flush,
boolean batch) |
void |
ChannelImpl.sendAndFlush(Packet packet) |
void |
ChannelImpl.sendBatched(Packet packet) |
Packet |
ChannelImpl.sendBlocking(Packet packet) |
Modifier and Type | Method and Description |
---|---|
void |
ReplicationManagerImpl.ResponseHandler.handlePacket(Packet packet) |
void |
ReplicationEndpointImpl.handlePacket(Packet packet) |
Copyright © 2012 JBoss by Red Hat. All Rights Reserved.