Class AbstractTaskSchedulerChannel

Inheritance

System.Object

AbstractMessageChannel

AbstractSubscribableChannel

AbstractTaskSchedulerChannel

PublishSubscribeChannel

TaskSchedulerChannel

Implements

IMessageChannel

ISubscribableChannel

ITaskSchedulerChannelInterceptorAware

IChannelInterceptorAware

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, Int32)

AbstractMessageChannel.SendAsync(IMessage, CancellationToken)

AbstractMessageChannel.logger

AbstractMessageChannel.DoSend(IMessage, Int32)

AbstractMessageChannel.DoSend(IMessage, CancellationToken)

Namespace: Steeltoe.Integration.Channel

Assembly: Steeltoe.Integration.IntegrationBase.dll

Syntax

public abstract class AbstractTaskSchedulerChannel : AbstractSubscribableChannel, ITaskSchedulerChannelInterceptorAware, IChannelInterceptorAware

Constructors

| Edit this page View Source

AbstractTaskSchedulerChannel(IApplicationContext, IMessageDispatcher, ILogger)

Declaration

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

Parameters

Type	Name	Description
IApplicationContext	context
IMessageDispatcher	dispatcher
ILogger	logger

| Edit this page View Source

AbstractTaskSchedulerChannel(IApplicationContext, IMessageDispatcher, TaskScheduler, ILogger)

Declaration

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

Parameters

Type	Name	Description
IApplicationContext	context
IMessageDispatcher	dispatcher
TaskScheduler	executor
ILogger	logger

| Edit this page View Source

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

Declaration

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

Parameters

Type	Name	Description
IApplicationContext	context
IMessageDispatcher	dispatcher
TaskScheduler	executor
System.String	name
ILogger	logger

Fields

| Edit this page View Source

_executor

Declaration

protected TaskScheduler _executor

Field Value

Type	Description
TaskScheduler

| Edit this page View Source

_taskSchedulerInterceptorsSize

Declaration

protected int _taskSchedulerInterceptorsSize

Field Value

Type	Description
System.Int32

Properties

| Edit this page View Source

ChannelInterceptors

Declaration

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

Property Value

Type	Description
List<IChannelInterceptor>

Overrides

AbstractMessageChannel.ChannelInterceptors

| Edit this page View Source

HasTaskSchedulerInterceptors

Declaration

public virtual bool HasTaskSchedulerInterceptors { get; }

Property Value

Type	Description
System.Boolean

Methods

| Edit this page View Source

AddInterceptor(IChannelInterceptor)

Declaration

public override void AddInterceptor(IChannelInterceptor interceptor)

Parameters

Type	Name	Description
IChannelInterceptor	interceptor

Overrides

AbstractMessageChannel.AddInterceptor(IChannelInterceptor)

| Edit this page View Source

AddInterceptor(Int32, IChannelInterceptor)

Declaration

public override void AddInterceptor(int index, IChannelInterceptor interceptor)

Parameters

Type	Name	Description
System.Int32	index
IChannelInterceptor	interceptor

Overrides

AbstractMessageChannel.AddInterceptor(Int32, IChannelInterceptor)

| Edit this page View Source

RemoveInterceptor(IChannelInterceptor)

Declaration

public override bool RemoveInterceptor(IChannelInterceptor interceptor)

Parameters

Type	Name	Description
IChannelInterceptor	interceptor

Returns

Type	Description
System.Boolean

Overrides

AbstractMessageChannel.RemoveInterceptor(IChannelInterceptor)

| Edit this page View Source

RemoveInterceptor(Int32)

Declaration

public override IChannelInterceptor RemoveInterceptor(int index)

Parameters

Type	Name	Description
System.Int32	index

Returns

Type	Description
IChannelInterceptor

Overrides

AbstractMessageChannel.RemoveInterceptor(Int32)

Implements

IMessageChannel

ISubscribableChannel

ITaskSchedulerChannelInterceptorAware

IChannelInterceptorAware