Show / Hide Table of Contents

Interface IMessageProcessor

Application service for processing messages.

Namespace: Kephas.Messaging
Assembly: Kephas.Messaging.dll
Syntax
[SingletonAppServiceContract]
public interface IMessageProcessor
Remarks

The message processor is defined as a shared service.

Methods

| Improve this Doc View Source

ProcessAsync(IMessage, IMessagingContext, CancellationToken)

Processes the specified message asynchronously.

Declaration
Task<IMessage> ProcessAsync(IMessage message, IMessagingContext context = null, CancellationToken token = default(CancellationToken))
Parameters
Type Name Description
IMessage message

The message.

IMessagingContext context

Context for the message processing.

System.Threading.CancellationToken token

The cancellation token.

Returns
Type Description
System.Threading.Tasks.Task<IMessage>

The response promise.

Extension Methods

DynamicObjectExtensions.SetPropertyValue(Object, String, Object)
DynamicObjectExtensions.TrySetPropertyValue(Object, String, Object)
DynamicObjectExtensions.GetPropertyValue(Object, String)
DynamicObjectExtensions.TryGetPropertyValue(Object, String, out Object)
DynamicObjectExtensions.GetRuntimeTypeInfo(Object)
DynamicObjectExtensions.ToDynamic(Object)
DynamicObjectExtensions.ToExpando(Object)
BehaviorValue.ToBehaviorValue<TValue>(TValue)
CollectionExtensions.AddRange<T, TItem>(T, IEnumerable<TItem>)
LoggingExtensions.GetLogger(Object, IContext)
TypeExtensions.GetAbstractType(Object)
TypeExtensions.GetAbstractTypeInfo(Object)
ReflectionHelper.GetTypeInfo(Object)
MessageProcessorExtensions.ProcessAsync(IMessageProcessor, Object, IMessagingContext, CancellationToken)
EntityEntryExtensions.TryGetAttachedEntityEntry(Object)
  • Improve this Doc
  • View Source
Back to top Generated by DocFX