Class AbstractTaskSchedulerChannel

Namespace

Steeltoe.Integration.Channel

Assembly

Steeltoe.Integration.IntegrationBase.dll

public abstract class AbstractTaskSchedulerChannel : AbstractSubscribableChannel, ISubscribableChannel, IMessageChannel, IServiceNameAware, ITaskSchedulerChannelInterceptorAware, IChannelInterceptorAware

Inheritance

object

Channel<IMessage, IMessage>

Channel<IMessage>

AbstractMessageChannel

AbstractSubscribableChannel

AbstractTaskSchedulerChannel

Implements

ISubscribableChannel

IMessageChannel

IServiceNameAware

ITaskSchedulerChannelInterceptorAware

IChannelInterceptorAware

Derived

PublishSubscribeChannel

TaskSchedulerChannel

Inherited Members

AbstractSubscribableChannel.SubscriberCount

AbstractSubscribableChannel.MaxSubscribers

AbstractSubscribableChannel.Failover

AbstractSubscribableChannel.Dispatcher

AbstractSubscribableChannel.Subscribe(IMessageHandler)

AbstractSubscribableChannel.Unsubscribe(IMessageHandler)

AbstractSubscribableChannel.DoSendInternal(IMessage, CancellationToken)

AbstractMessageChannel.INDEFINITE_TIMEOUT

AbstractMessageChannel.ApplicationContext

AbstractMessageChannel.IntegrationServices

AbstractMessageChannel.ComponentType

AbstractMessageChannel.ServiceName

AbstractMessageChannel.ComponentName

AbstractMessageChannel.DataTypes

AbstractMessageChannel.MessageConverter

AbstractMessageChannel.Send(IMessage)

AbstractMessageChannel.Send(IMessage, int)

AbstractMessageChannel.SendAsync(IMessage, CancellationToken)

AbstractMessageChannel.logger

AbstractMessageChannel.DoSend(IMessage, int)

AbstractMessageChannel.DoSend(IMessage, CancellationToken)

Channel<IMessage, IMessage>.Reader

Channel<IMessage, IMessage>.Writer

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Constructors

AbstractTaskSchedulerChannel(IApplicationContext, IMessageDispatcher, ILogger)

protected AbstractTaskSchedulerChannel(IApplicationContext context, IMessageDispatcher dispatcher, ILogger logger = null)

Parameters

context IApplicationContext

dispatcher IMessageDispatcher

logger ILogger

AbstractTaskSchedulerChannel(IApplicationContext, IMessageDispatcher, TaskScheduler, ILogger)

protected AbstractTaskSchedulerChannel(IApplicationContext context, IMessageDispatcher dispatcher, TaskScheduler executor, ILogger logger = null)

Parameters

context IApplicationContext

dispatcher IMessageDispatcher

executor TaskScheduler

logger ILogger

AbstractTaskSchedulerChannel(IApplicationContext, IMessageDispatcher, TaskScheduler, string, ILogger)

protected AbstractTaskSchedulerChannel(IApplicationContext context, IMessageDispatcher dispatcher, TaskScheduler executor, string name, ILogger logger = null)

Parameters

context IApplicationContext

dispatcher IMessageDispatcher

executor TaskScheduler

name string

logger ILogger

Fields

_executor

protected TaskScheduler _executor

Field Value

TaskScheduler

_taskSchedulerInterceptorsSize

protected int _taskSchedulerInterceptorsSize

Field Value

int

Properties

ChannelInterceptors

Gets or sets the channel interceptors

public override List<IChannelInterceptor> ChannelInterceptors { get; set; }

Property Value

List<IChannelInterceptor>

HasTaskSchedulerInterceptors

Gets a value indicating whether there are any task scheduler interceptors on the channel

public virtual bool HasTaskSchedulerInterceptors { get; }

Property Value

bool

Methods

AddInterceptor(IChannelInterceptor)

Add a interceptor to the channel

public override void AddInterceptor(IChannelInterceptor interceptor)

Parameters

interceptor IChannelInterceptor

the interceptor

AddInterceptor(int, IChannelInterceptor)

Add an interceptor to the channel at the specified index

public override void AddInterceptor(int index, IChannelInterceptor interceptor)

Parameters

index int

the index to add the interceptor at

interceptor IChannelInterceptor

the interceptor

RemoveInterceptor(IChannelInterceptor)

Remove an intercetptor from the channel

public override bool RemoveInterceptor(IChannelInterceptor interceptor)

Parameters

interceptor IChannelInterceptor

the interceptor

Returns

bool

succss or failure

RemoveInterceptor(int)

Remove an interceptor at the specified index

public override IChannelInterceptor RemoveInterceptor(int index)

Parameters

index int

the index

Returns

IChannelInterceptor

removed interceptor