Modifier and Type | Method and Description |
---|---|
ProtocolEngine |
ProtocolEngineCreator.newProtocolEngine(Broker<?> broker,
ServerNetworkConnection network,
AmqpPort<?> port,
Transport transport,
long id,
AggregateTicker aggregateTicker) |
Modifier and Type | Class and Description |
---|---|
class |
AMQPConnection_0_10 |
Modifier and Type | Method and Description |
---|---|
ProtocolEngine |
ProtocolEngineCreator_0_10.newProtocolEngine(Broker<?> broker,
ServerNetworkConnection network,
AmqpPort<?> port,
Transport transport,
long id,
AggregateTicker aggregateTicker) |
Modifier and Type | Method and Description |
---|---|
void |
AMQPConnection_0_10.setWorkListener(Action<ProtocolEngine> listener) |
Constructor and Description |
---|
CreditCreditManager(long bytesCredit,
long messageCredit,
ProtocolEngine protocolEngine) |
WindowCreditManager(long bytesCreditLimit,
long messageCreditLimit,
ProtocolEngine protocolEngine) |
Modifier and Type | Class and Description |
---|---|
class |
AMQPConnection_0_8 |
Modifier and Type | Method and Description |
---|---|
ProtocolEngine |
ProtocolEngineCreator_0_9.newProtocolEngine(Broker<?> broker,
ServerNetworkConnection network,
AmqpPort<?> port,
Transport transport,
long id,
AggregateTicker aggregateTicker) |
ProtocolEngine |
ProtocolEngineCreator_0_8.newProtocolEngine(Broker<?> broker,
ServerNetworkConnection network,
AmqpPort<?> port,
Transport transport,
long id,
AggregateTicker aggregateTicker) |
ProtocolEngine |
ProtocolEngineCreator_0_9_1.newProtocolEngine(Broker<?> broker,
ServerNetworkConnection network,
AmqpPort<?> port,
Transport transport,
long id,
AggregateTicker aggregateTicker) |
Modifier and Type | Method and Description |
---|---|
void |
AMQPConnection_0_8.setWorkListener(Action<ProtocolEngine> listener) |
Constructor and Description |
---|
NoAckCreditManager(ProtocolEngine protocolEngine) |
Pre0_10CreditManager(long bytesCreditLimit,
long messageCreditLimit,
ProtocolEngine protocolEngine) |
Modifier and Type | Class and Description |
---|---|
class |
AMQPConnection_1_0 |
Modifier and Type | Method and Description |
---|---|
ProtocolEngine |
ProtocolEngineCreator_1_0_0.newProtocolEngine(Broker<?> broker,
ServerNetworkConnection network,
AmqpPort<?> port,
Transport transport,
long id,
AggregateTicker aggregateTicker) |
ProtocolEngine |
ProtocolEngineCreator_1_0_0_SASL.newProtocolEngine(Broker<?> broker,
ServerNetworkConnection network,
AmqpPort<?> port,
Transport transport,
long id,
AggregateTicker aggregateTicker) |
Modifier and Type | Method and Description |
---|---|
void |
AMQPConnection_1_0.setWorkListener(Action<ProtocolEngine> listener) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractAMQPConnection<C extends AbstractAMQPConnection<C>> |
class |
MultiVersionProtocolEngine |
Modifier and Type | Method and Description |
---|---|
ProtocolEngine |
AbstractAMQPConnection.getProtocolEngine() |
ProtocolEngine |
ProtocolEngineFactory.newProtocolEngine(SocketAddress remoteSocketAddress) |
Modifier and Type | Method and Description |
---|---|
void |
ProtocolEngine.setWorkListener(Action<ProtocolEngine> listener) |
void |
MultiVersionProtocolEngine.setWorkListener(Action<ProtocolEngine> listener) |
Constructor and Description |
---|
NonBlockingConnection(SocketChannel socketChannel,
ProtocolEngine protocolEngine,
Set<TransportEncryption> encryptionSet,
Runnable onTransportEncryptionAction,
NetworkConnectionScheduler scheduler,
AmqpPort port) |
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.