Class DelegatingMessageSink
Implementation of IMessageSink that delegates to another implementation of IMessageSink while calling into an optional callback for each message.
public class DelegatingMessageSink : IMessageSink
- Inheritance
-
DelegatingMessageSink
- Implements
- Derived
- Inherited Members
Constructors
DelegatingMessageSink(IMessageSink, Action<IMessageSinkMessage>?)
Implementation of IMessageSink that delegates to another implementation of IMessageSink while calling into an optional callback for each message.
public DelegatingMessageSink(IMessageSink innerSink, Action<IMessageSinkMessage>? callback = null)
Parameters
innerSinkIMessageSinkThe inner message sink.
callbackAction<IMessageSinkMessage>The callback.
Methods
OnMessage(IMessageSinkMessage)
Reports the presence of a message on the message bus. This method should never throw exceptions.
public virtual bool OnMessage(IMessageSinkMessage message)
Parameters
messageIMessageSinkMessageThe message from the message bus
Returns
- bool
Return
trueto continue running tests, orfalseto stop.