Proton DotNet
|
A context object that is assigned to each new engine handler that is inserted into an engine handler pipeline. More...
Public Member Functions | |
ProtonEngineHandlerContext (string name, IEngine engine, IEngineHandler handler) | |
virtual void | FireEngineStarting () |
Fires the engine starting event into the next handler in the engine pipeline. | |
virtual void | FireEngineStateChanged () |
Fires the engine state changed event into the next handler in the EnginePipeline chain. The state change events occur after the engine starting event and generally signify that the engine has been shutdown normally. | |
virtual void | FireFailed (EngineFailedException ex) |
Fires the engine failed event into the next handler in the {engine pipeline chain. | |
virtual void | FireRead (IProtonBuffer buffer) |
Fires a read event into the previous handler in the engine pipeline for further processing or dispatch to the next in line. | |
virtual void | FireRead (HeaderEnvelope header) |
Fires a read of AMQP header events into the previous handler in the engine pipeline for further processing. | |
virtual void | FireRead (SaslEnvelope envelope) |
Fires a read of SASL performative envelope events into the previous handler in the engine pipeline for further processing. | |
virtual void | FireRead (IncomingAmqpEnvelope envelope) |
Fires a read of AMQP performative envelope events into the previous handler in the engine pipeline for further processing. | |
virtual void | FireWrite (OutgoingAmqpEnvelope envelope) |
Fires a write of the given AMQP performative envelope which should be passed along the engine pipeline for processing. | |
virtual void | FireWrite (SaslEnvelope envelope) |
Fires a write of the given SASL performative envelope which should be passed along the engine pipeline for processing. | |
virtual void | FireWrite (HeaderEnvelope envelope) |
Fires a write of the given AMQP Header envelope which should be passed along the engine pipeline for processing. | |
virtual void | FireWrite (IProtonBuffer buffer, Action ioComplete) |
Fires a write of the given proton buffer into the engine pipeline for processing and provides an action delegate which should be invoked when the IO has written the bytes fully. | |
Static Public Attributes | |
static readonly uint | HANDLER_READS = 1 << 1 |
The context indicator for a handler that wants to be sent read events. | |
static readonly uint | HANDLER_WRITES = 1 << 2 |
The context indicator for a handler that wants to be sent write events. | |
static readonly uint | HANDLER_ALL_EVENTS = HANDLER_READS | HANDLER_WRITES |
The context indicator for a handler that wants to be sent all read and write events. | |
Properties | |
IEngineHandler | Handler [get] |
Access the engine handler that this context is assigned to. | |
IEngine | Engine [get] |
Access the engine instance where this context and its handler are assigned. | |
string | Name [get] |
Access the name that was given to the handler assigned to this context. | |
uint | InterestMask [get, set] |
Allows a handler to indicate if it wants to be notified of a Engine Handler events for specific operations or opt into all engine handler events. By opting out of the events that the handler does not process the call chain can be reduced when processing engine events. | |
![]() |
A context object that is assigned to each new engine handler that is inserted into an engine handler pipeline.
|
inlinevirtual |
Fires the engine starting event into the next handler in the engine pipeline.
Implements Apache.Qpid.Proton.Engine.IEngineHandlerContext.
|
inlinevirtual |
Fires the engine state changed event into the next handler in the EnginePipeline
chain. The state change events occur after the engine starting event and generally signify that the engine has been shutdown normally.
Implements Apache.Qpid.Proton.Engine.IEngineHandlerContext.
|
inlinevirtual |
Fires the engine failed event into the next handler in the {engine pipeline chain.
ex | The exception that triggered the failure |
Implements Apache.Qpid.Proton.Engine.IEngineHandlerContext.
|
inlinevirtual |
Fires a read of AMQP header events into the previous handler in the engine pipeline for further processing.
header |
Implements Apache.Qpid.Proton.Engine.IEngineHandlerContext.
|
inlinevirtual |
Fires a read of AMQP performative envelope events into the previous handler in the engine pipeline for further processing.
envelope | The incoming envelope that was read. |
Implements Apache.Qpid.Proton.Engine.IEngineHandlerContext.
|
inlinevirtual |
Fires a read event into the previous handler in the engine pipeline for further processing or dispatch to the next in line.
buffer | The buffer containing the bytes read |
Implements Apache.Qpid.Proton.Engine.IEngineHandlerContext.
|
inlinevirtual |
Fires a read of SASL performative envelope events into the previous handler in the engine pipeline for further processing.
envelope | The incoming envelope that was read. |
Implements Apache.Qpid.Proton.Engine.IEngineHandlerContext.
|
inlinevirtual |
Fires a write of the given AMQP Header envelope which should be passed along the engine pipeline for processing.
envelope | The outgoing envelope that should be written. |
Implements Apache.Qpid.Proton.Engine.IEngineHandlerContext.
|
inlinevirtual |
Fires a write of the given proton buffer into the engine pipeline for processing and provides an action delegate which should be invoked when the IO has written the bytes fully.
buffer | The buffer that should be written to the IO layer |
ioComplete | The completion action to invoke when the IO is done |
Implements Apache.Qpid.Proton.Engine.IEngineHandlerContext.
|
inlinevirtual |
Fires a write of the given AMQP performative envelope which should be passed along the engine pipeline for processing.
envelope | The outgoing envelope that should be written. |
Implements Apache.Qpid.Proton.Engine.IEngineHandlerContext.
|
inlinevirtual |
Fires a write of the given SASL performative envelope which should be passed along the engine pipeline for processing.
envelope | The outgoing envelope that should be written. |
Implements Apache.Qpid.Proton.Engine.IEngineHandlerContext.
|
get |
Access the engine instance where this context and its handler are assigned.
Implements Apache.Qpid.Proton.Engine.IEngineHandlerContext.
|
get |
Access the engine handler that this context is assigned to.
Implements Apache.Qpid.Proton.Engine.IEngineHandlerContext.
|
get |
Access the name that was given to the handler assigned to this context.
Implements Apache.Qpid.Proton.Engine.IEngineHandlerContext.