DefaultMessageConsumer Class

Reference

Definition

Namespace:: System.Cloud.Messaging

Assembly:: System.Cloud.Messaging.dll

Package:: System.Cloud.Messaging v8.0.0-rc.1.23453.1

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.

Provides default implementation to MessageConsumer.

public ref class DefaultMessageConsumer sealed : System::Cloud::Messaging::MessageConsumer

public sealed class DefaultMessageConsumer : System.Cloud.Messaging.MessageConsumer

type DefaultMessageConsumer = class
    inherit MessageConsumer

Public NotInheritable Class DefaultMessageConsumer
Inherits MessageConsumer

Inheritance: Object

MessageConsumer
DefaultMessageConsumer

Constructors

DefaultMessageConsumer(IMessageSource, IReadOnlyList<IMessageMiddleware>, MessageDelegate, ILogger)

Initializes a new instance of the DefaultMessageConsumer class.

Properties

Logger	Gets the logger. (Inherited from MessageConsumer)
MessageSource	Gets the underlying message source. (Inherited from MessageConsumer)
PipelineDelegate	Gets the message delegate composed from the pipeline of IMessageMiddleware implementations and a terminal MessageDelegate. (Inherited from MessageConsumer)

Methods

ExecuteAsync(CancellationToken)	Start processing the messages. (Inherited from MessageConsumer)
FetchAndProcessMessageAsync(CancellationToken)	Fetches a MessageContext via the FetchMessageAsync(CancellationToken) and processes it asynchronously via ProcessMessageAsync(MessageContext). (Inherited from MessageConsumer)
FetchMessageAsync(CancellationToken)	Fetches message from the message source. (Inherited from MessageConsumer)
HandleMessageProcessingCompletionAsync(MessageContext)	Handles the completion of the message processing. (Inherited from MessageConsumer)
HandleMessageProcessingFailureAsync(MessageContext, Exception)	Handles failures that occur during the message processing. (Inherited from MessageConsumer)
ProcessingStepAsync(CancellationToken)	Represents processing steps for message(s). (Inherited from MessageConsumer)
ProcessMessageAsync(MessageContext)	Processes a message asynchronously. (Inherited from MessageConsumer)
ReleaseContext(MessageContext)	Releases the message context. (Inherited from MessageConsumer)
ShouldStopConsumer(MessageContext)	Determines if the consumer should stop processing. (Inherited from MessageConsumer)

Applies to

Dela via