X

Class TaskSchedulerSubscribableChannel

Inheritance
System.Object
AbstractMessageChannel
AbstractSubscribableChannel
TaskSchedulerSubscribableChannel
Implements
IServiceNameAware
Inherited Members
Namespace: Steeltoe.Messaging.Support
Assembly: Steeltoe.Messaging.MessagingBase.dll
Syntax
public class TaskSchedulerSubscribableChannel : AbstractSubscribableChannel, IInterceptableChannel, ISubscribableChannel, IMessageChannel

Constructors

| Edit this page View Source

TaskSchedulerSubscribableChannel(ILogger)

Declaration
public TaskSchedulerSubscribableChannel(ILogger logger = null)
Parameters
Type Name Description
ILogger logger
| Edit this page View Source

TaskSchedulerSubscribableChannel(TaskScheduler, ILogger)

Declaration
public TaskSchedulerSubscribableChannel(TaskScheduler scheduler, ILogger logger = null)
Parameters
Type Name Description
TaskScheduler scheduler
ILogger logger

Fields

| Edit this page View Source

_schedulerInterceptors

Declaration
protected List<ITaskSchedulerChannelInterceptor> _schedulerInterceptors
Field Value
Type Description
List<ITaskSchedulerChannelInterceptor>

Properties

| Edit this page View Source

Factory

Declaration
protected TaskFactory Factory { get; }
Property Value
Type Description
TaskFactory
| Edit this page View Source

Scheduler

Declaration
protected TaskScheduler Scheduler { get; }
Property Value
Type Description
TaskScheduler

Methods

| Edit this page View Source

AddInterceptor(IChannelInterceptor)

Declaration
public override void AddInterceptor(IChannelInterceptor interceptor)
Parameters
Type Name Description
IChannelInterceptor interceptor
Overrides
| 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
| Edit this page View Source

DoSendInternal(IMessage, CancellationToken)

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

SetInterceptors(List<IChannelInterceptor>)

Declaration
public override void SetInterceptors(List<IChannelInterceptor> interceptors)
Parameters
Type Name Description
List<IChannelInterceptor> interceptors
Overrides

Implements

IServiceNameAware