Class TaskSchedulerSubscribableChannel

Namespace

Steeltoe.Messaging.Support

Assembly

Steeltoe.Messaging.MessagingBase.dll

public class TaskSchedulerSubscribableChannel : AbstractSubscribableChannel, IInterceptableChannel, ISubscribableChannel, IMessageChannel, IServiceNameAware

Inheritance

object

Channel<IMessage, IMessage>

Channel<IMessage>

AbstractMessageChannel

AbstractSubscribableChannel

TaskSchedulerSubscribableChannel

Implements

IInterceptableChannel

ISubscribableChannel

IMessageChannel

IServiceNameAware

Inherited Members

AbstractSubscribableChannel.SubscriberCount

AbstractSubscribableChannel.Subscribers

AbstractSubscribableChannel.HasSubscription(IMessageHandler)

AbstractSubscribableChannel.Subscribe(IMessageHandler)

AbstractSubscribableChannel.Unsubscribe(IMessageHandler)

AbstractMessageChannel.INDEFINITE_TIMEOUT

AbstractMessageChannel.ServiceName

AbstractMessageChannel.Logger

AbstractMessageChannel.GetInterceptors()

AbstractMessageChannel.RemoveInterceptor(IChannelInterceptor)

AbstractMessageChannel.RemoveInterceptor(int)

AbstractMessageChannel.Send(IMessage)

AbstractMessageChannel.Send(IMessage, int)

AbstractMessageChannel.SendAsync(IMessage, CancellationToken)

AbstractMessageChannel.ToString()

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)

Constructors

TaskSchedulerSubscribableChannel(ILogger)

public TaskSchedulerSubscribableChannel(ILogger logger = null)

Parameters

logger ILogger

TaskSchedulerSubscribableChannel(TaskScheduler, ILogger)

public TaskSchedulerSubscribableChannel(TaskScheduler scheduler, ILogger logger = null)

Parameters

scheduler TaskScheduler

logger ILogger

Fields

_schedulerInterceptors

protected List<ITaskSchedulerChannelInterceptor> _schedulerInterceptors

Field Value

List<ITaskSchedulerChannelInterceptor>

Properties

Factory

protected TaskFactory Factory { get; }

Property Value

TaskFactory

Scheduler

protected TaskScheduler Scheduler { get; }

Property Value

TaskScheduler

Methods

AddInterceptor(IChannelInterceptor)

Add an interceptor to the list

public override void AddInterceptor(IChannelInterceptor interceptor)

Parameters

interceptor IChannelInterceptor

the interceptor to add

AddInterceptor(int, IChannelInterceptor)

Add an interceptor at the location specified by the index

public override void AddInterceptor(int index, IChannelInterceptor interceptor)

Parameters

index int

the index to add the interceptor at

interceptor IChannelInterceptor

the interceptor to add

DoSendInternal(IMessage, CancellationToken)

protected override bool DoSendInternal(IMessage message, CancellationToken cancellationToken)

Parameters

message IMessage

cancellationToken CancellationToken

Returns

bool

SetInterceptors(List<IChannelInterceptor>)

Set the list of channel interceptors

public override void SetInterceptors(List<IChannelInterceptor> interceptors)

Parameters

interceptors List<IChannelInterceptor>

the interceptors to use