Package | Description |
---|---|
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 |
Modifier and Type | Method and Description |
---|---|
CoreRemotingConnection |
ClientSessionFactory.getConnection() |
Modifier and Type | Method and Description |
---|---|
CoreRemotingConnection |
ClientSessionFactoryImpl.getConnection() |
Modifier and Type | Method and Description |
---|---|
void |
DelegatingSession.handleFailover(CoreRemotingConnection backupConnection) |
void |
ClientSessionInternal.handleFailover(CoreRemotingConnection backupConnection) |
void |
ClientSessionImpl.handleFailover(CoreRemotingConnection backupConnection) |
void |
DelegatingSession.preHandleFailover(CoreRemotingConnection connection) |
void |
ClientSessionInternal.preHandleFailover(CoreRemotingConnection connection) |
void |
ClientSessionImpl.preHandleFailover(CoreRemotingConnection connection) |
Constructor and Description |
---|
ClientSessionImpl(ClientSessionFactoryInternal sessionFactory,
String name,
String username,
String password,
boolean xa,
boolean autoCommitSends,
boolean autoCommitAcks,
boolean preAcknowledge,
boolean blockOnAcknowledge,
boolean autoGroup,
int ackBatchSize,
int consumerWindowSize,
int consumerMaxRate,
int confirmationWindowSize,
int producerWindowSize,
int producerMaxRate,
boolean blockOnNonDurableSend,
boolean blockOnDurableSend,
boolean cacheLargeMessageClient,
int minLargeMessageSize,
boolean compressLargeMessages,
int initialMessagePacketSize,
String groupID,
CoreRemotingConnection remotingConnection,
int version,
Channel channel,
Executor executor,
Executor flowControlExecutor) |
Modifier and Type | Method and Description |
---|---|
CoreRemotingConnection |
Channel.getConnection()
returns the Remoting Connection being used by the channel
|
Modifier and Type | Method and Description |
---|---|
void |
Channel.transferConnection(CoreRemotingConnection newConnection)
transfers the connection used by this channel to the one specified.
|
int |
ServerSessionPacketHandler.transferConnection(CoreRemotingConnection newConnection,
int lastReceivedCommandID) |
Modifier and Type | Class and Description |
---|---|
class |
RemotingConnectionImpl |
Modifier and Type | Method and Description |
---|---|
CoreRemotingConnection |
ChannelImpl.getConnection() |
Modifier and Type | Method and Description |
---|---|
void |
ChannelImpl.transferConnection(CoreRemotingConnection newConnection) |
Constructor and Description |
---|
ChannelImpl(CoreRemotingConnection connection,
long id,
int confWindowSize) |
HornetQPacketHandler(CoreProtocolManager protocolManager,
HornetQServer server,
Channel channel1,
CoreRemotingConnection connection) |
Copyright © 2012 JBoss by Red Hat. All Rights Reserved.