| 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 | |
| org.hornetq.core.remoting.server | |
| org.hornetq.core.remoting.server.impl | |
| org.hornetq.core.replication | |
| org.hornetq.core.server | |
| org.hornetq.core.server.impl |
| Modifier and Type | Method and Description |
|---|---|
CoreRemotingConnection |
ClientSessionFactory.getConnection()
Returns the code connection used by this session factory.
|
| Modifier and Type | Method and Description |
|---|---|
CoreRemotingConnection |
ClientSessionFactoryImpl.getConnection() |
| Modifier and Type | Method and Description |
|---|---|
void |
ClientSessionImpl.handleFailover(CoreRemotingConnection backupConnection,
HornetQException cause) |
void |
ClientSessionInternal.handleFailover(CoreRemotingConnection backupConnection,
HornetQException cause) |
void |
DelegatingSession.handleFailover(CoreRemotingConnection backupConnection,
HornetQException cause) |
void |
ClientSessionImpl.preHandleFailover(CoreRemotingConnection connection) |
void |
ClientSessionInternal.preHandleFailover(CoreRemotingConnection connection) |
void |
DelegatingSession.preHandleFailover(CoreRemotingConnection connection) |
| Modifier and Type | Method and Description |
|---|---|
CoreRemotingConnection |
Channel.getConnection()
returns the
CoreRemotingConnection 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,
List<Interceptor> interceptors) |
HornetQPacketHandler(org.hornetq.core.protocol.core.impl.CoreProtocolManager protocolManager,
HornetQServer server,
Channel channel1,
CoreRemotingConnection connection) |
| Modifier and Type | Method and Description |
|---|---|
void |
RemotingService.freeze(CoreRemotingConnection rc)
Freezes and then disconnects all connections except the given one.
|
| Modifier and Type | Method and Description |
|---|---|
void |
RemotingServiceImpl.freeze(CoreRemotingConnection connectionToKeepOpen) |
| Modifier and Type | Method and Description |
|---|---|
CoreRemotingConnection |
ReplicationManager.getBackupTransportConnection()
Used while stopping the server to ensure that we freeze communications with the backup.
|
| Constructor and Description |
|---|
ReplicationManager(CoreRemotingConnection remotingConnection,
ExecutorFactory executorFactory) |
| Modifier and Type | Method and Description |
|---|---|
void |
HornetQServer.startReplication(CoreRemotingConnection rc,
ClusterConnection clusterConnection,
Pair<TransportConfiguration,TransportConfiguration> pair,
boolean failBackRequest)
Starts replication.
|
| Modifier and Type | Method and Description |
|---|---|
void |
QuorumManager.addAsFailureListenerOf(CoreRemotingConnection liveConnection) |
void |
HornetQServerImpl.startReplication(CoreRemotingConnection rc,
ClusterConnection clusterConnection,
Pair<TransportConfiguration,TransportConfiguration> pair,
boolean isFailBackRequest) |
Copyright © 2016 JBoss, a division of Red Hat. All rights reserved.