Interface IMessageProcessorAsync<TMessage>
public interface IMessageProcessorAsync<in TMessage>
Type Parameters
TMessage
Methods
ProcessMessageAsync(TMessage, MessageProperties, CancellationToken)
Task<IMessageProcessorOutput> ProcessMessageAsync(TMessage message, MessageProperties properties, CancellationToken cancellationToken)
Parameters
message
TMessageproperties
MessagePropertiescancellationToken
CancellationToken