DefaultMessageConsumer Class

Definition

Namespace:

System.Cloud.Messaging

Assembly:

System.Cloud.Messaging.dll

Package:

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

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)