X

Class AbstractMessageChannel

Inheritance
System.Object
AbstractMessageChannel
AbstractSubscribableChannel
Implements
IServiceNameAware
Namespace: Steeltoe.Messaging.Support
Assembly: Steeltoe.Messaging.MessagingBase.dll
Syntax
public abstract class AbstractMessageChannel : Channel<IMessage>, IMessageChannel, IInterceptableChannel

Constructors

| Edit this page View Source

AbstractMessageChannel(ILogger)

Declaration
public AbstractMessageChannel(ILogger logger = null)
Parameters
Type Name Description
ILogger logger

Fields

| Edit this page View Source

INDEFINITE_TIMEOUT

Declaration
public const int INDEFINITE_TIMEOUT = null
Field Value
Type Description
System.Int32

Properties

| Edit this page View Source

Logger

Declaration
public ILogger Logger { get; set; }
Property Value
Type Description
ILogger
| Edit this page View Source

ServiceName

Declaration
public virtual string ServiceName { get; set; }
Property Value
Type Description
System.String

Methods

| Edit this page View Source

AddInterceptor(IChannelInterceptor)

Declaration
public virtual void AddInterceptor(IChannelInterceptor interceptor)
Parameters
Type Name Description
IChannelInterceptor interceptor
| Edit this page View Source

AddInterceptor(Int32, IChannelInterceptor)

Declaration
public virtual void AddInterceptor(int index, IChannelInterceptor interceptor)
Parameters
Type Name Description
System.Int32 index
IChannelInterceptor interceptor
| Edit this page View Source

DoSend(IMessage, CancellationToken)

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

DoSend(IMessage, Int32)

Declaration
protected virtual bool DoSend(IMessage message, int timeout)
Parameters
Type Name Description
IMessage message
System.Int32 timeout
Returns
Type Description
System.Boolean
| Edit this page View Source

DoSendInternal(IMessage, CancellationToken)

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

GetInterceptors()

Declaration
public virtual List<IChannelInterceptor> GetInterceptors()
Returns
Type Description
List<IChannelInterceptor>
| Edit this page View Source

RemoveInterceptor(IChannelInterceptor)

Declaration
public virtual bool RemoveInterceptor(IChannelInterceptor interceptor)
Parameters
Type Name Description
IChannelInterceptor interceptor
Returns
Type Description
System.Boolean
| Edit this page View Source

RemoveInterceptor(Int32)

Declaration
public virtual IChannelInterceptor RemoveInterceptor(int index)
Parameters
Type Name Description
System.Int32 index
Returns
Type Description
IChannelInterceptor
| Edit this page View Source

Send(IMessage)

Declaration
public virtual bool Send(IMessage message)
Parameters
Type Name Description
IMessage message
Returns
Type Description
System.Boolean
| Edit this page View Source

Send(IMessage, Int32)

Declaration
public virtual bool Send(IMessage message, int timeout)
Parameters
Type Name Description
IMessage message
System.Int32 timeout
Returns
Type Description
System.Boolean
| Edit this page View Source

SendAsync(IMessage, CancellationToken)

Declaration
public virtual ValueTask<bool> SendAsync(IMessage message, CancellationToken cancellationToken = null)
Parameters
Type Name Description
IMessage message
CancellationToken cancellationToken
Returns
Type Description
ValueTask<System.Boolean>
| Edit this page View Source

SetInterceptors(List<IChannelInterceptor>)

Declaration
public virtual void SetInterceptors(List<IChannelInterceptor> interceptors)
Parameters
Type Name Description
List<IChannelInterceptor> interceptors
| Edit this page View Source

ToString()

Declaration
public override string ToString()
Returns
Type Description
System.String

Implements

IServiceNameAware