Class BroadcastingDispatcher

Namespace

Steeltoe.Integration.Dispatcher

Assembly

Steeltoe.Integration.IntegrationBase.dll

[Obsolete("This feature will be removed in the next major version. See https://steeltoe.io/docs/v3/obsolete for details.")]
public class BroadcastingDispatcher : AbstractDispatcher, IMessageDispatcher

Inheritance

object

AbstractDispatcher

BroadcastingDispatcher

Implements

IMessageDispatcher

Inherited Members

AbstractDispatcher._context

AbstractDispatcher._logger

AbstractDispatcher._executor

AbstractDispatcher._factory

AbstractDispatcher._handlers

AbstractDispatcher.MaxSubscribers

AbstractDispatcher.HandlerCount

AbstractDispatcher.LoadBalancingStrategy

AbstractDispatcher.Failover

AbstractDispatcher.MessageHandlingDecorator

AbstractDispatcher.IntegrationServices

AbstractDispatcher.ErrorHandler

AbstractDispatcher.AddHandler(IMessageHandler)

AbstractDispatcher.RemoveHandler(IMessageHandler)

AbstractDispatcher.ToString()

AbstractDispatcher.Dispatch(IMessage, CancellationToken)

AbstractDispatcher.TryOptimizedDispatch(IMessage)

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

Constructors

BroadcastingDispatcher(IApplicationContext, ILogger)

public BroadcastingDispatcher(IApplicationContext context, ILogger logger = null)

Parameters

context IApplicationContext

logger ILogger

BroadcastingDispatcher(IApplicationContext, bool, ILogger)

public BroadcastingDispatcher(IApplicationContext context, bool requireSubscribers, ILogger logger = null)

Parameters

context IApplicationContext

requireSubscribers bool

logger ILogger

BroadcastingDispatcher(IApplicationContext, TaskScheduler, ILogger)

public BroadcastingDispatcher(IApplicationContext context, TaskScheduler executor, ILogger logger = null)

Parameters

context IApplicationContext

executor TaskScheduler

logger ILogger

BroadcastingDispatcher(IApplicationContext, TaskScheduler, bool, ILogger)

public BroadcastingDispatcher(IApplicationContext context, TaskScheduler executor, bool requireSubscribers, ILogger logger = null)

Parameters

context IApplicationContext

executor TaskScheduler

requireSubscribers bool

logger ILogger

Properties

ApplySequence

public virtual bool ApplySequence { get; set; }

Property Value

bool

IgnoreFailures

public virtual bool IgnoreFailures { get; set; }

Property Value

bool

MinSubscribers

public virtual int MinSubscribers { get; set; }

Property Value

int

Methods

DoDispatch(IMessage, CancellationToken)

protected override bool DoDispatch(IMessage message, CancellationToken cancellationToken)

Parameters

message IMessage

cancellationToken CancellationToken

Returns

bool

InvokeHandler(IMessageHandler, IMessage)

protected void InvokeHandler(IMessageHandler handler, IMessage message)

Parameters

handler IMessageHandler

message IMessage