Class PublisherConsumerBehavior

Publishes the consumed messages via the message bus.

Inheritance

object

PublisherConsumerBehavior

Implements

IConsumerBehavior

IBrokerBehavior

ISorted

Inherited Members

object.GetType()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Namespace: Silverback.Messaging.Consuming

Assembly: Silverback.Integration.dll

Syntax

public sealed class PublisherConsumerBehavior : IConsumerBehavior, IBrokerBehavior, ISorted

Constructors

PublisherConsumerBehavior(ISilverbackLogger<PublisherConsumerBehavior>)

Initializes a new instance of the PublisherConsumerBehavior class.

Declaration

public PublisherConsumerBehavior(ISilverbackLogger<PublisherConsumerBehavior> logger)

Parameters

Type	Name	Description
ISilverbackLogger<PublisherConsumerBehavior>	logger	The ISilverbackLogger<TCategoryName>.

Properties

SortIndex

Gets the sort index.

Declaration

public int SortIndex { get; }

Property Value

Type	Description
int

Methods

HandleAsync(ConsumerPipelineContext, ConsumerBehaviorHandler, CancellationToken)

Process, handles or transforms the message being consumed.

Declaration

public ValueTask HandleAsync(ConsumerPipelineContext context, ConsumerBehaviorHandler next, CancellationToken cancellationToken)

Parameters

Type	Name	Description
ConsumerPipelineContext	context	The context that is passed along the behaviors pipeline.
ConsumerBehaviorHandler	next	The next behavior in the pipeline.
CancellationToken	cancellationToken	The cancellation token that can be used to cancel the operation.

Returns

Type	Description
ValueTask	A ValueTask representing the asynchronous operation.

Implements

IConsumerBehavior

IBrokerBehavior

ISorted