Class MessageProcessorExtensions

Extension methods for message processor.

Inheritance

System.Object

MessageProcessorExtensions

Inherited Members

System.Object.Equals(System.Object)

System.Object.Equals(System.Object, System.Object)

System.Object.GetHashCode()

System.Object.GetType()

System.Object.MemberwiseClone()

System.Object.ReferenceEquals(System.Object, System.Object)

System.Object.ToString()

Namespace: Kephas.Messaging

Assembly: Kephas.Messaging.dll

Syntax

public static class MessageProcessorExtensions

Methods

ProcessAsync(IMessageProcessor, Object, IMessagingContext, CancellationToken)

Processes the specified message asynchronously.

Declaration

public static Task<IMessage> ProcessAsync(this IMessageProcessor this, object message, IMessagingContext context = null, CancellationToken token = default(CancellationToken))

Parameters

Type	Name	Description
IMessageProcessor	this	The message processor to act on.
System.Object	message	The message.
IMessagingContext	context	Optional. Context for the message processing.
System.Threading.CancellationToken	token	Optional. The cancellation token.

Returns

Type	Description
System.Threading.Tasks.Task<IMessage>	The response promise.