Class AbstractSubscribableChannel

Namespace

Steeltoe.Messaging.Support

Assembly

Steeltoe.Messaging.MessagingBase.dll

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

Inheritance

object

Channel<IMessage, IMessage>

Channel<IMessage>

AbstractMessageChannel

AbstractSubscribableChannel

Implements

IInterceptableChannel

ISubscribableChannel

IMessageChannel

IServiceNameAware

Derived

TaskSchedulerSubscribableChannel

Inherited Members

AbstractMessageChannel.INDEFINITE_TIMEOUT

AbstractMessageChannel.ServiceName

AbstractMessageChannel.Logger

AbstractMessageChannel.SetInterceptors(List<IChannelInterceptor>)

AbstractMessageChannel.AddInterceptor(IChannelInterceptor)

AbstractMessageChannel.AddInterceptor(int, IChannelInterceptor)

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)

AbstractMessageChannel.DoSendInternal(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

AbstractSubscribableChannel(ILogger)

public AbstractSubscribableChannel(ILogger logger = null)

Parameters

logger ILogger

Properties

SubscriberCount

public virtual int SubscriberCount { get; }

Property Value

int

Subscribers

public virtual ISet<IMessageHandler> Subscribers { get; }

Property Value

ISet<IMessageHandler>

Methods

HasSubscription(IMessageHandler)

public virtual bool HasSubscription(IMessageHandler handler)

Parameters

handler IMessageHandler

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