Uses of Class
org.apache.qpid.protonj2.engine.OutgoingAMQPEnvelope
-
Packages that use OutgoingAMQPEnvelope Package Description org.apache.qpid.protonj2.engine org.apache.qpid.protonj2.engine.impl org.apache.qpid.protonj2.engine.impl.sasl -
-
Uses of OutgoingAMQPEnvelope in org.apache.qpid.protonj2.engine
Methods in org.apache.qpid.protonj2.engine that return OutgoingAMQPEnvelope Modifier and Type Method Description OutgoingAMQPEnvelope
OutgoingAMQPEnvelope. 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
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
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
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.Methods in org.apache.qpid.protonj2.engine that return types with arguments of type OutgoingAMQPEnvelope Modifier and Type Method Description static AMQPPerformativeEnvelopePool<OutgoingAMQPEnvelope>
AMQPPerformativeEnvelopePool. outgoingEnvelopePool()
static AMQPPerformativeEnvelopePool<OutgoingAMQPEnvelope>
AMQPPerformativeEnvelopePool. outgoingEnvelopePool(int maxPoolSize)
Methods in org.apache.qpid.protonj2.engine with parameters of type OutgoingAMQPEnvelope Modifier and Type Method Description void
EngineHandlerContext. fireWrite(OutgoingAMQPEnvelope envelope)
Fires a write ofOutgoingAMQPEnvelope
events into the next handler in theEnginePipeline
for further processing.EnginePipeline
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
Methods in org.apache.qpid.protonj2.engine.impl with parameters of type OutgoingAMQPEnvelope Modifier and Type Method Description void
ProtonEngineHandlerContext. fireWrite(OutgoingAMQPEnvelope envelope)
ProtonEnginePipeline
ProtonEnginePipeline. fireWrite(OutgoingAMQPEnvelope envelope)
ProtonEnginePipelineProxy
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
Methods in org.apache.qpid.protonj2.engine.impl.sasl with parameters of type OutgoingAMQPEnvelope Modifier and Type Method Description void
ProtonSaslHandler. handleWrite(EngineHandlerContext context, OutgoingAMQPEnvelope frame)
-