Uses of Class
org.apache.qpid.protonj2.engine.OutgoingAMQPEnvelope
Packages that use OutgoingAMQPEnvelope
Package
Description
-
Uses of OutgoingAMQPEnvelope in org.apache.qpid.protonj2.engine
Methods in org.apache.qpid.protonj2.engine that return OutgoingAMQPEnvelopeModifier and TypeMethodDescriptionOutgoingAMQPEnvelope.handleOutgoingFrameWriteComplete()Called by the encoder when the write of a frame that comprises the transfer of the AMQPPerformativeplus any assigned payload has completed.OutgoingAMQPEnvelope.handlePayloadToLarge()Called when the encoder determines that the encoding of thePerformativeplus 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.Methods in org.apache.qpid.protonj2.engine that return types with arguments of type OutgoingAMQPEnvelopeModifier and TypeMethodDescriptionAMQPPerformativeEnvelopePool.outgoingEnvelopePool()AMQPPerformativeEnvelopePool.outgoingEnvelopePool(int maxPoolSize) Methods in org.apache.qpid.protonj2.engine with parameters of type OutgoingAMQPEnvelopeModifier and TypeMethodDescriptionvoidEngineHandlerContext.fireWrite(OutgoingAMQPEnvelope envelope) Fires a write ofOutgoingAMQPEnvelopeevents into the next handler in theEnginePipelinefor further processing.EnginePipeline.fireWrite(OutgoingAMQPEnvelope envelope) Fires a write event consisting of the givenOutgoingAMQPEnvelopeinto the pipeline starting from the firstEngineHandlerin the pipeline and moving through each until the outgoing work is fully processed.default voidEngineHandler.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 theProtonBufferbased 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 OutgoingAMQPEnvelopeModifier and TypeMethodDescriptionvoidProtonEngineHandlerContext.fireWrite(OutgoingAMQPEnvelope envelope) ProtonEnginePipeline.fireWrite(OutgoingAMQPEnvelope envelope) ProtonEnginePipelineProxy.fireWrite(OutgoingAMQPEnvelope envelope) voidProtonFrameEncodingHandler.handleWrite(EngineHandlerContext context, OutgoingAMQPEnvelope envelope) voidProtonFrameLoggingHandler.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 OutgoingAMQPEnvelopeModifier and TypeMethodDescriptionvoidProtonSaslHandler.handleWrite(EngineHandlerContext context, OutgoingAMQPEnvelope frame)