Class PublishSubscribeChannel

Namespace

Steeltoe.Integration.Channel

Assembly

Steeltoe.Integration.IntegrationBase.dll

public class PublishSubscribeChannel : AbstractTaskSchedulerChannel, ISubscribableChannel, IMessageChannel, IServiceNameAware, ITaskSchedulerChannelInterceptorAware, IChannelInterceptorAware

Inheritance

object

Channel<IMessage, IMessage>

Channel<IMessage>

AbstractMessageChannel

AbstractSubscribableChannel

AbstractTaskSchedulerChannel

PublishSubscribeChannel

Implements

ISubscribableChannel

IMessageChannel

IServiceNameAware

ITaskSchedulerChannelInterceptorAware

IChannelInterceptorAware

Inherited Members

AbstractTaskSchedulerChannel._executor

AbstractTaskSchedulerChannel._taskSchedulerInterceptorsSize

AbstractTaskSchedulerChannel.ChannelInterceptors

AbstractTaskSchedulerChannel.AddInterceptor(IChannelInterceptor)

AbstractTaskSchedulerChannel.AddInterceptor(int, IChannelInterceptor)

AbstractTaskSchedulerChannel.RemoveInterceptor(IChannelInterceptor)

AbstractTaskSchedulerChannel.RemoveInterceptor(int)

AbstractTaskSchedulerChannel.HasTaskSchedulerInterceptors

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.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

PublishSubscribeChannel(ILogger)

public PublishSubscribeChannel(ILogger logger = null)

Parameters

logger ILogger

PublishSubscribeChannel(IApplicationContext, ILogger)

public PublishSubscribeChannel(IApplicationContext context, ILogger logger = null)

Parameters

context IApplicationContext

logger ILogger

PublishSubscribeChannel(IApplicationContext, string, ILogger)

public PublishSubscribeChannel(IApplicationContext context, string name, ILogger logger = null)

Parameters

context IApplicationContext

name string

logger ILogger

PublishSubscribeChannel(IApplicationContext, TaskScheduler, ILogger)

public PublishSubscribeChannel(IApplicationContext context, TaskScheduler executor, ILogger logger = null)

Parameters

context IApplicationContext

executor TaskScheduler

logger ILogger

PublishSubscribeChannel(IApplicationContext, TaskScheduler, string, ILogger)

public PublishSubscribeChannel(IApplicationContext context, TaskScheduler executor, string name, ILogger logger = null)

Parameters

context IApplicationContext

executor TaskScheduler

name string

logger ILogger

Properties

ApplySequence

public virtual bool ApplySequence { get; set; }

Property Value

bool

BroadcastingDispatcher

protected BroadcastingDispatcher BroadcastingDispatcher { get; }

Property Value

BroadcastingDispatcher

ComponentType

public override string ComponentType { get; }

Property Value

string

ErrorHandler

public virtual IErrorHandler ErrorHandler { get; set; }

Property Value

IErrorHandler

IgnoreFailures

public virtual bool IgnoreFailures { get; set; }

Property Value

bool

MinSubscribers

public virtual int MinSubscribers { get; set; }

Property Value

int