Constructor and Description |
---|
ActiveMQProtonRemotingConnection(ProtonProtocolManager manager,
AMQPConnectionContext amqpConnection,
Connection transportConnection,
Executor executor) |
Modifier and Type | Field and Description |
---|---|
protected AMQPConnectionContext |
ActiveMQProtonConnectionCallback.amqpConnection |
Modifier and Type | Method and Description |
---|---|
AMQPConnectionContext |
ActiveMQProtonConnectionCallback.getConnection() |
Modifier and Type | Method and Description |
---|---|
AMQPSessionCallback |
ActiveMQProtonConnectionCallback.createSessionCallback(AMQPConnectionContext connection) |
void |
ActiveMQProtonConnectionCallback.onTransport(io.netty.buffer.ByteBuf byteBuf,
AMQPConnectionContext amqpConnection) |
void |
ActiveMQProtonConnectionCallback.setConnection(AMQPConnectionContext connection) |
Constructor and Description |
---|
ProtonSessionIntegrationCallback(ActiveMQProtonConnectionCallback protonSPI,
ProtonProtocolManager manager,
AMQPConnectionContext connection,
Connection transportConnection,
Executor executor) |
Modifier and Type | Interface and Description |
---|---|
interface |
AMQPClientConnectionContext
This is valid only on a client connection.
|
interface |
AMQPServerConnectionContext |
Modifier and Type | Method and Description |
---|---|
abstract AMQPConnectionContext |
AMQPConnectionContextFactory.createConnection(AMQPConnectionCallback connectionCallback,
Executor dispatchExecutor,
ScheduledExecutorService scheduledPool) |
abstract AMQPConnectionContext |
AMQPConnectionContextFactory.createConnection(AMQPConnectionCallback connectionCallback,
String containerId,
int idleTimeout,
int maxFrameSize,
int channelMax,
Executor dispatchExecutor,
ScheduledExecutorService scheduledPool) |
AMQPConnectionContext |
AMQPConnectionCallback.getConnection() |
Modifier and Type | Method and Description |
---|---|
AMQPSessionCallback |
AMQPConnectionCallback.createSessionCallback(AMQPConnectionContext connection) |
void |
AMQPConnectionCallback.onTransport(io.netty.buffer.ByteBuf bytes,
AMQPConnectionContext connection)
this is called when bytes are available to be sent to the client.
|
void |
AMQPConnectionCallback.setConnection(AMQPConnectionContext connection) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractConnectionContext |
Modifier and Type | Class and Description |
---|---|
class |
ProtonClientConnectionContext |
Modifier and Type | Method and Description |
---|---|
AMQPConnectionContext |
ProtonClientConnectionContextFactory.createConnection(AMQPConnectionCallback connectionCallback,
Executor dispatchExecutor,
ScheduledExecutorService scheduledPool) |
AMQPConnectionContext |
ProtonClientConnectionContextFactory.createConnection(AMQPConnectionCallback connectionCallback,
String containerId,
int idleTimeout,
int maxFrameSize,
int channelMax,
Executor dispatchExecutor,
ScheduledExecutorService scheduledPool) |
Modifier and Type | Class and Description |
---|---|
class |
ProtonServerConnectionContext |
Copyright © 2016 The Apache Software Foundation. All rights reserved.