X

Class AbstractDispatcher

Inheritance
System.Object
AbstractDispatcher
BroadcastingDispatcher
UnicastingDispatcher
Implements
Namespace: Steeltoe.Integration.Dispatcher
Assembly: Steeltoe.Integration.IntegrationBase.dll
Syntax
public abstract class AbstractDispatcher : object, IMessageDispatcher

Constructors

| Edit this page View Source

AbstractDispatcher(IApplicationContext, TaskScheduler, ILogger)

Declaration
protected AbstractDispatcher(IApplicationContext context, TaskScheduler executor, ILogger logger = null)
Parameters
Type Name Description
IApplicationContext context
TaskScheduler executor
ILogger logger

Fields

| Edit this page View Source

_context

Declaration
protected readonly IApplicationContext _context
Field Value
Type Description
IApplicationContext
| Edit this page View Source

_executor

Declaration
protected readonly TaskScheduler _executor
Field Value
Type Description
TaskScheduler
| Edit this page View Source

_factory

Declaration
protected readonly TaskFactory _factory
Field Value
Type Description
TaskFactory
| Edit this page View Source

_handlers

Declaration
protected List<IMessageHandler> _handlers
Field Value
Type Description
List<IMessageHandler>
| Edit this page View Source

_logger

Declaration
protected readonly ILogger _logger
Field Value
Type Description
ILogger

Properties

| Edit this page View Source

ErrorHandler

Declaration
public virtual IErrorHandler ErrorHandler { get; set; }
Property Value
Type Description
IErrorHandler
| Edit this page View Source

Failover

Declaration
public virtual bool Failover { get; set; }
Property Value
Type Description
System.Boolean
| Edit this page View Source

HandlerCount

Declaration
public virtual int HandlerCount { get; }
Property Value
Type Description
System.Int32
| Edit this page View Source

IntegrationServices

Declaration
public virtual IIntegrationServices IntegrationServices { get; }
Property Value
Type Description
IIntegrationServices
| Edit this page View Source

LoadBalancingStrategy

Declaration
public virtual ILoadBalancingStrategy LoadBalancingStrategy { get; set; }
Property Value
Type Description
ILoadBalancingStrategy
| Edit this page View Source

MaxSubscribers

Declaration
public virtual int MaxSubscribers { get; set; }
Property Value
Type Description
System.Int32
| Edit this page View Source

MessageHandlingDecorator

Declaration
public virtual IMessageHandlingDecorator MessageHandlingDecorator { get; set; }
Property Value
Type Description
IMessageHandlingDecorator

Methods

| Edit this page View Source

AddHandler(IMessageHandler)

Declaration
public virtual bool AddHandler(IMessageHandler handler)
Parameters
Type Name Description
IMessageHandler handler
Returns
Type Description
System.Boolean
| Edit this page View Source

Dispatch(IMessage, CancellationToken)

Declaration
public virtual bool Dispatch(IMessage message, CancellationToken cancellationToken = null)
Parameters
Type Name Description
IMessage message
CancellationToken cancellationToken
Returns
Type Description
System.Boolean
| Edit this page View Source

DoDispatch(IMessage, CancellationToken)

Declaration
protected abstract bool DoDispatch(IMessage message, CancellationToken cancellationToken)
Parameters
Type Name Description
IMessage message
CancellationToken cancellationToken
Returns
Type Description
System.Boolean
| Edit this page View Source

RemoveHandler(IMessageHandler)

Declaration
public virtual bool RemoveHandler(IMessageHandler handler)
Parameters
Type Name Description
IMessageHandler handler
Returns
Type Description
System.Boolean
| Edit this page View Source

ToString()

Declaration
public override string ToString()
Returns
Type Description
System.String
| Edit this page View Source

TryOptimizedDispatch(IMessage)

Declaration
protected virtual bool TryOptimizedDispatch(IMessage message)
Parameters
Type Name Description
IMessage message
Returns
Type Description
System.Boolean

Implements