Package | Description |
---|---|
org.hornetq.api.core |
Core Messaging API.
|
org.hornetq.api.core.client |
Core Client 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.spi.core.protocol |
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 |
---|---|
boolean |
TopologyMember.isMember(RemotingConnection connection)
Returns true if this TopologyMember is the target of this remoting connection
|
Modifier and Type | Method and Description |
---|---|
RemotingConnection |
ClientSessionInternal.getConnection() |
RemotingConnection |
DelegatingSession.getConnection() |
Modifier and Type | Method and Description |
---|---|
boolean |
TopologyMemberImpl.isMember(RemotingConnection connection) |
Modifier and Type | Interface and Description |
---|---|
interface |
CoreRemotingConnection
Extension of RemotingConnection for the HornetQ core protocol
|
Modifier and Type | Method and Description |
---|---|
HornetQBuffer |
Packet.encode(RemotingConnection connection)
Encodes the packet and returns a
HornetQBuffer containing the data |
Modifier and Type | Class and Description |
---|---|
class |
RemotingConnectionImpl |
Modifier and Type | Method and Description |
---|---|
HornetQBuffer |
PacketImpl.encode(RemotingConnection connection) |
static String |
ChannelImpl.invokeInterceptors(Packet packet,
List<Interceptor> interceptors,
RemotingConnection connection) |
Modifier and Type | Method and Description |
---|---|
HornetQBuffer |
SessionSendMessage.encode(RemotingConnection connection) |
HornetQBuffer |
SessionReceiveMessage.encode(RemotingConnection connection) |
Modifier and Type | Field and Description |
---|---|
RemotingConnection |
ConnectionEntry.connection |
Constructor and Description |
---|
ConnectionEntry(RemotingConnection connection,
Executor connectionExecutor,
long lastCheck,
long ttl) |
Copyright © 2015 JBoss, a division of Red Hat. All Rights Reserved.