Uses of Class
org.apache.qpid.protonj2.engine.OutgoingAMQPEnvelope
Package
Description
-
Uses of OutgoingAMQPEnvelope in org.apache.qpid.protonj2.engine
Modifier and TypeMethodDescriptionOutgoingAMQPEnvelope.handleOutgoingFrameWriteComplete()
Called by the encoder when the write of a frame that comprises the transfer of the AMQPPerformative
plus any assigned payload has completed.OutgoingAMQPEnvelope.handlePayloadToLarge()
Called when the encoder determines that the encoding of thePerformative
plus any payload value is to large for a single AMQP frame.OutgoingAMQPEnvelope.setFrameWriteCompletionHandler
(Runnable frameWriteCompleteHandler) Configures a handler to be invoked when a write operation that was handed off to the I/O layer has completed indicated that a single frame portion of the payload has been fully written.OutgoingAMQPEnvelope.setPayloadToLargeHandler
(Consumer<Performative> payloadToLargeHandler) Configures a handler to be invoked if the payload that is being transmitted with this performative is to large to allow encoding the frame within the maximum configured AMQP frame size limit.Modifier and TypeMethodDescriptionAMQPPerformativeEnvelopePool.outgoingEnvelopePool()
AMQPPerformativeEnvelopePool.outgoingEnvelopePool
(int maxPoolSize) Modifier and TypeMethodDescriptionvoid
EngineHandlerContext.fireWrite
(OutgoingAMQPEnvelope envelope) Fires a write ofOutgoingAMQPEnvelope
events into the next handler in theEnginePipeline
for further processing.EnginePipeline.fireWrite
(OutgoingAMQPEnvelope envelope) Fires a write event consisting of the givenOutgoingAMQPEnvelope
into the pipeline starting from the firstEngineHandler
in the pipeline and moving through each until the outgoing work is fully processed.default void
EngineHandler.handleWrite
(EngineHandlerContext context, OutgoingAMQPEnvelope envelope) Handles write of AMQP performative envelope either by directly writing it to the output target or by converting it to bytes and firing a write using theProtonBuffer
based API inEngineHandlerContext.fireWrite(ProtonBuffer, Runnable)
-
Uses of OutgoingAMQPEnvelope in org.apache.qpid.protonj2.engine.impl
Modifier and TypeMethodDescriptionvoid
ProtonEngineHandlerContext.fireWrite
(OutgoingAMQPEnvelope envelope) ProtonEnginePipeline.fireWrite
(OutgoingAMQPEnvelope envelope) ProtonEnginePipelineProxy.fireWrite
(OutgoingAMQPEnvelope envelope) void
ProtonFrameEncodingHandler.handleWrite
(EngineHandlerContext context, OutgoingAMQPEnvelope envelope) void
ProtonFrameLoggingHandler.handleWrite
(EngineHandlerContext context, OutgoingAMQPEnvelope envelope) -
Uses of OutgoingAMQPEnvelope in org.apache.qpid.protonj2.engine.impl.sasl
Modifier and TypeMethodDescriptionvoid
ProtonSaslHandler.handleWrite
(EngineHandlerContext context, OutgoingAMQPEnvelope frame)