Class AbstractSubscribableChannel

Namespace

Steeltoe.Integration.Channel

Assembly

Steeltoe.Integration.IntegrationBase.dll

public abstract class AbstractSubscribableChannel : AbstractMessageChannel, IChannelInterceptorAware, ISubscribableChannel, IMessageChannel, IServiceNameAware

Inheritance

object

Channel<IMessage, IMessage>

Channel<IMessage>

AbstractMessageChannel

AbstractSubscribableChannel

Implements

IChannelInterceptorAware

ISubscribableChannel

IMessageChannel

IServiceNameAware

Derived

AbstractTaskSchedulerChannel

DirectChannel

Inherited Members

AbstractMessageChannel.INDEFINITE_TIMEOUT

AbstractMessageChannel.ApplicationContext

AbstractMessageChannel.IntegrationServices

AbstractMessageChannel.ComponentType

AbstractMessageChannel.ServiceName

AbstractMessageChannel.ComponentName

AbstractMessageChannel.DataTypes

AbstractMessageChannel.MessageConverter

AbstractMessageChannel.ChannelInterceptors

AbstractMessageChannel.AddInterceptor(IChannelInterceptor)

AbstractMessageChannel.AddInterceptor(int, IChannelInterceptor)

AbstractMessageChannel.RemoveInterceptor(IChannelInterceptor)

AbstractMessageChannel.RemoveInterceptor(int)

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

AbstractSubscribableChannel(IApplicationContext, IMessageDispatcher, ILogger)

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

Parameters

context IApplicationContext

dispatcher IMessageDispatcher

logger ILogger

AbstractSubscribableChannel(IApplicationContext, IMessageDispatcher, string, ILogger)

protected AbstractSubscribableChannel(IApplicationContext context, IMessageDispatcher dispatcher, string name, ILogger logger = null)

Parameters

context IApplicationContext

dispatcher IMessageDispatcher

name string

logger ILogger

Properties

Dispatcher

public IMessageDispatcher Dispatcher { get; }

Property Value

IMessageDispatcher

Failover

public virtual bool Failover { get; set; }

Property Value

bool

MaxSubscribers

public virtual int MaxSubscribers { get; set; }

Property Value

int

SubscriberCount

public virtual int SubscriberCount { get; }

Property Value

int

Methods

DoSendInternal(IMessage, CancellationToken)

protected override bool DoSendInternal(IMessage message, CancellationToken cancellationToken)

Parameters

message IMessage

cancellationToken CancellationToken

Returns

bool

Subscribe(IMessageHandler)

Register a message handler.

public virtual bool Subscribe(IMessageHandler handler)

Parameters

handler IMessageHandler

the handler to register

Returns

bool

false if already registered; otherwise true

Unsubscribe(IMessageHandler)

Un-register a message handler.

public virtual bool Unsubscribe(IMessageHandler handler)

Parameters

handler IMessageHandler

the handler to remvoe

Returns

bool

false if not registered; otherwise true