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 |
ClientSessionImpl.getConnection() |
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 | Class and Description |
---|---|
class |
StompConnection
A StompConnection
|
Modifier and Type | Method and Description |
---|---|
RemotingConnection |
StompSession.getConnection() |
Modifier and Type | Method and Description |
---|---|
RemotingConnection |
RemotingService.removeConnection(Object remotingConnectionID)
Remove a connection from the connections held by the remoting service.
|
Modifier and Type | Method and Description |
---|---|
Set<RemotingConnection> |
RemotingService.getConnections() |
Modifier and Type | Method and Description |
---|---|
RemotingConnection |
RemotingServiceImpl.removeConnection(Object remotingConnectionID) |
Modifier and Type | Method and Description |
---|---|
Set<RemotingConnection> |
RemotingServiceImpl.getConnections() |
Modifier and Type | Method and Description |
---|---|
RemotingConnection |
ServerSession.getRemotingConnection() |
Modifier and Type | Method and Description |
---|---|
ServerSession |
HornetQServer.createSession(String name,
String username,
String password,
int minLargeMessageSize,
RemotingConnection remotingConnection,
boolean autoCommitSends,
boolean autoCommitAcks,
boolean preAcknowledge,
boolean xa,
String defaultAddress,
SessionCallback callback) |
Modifier and Type | Method and Description |
---|---|
RemotingConnection |
Bridge.getForwardingConnection() |
Modifier and Type | Method and Description |
---|---|
boolean |
ClusterManager.IncomingInterceptorLookingForExceptionMessage.intercept(Packet packet,
RemotingConnection connection) |
Modifier and Type | Method and Description |
---|---|
RemotingConnection |
BridgeImpl.getForwardingConnection() |
Modifier and Type | Method and Description |
---|---|
RemotingConnection |
ServerSessionImpl.getRemotingConnection() |
Modifier and Type | Method and Description |
---|---|
ServerSession |
HornetQServerImpl.createSession(String name,
String username,
String password,
int minLargeMessageSize,
RemotingConnection connection,
boolean autoCommitSends,
boolean autoCommitAcks,
boolean preAcknowledge,
boolean xa,
String defaultAddress,
SessionCallback callback) |
protected ServerSessionImpl |
HornetQServerImpl.internalCreateSession(String name,
String username,
String password,
int minLargeMessageSize,
RemotingConnection connection,
boolean autoCommitSends,
boolean autoCommitAcks,
boolean preAcknowledge,
boolean xa,
String defaultAddress,
SessionCallback callback,
OperationContext context) |
Constructor and Description |
---|
ServerSessionImpl(String name,
String username,
String password,
int minLargeMessageSize,
boolean autoCommitSends,
boolean autoCommitAcks,
boolean preAcknowledge,
boolean strictUpdateDeliveryCount,
boolean xa,
RemotingConnection remotingConnection,
StorageManager storageManager,
PostOffice postOffice,
ResourceManager resourceManager,
SecurityStore securityStore,
ManagementService managementService,
HornetQServer server,
SimpleString managementAddress,
SimpleString defaultAddress,
SessionCallback callback,
OperationContext context) |
Modifier and Type | Field and Description |
---|---|
RemotingConnection |
ConnectionEntry.connection |
Modifier and Type | Method and Description |
---|---|
void |
ProtocolManager.handleBuffer(RemotingConnection connection,
HornetQBuffer buffer) |
Constructor and Description |
---|
ConnectionEntry(RemotingConnection connection,
Executor connectionExecutor,
long lastCheck,
long ttl) |
Copyright © 2017 JBoss, a division of Red Hat. All rights reserved.