BaseMessageConsumer Class

Reference

Definition

Namespace:: System.Cloud.Messaging

Assembly:: System.Cloud.Messaging.Abstractions.dll

Package:: System.Cloud.Messaging.Abstractions v8.0.0-preview.4.23273.7

Important

Some information relates to prerelease product that may be substantially modified before it’s released. Microsoft makes no warranties, express or implied, with respect to the information provided here.

Reference base class implementation for IMessageConsumer.

public ref class BaseMessageConsumer : System::Cloud::Messaging::IMessageConsumer

public class BaseMessageConsumer : System.Cloud.Messaging.IMessageConsumer

type BaseMessageConsumer = class
    interface IMessageConsumer

Public Class BaseMessageConsumer
Implements IMessageConsumer

Inheritance: Object
BaseMessageConsumer

Implements: IMessageConsumer

Constructors

BaseMessageConsumer(IMessageSource, IMessageDelegate, ILogger)

Initializes a new instance of the BaseMessageConsumer class.

Properties

Logger	Gets the ILogger.
MessageDelegate	Gets the IMessageDelegate.
MessageSource	Gets the underlying IMessageSource.

Methods

ExecuteAsync(CancellationToken)	Start processing the messages.
FetchAndProcessMessageAsync(CancellationToken)	Process a single message asynchronously.
FetchMessageAsync(CancellationToken)	Fetch message from message source.
OnMessageProcessingCompletionAsync(MessageContext)	Handles the message processing completion.
OnMessageProcessingFailureAsync(MessageContext, Exception)	Handles exception occured during processing message.
ProcessingStepAsync(CancellationToken)	Represents processing steps for message(s).
ProcessMessageAsync(MessageContext)	Process a message asynchronously.
ReleaseContext(MessageContext)	Release context.

Applies to

Dela via