| 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 © 2024 The Apache Software Foundation. All rights reserved.