Frame object that carries an AMQP Performative.
More...
|
|
void | Release () |
| | Used to release a Frame that was taken from a Frame pool in order to make it available for the next input operations. Once called the contents of the Frame are invalid and cannot be used again inside the same context.
|
| |
| OutgoingAmqpEnvelope | HandlePayloadToLarge () |
| | Called when the encoder determines that the encoding of the Performative plus any payload value is to large for a single AMQP frame. The configured handler should update the performative in preparation for encoding as a split framed AMQP transfer.
|
| |
| OutgoingAmqpEnvelope | HandleOutgoingFrameWriteComplete () |
| | Called by the encoder when the write of a frame that comprises the transfer of the AMQP performative plus any assigned payload has completed. If the transfer comprises multiple frame writes this handler should be invoked as each frame is successfully written by the IO layer.
|
| |
| void | Invoke< T > (IPerformativeHandler< T > handler, T context) |
| | Invoke the correct performative handler event based on the body of this AMQP performative.
|
| |
|
|
static readonly byte | AmqpFrameType = 0 |
| |
|
|
Action< IPerformative > | PayloadToLargeHandler [set] |
| | 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.
|
| |
|
Action | FrameWriteCompletionHandler [set] |
| | 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.
|
| |
|
T | Body [get] |
| | Access the performative that is the body of this envelope.
|
| |
|
ushort | Channel [get] |
| | Access the channel on which the performative was received.
|
| |
|
IProtonBuffer | Payload [get] |
| | Access the payload bytes that arrived with the performative.
|
| |
|
byte | FrameType [get] |
| | Provides the frame type that defines what types of performatives can be received.
|
| |
Frame object that carries an AMQP Performative.
◆ HandleOutgoingFrameWriteComplete()
| OutgoingAmqpEnvelope Apache.Qpid.Proton.Engine.OutgoingAmqpEnvelope.HandleOutgoingFrameWriteComplete |
( |
| ) |
|
|
inline |
Called by the encoder when the write of a frame that comprises the transfer of the AMQP performative plus any assigned payload has completed. If the transfer comprises multiple frame writes this handler should be invoked as each frame is successfully written by the IO layer.
- Returns
- This outgoing performative envelope instance.
◆ HandlePayloadToLarge()
Called when the encoder determines that the encoding of the Performative plus any payload value is to large for a single AMQP frame. The configured handler should update the performative in preparation for encoding as a split framed AMQP transfer.
- Returns
- This outgoing performative envelope instance.
◆ Invoke< T >()
| void Apache.Qpid.Proton.Engine.OutgoingAmqpEnvelope.Invoke< T > |
( |
IPerformativeHandler< T > |
handler, |
|
|
T |
context |
|
) |
| |
|
inline |
Invoke the correct performative handler event based on the body of this AMQP performative.
- Template Parameters
-
| T | The type of context that will be provided to the invocation |
- Parameters
-
| handler | The handle to invoke an event on. |
| context | The context to pass to the event invocation |
The documentation for this class was generated from the following file:
- src/Proton/Engine/OutgoingAmqpEnvelope.cs
Properties inherited from Apache.Qpid.Proton.Engine.PerformativeEnvelope< IPerformative >