Interface IMessageProcessorWithResultAsync<TMessage, TResult>
public interface IMessageProcessorWithResultAsync<in TMessage, TResult> where TResult : class
Type Parameters
TMessage
TResult
Methods
ProcessMessageAsync(TMessage, MessageProperties, CancellationToken)
Task<IMessageProcessorOutputWithResult<TResult>> ProcessMessageAsync(TMessage message, MessageProperties properties, CancellationToken cancellationToken)
Parameters
message
TMessageproperties
MessagePropertiescancellationToken
CancellationToken
Returns
- Task<IMessageProcessorOutputWithResult<TResult>>