Modifier and Type | Method and Description |
---|---|
ActiveMQConnectionTimedOutException |
ActiveMQClientMessageBundle.connectionTimedOut(Connection transportConnection) |
Modifier and Type | Method and Description |
---|---|
protected Connection |
ClientSessionFactoryImpl.createTransportConnection()
It will connect to either live or backup accordingly to the current configurations
it will also switch to backup case it can't connect to live and there's a backup configured
|
protected Connection |
ClientSessionFactoryImpl.openTransportConnection(Connector connector) |
Modifier and Type | Method and Description |
---|---|
void |
ClientSessionFactoryImpl.connectionCreated(ActiveMQComponent component,
Connection connection,
ClientProtocolManager protocol) |
Modifier and Type | Method and Description |
---|---|
RemotingConnection |
ActiveMQClientProtocolManager.connect(Connection transportConnection,
long callTimeout,
long callFailoverTimeout,
List<Interceptor> incomingInterceptors,
List<Interceptor> outgoingInterceptors,
TopologyResponseHandler topologyResponseHandler) |
ConnectionEntry |
CoreProtocolManager.createConnectionEntry(Acceptor acceptorUsed,
Connection connection) |
protected void |
ActiveMQClientProtocolManager.sendHandshake(Connection transportConnection) |
Constructor and Description |
---|
RemotingConnectionImpl(PacketDecoder packetDecoder,
Connection transportConnection,
long blockingCallTimeout,
long blockingCallFailoverTimeout,
List<Interceptor> incomingInterceptors,
List<Interceptor> outgoingInterceptors) |
Modifier and Type | Method and Description |
---|---|
protected void |
HornetQClientProtocolManager.sendHandshake(Connection transportConnection) |
Modifier and Type | Class and Description |
---|---|
class |
InVMConnection |
Modifier and Type | Method and Description |
---|---|
Connection |
InVMConnector.createConnection() |
protected Connection |
InVMConnector.internalCreateConnection(BufferHandler handler,
ClientConnectionLifeCycleListener listener,
Executor serverExecutor) |
Modifier and Type | Class and Description |
---|---|
class |
NettyConnection |
class |
NettyServerConnection |
Modifier and Type | Method and Description |
---|---|
Connection |
NettyConnector.createConnection() |
Modifier and Type | Method and Description |
---|---|
void |
RemotingServiceImpl.connectionCreated(ActiveMQComponent component,
Connection connection,
ProtocolManager protocol) |
Modifier and Type | Field and Description |
---|---|
protected Connection |
AbstractRemotingConnection.transportConnection |
Modifier and Type | Method and Description |
---|---|
Connection |
RemotingConnection.getTransportConnection()
return the underlying Connection.
|
Connection |
AbstractRemotingConnection.getTransportConnection() |
Modifier and Type | Method and Description |
---|---|
ConnectionEntry |
ProtocolManager.createConnectionEntry(Acceptor acceptorUsed,
Connection connection) |
Constructor and Description |
---|
AbstractRemotingConnection(Connection transportConnection,
Executor executor) |
Modifier and Type | Method and Description |
---|---|
Connection |
Connector.createConnection()
Create and return a connection from this connector.
|
Modifier and Type | Method and Description |
---|---|
RemotingConnection |
ClientProtocolManager.connect(Connection transportConnection,
long callTimeout,
long callFailoverTimeout,
List<Interceptor> incomingInterceptors,
List<Interceptor> outgoingInterceptors,
TopologyResponseHandler topologyResponseHandler) |
void |
BaseConnectionLifeCycleListener.connectionCreated(ActiveMQComponent component,
Connection connection,
ProtocolClass protocol)
This method is used both by client connector creation and server connection creation through
acceptors.
|
Copyright © 2019 JBoss by Red Hat. All rights reserved.