BaseMessageConsumer Class

Definition

Namespace:

System.Cloud.Messaging

Assembly:

System.Cloud.Messaging.Abstractions.dll

Package:

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

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.