Share via


MessageProcessor Class

Definition

This class defines a strategy used for processing Service Bus messages.

public class MessageProcessor
type MessageProcessor = class
Public Class MessageProcessor
Inheritance
MessageProcessor

Constructors

MessageProcessor(MessageReceiver, MessageHandlerOptions)
MessageProcessor(ServiceBusProcessor)

Initializes a new instance of MessageProcessor.

Properties

MessageOptions
MessageReceiver
Processor

Gets or sets the ServiceBusProcessor that will be used by the Processor.

Methods

BeginProcessingMessageAsync(Message, CancellationToken)
BeginProcessingMessageAsync(ServiceBusMessageActions, ServiceBusReceivedMessage, CancellationToken)

This method is called when there is a new message to process, before the job function is invoked. This allows any preprocessing to take place on the message before processing begins.

CompleteProcessingMessageAsync(Message, FunctionResult, CancellationToken)
CompleteProcessingMessageAsync(ServiceBusMessageActions, ServiceBusReceivedMessage, FunctionResult, CancellationToken)

This method completes processing of the specified message, after the job function has been invoked.

Applies to