X

Class AbstractPollableChannel

Inheritance
System.Object
AbstractMessageChannel
AbstractPollableChannel
QueueChannel
Implements
IMessageChannel
IPollableChannel
Inherited Members
Namespace: Steeltoe.Integration.Channel
Assembly: Steeltoe.Integration.IntegrationBase.dll
Syntax
public abstract class AbstractPollableChannel : AbstractMessageChannel, ITaskSchedulerChannelInterceptorAware, IChannelInterceptorAware

Constructors

| Edit this page View Source

AbstractPollableChannel(IApplicationContext, ILogger)

Declaration
protected AbstractPollableChannel(IApplicationContext context, ILogger logger = null)
Parameters
Type Name Description
IApplicationContext context
ILogger logger
| Edit this page View Source

AbstractPollableChannel(IApplicationContext, String, ILogger)

Declaration
protected AbstractPollableChannel(IApplicationContext context, string name, ILogger logger = null)
Parameters
Type Name Description
IApplicationContext context
System.String name
ILogger logger

Properties

| Edit this page View Source

ChannelInterceptors

Declaration
public override List<IChannelInterceptor> ChannelInterceptors { get; set; }
Property Value
Type Description
List<IChannelInterceptor>
Overrides
| Edit this page View Source

HasTaskSchedulerInterceptors

Declaration
public virtual bool HasTaskSchedulerInterceptors { get; }
Property Value
Type Description
System.Boolean
| Edit this page View Source

TaskSchedulerInterceptorsSize

Declaration
public int TaskSchedulerInterceptorsSize { get; }
Property Value
Type Description
System.Int32

Methods

| Edit this page View Source

AddInterceptor(IChannelInterceptor)

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

AddInterceptor(Int32, IChannelInterceptor)

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

DoReceive(CancellationToken)

Declaration
protected virtual IMessage DoReceive(CancellationToken cancellationToken = null)
Parameters
Type Name Description
CancellationToken cancellationToken
Returns
Type Description
IMessage
| Edit this page View Source

DoReceive(Int32)

Declaration
protected virtual IMessage DoReceive(int timeout)
Parameters
Type Name Description
System.Int32 timeout
Returns
Type Description
IMessage
| Edit this page View Source

DoReceiveInternal(CancellationToken)

Declaration
protected abstract IMessage DoReceiveInternal(CancellationToken cancellationToken)
Parameters
Type Name Description
CancellationToken cancellationToken
Returns
Type Description
IMessage
| Edit this page View Source

Receive()

Declaration
public virtual IMessage Receive()
Returns
Type Description
IMessage
| Edit this page View Source

Receive(Int32)

Declaration
public virtual IMessage Receive(int timeout)
Parameters
Type Name Description
System.Int32 timeout
Returns
Type Description
IMessage
| Edit this page View Source

ReceiveAsync(CancellationToken)

Declaration
public virtual ValueTask<IMessage> ReceiveAsync(CancellationToken cancellationToken = null)
Parameters
Type Name Description
CancellationToken cancellationToken
Returns
Type Description
ValueTask<IMessage>
| Edit this page View Source

RemoveInterceptor(IChannelInterceptor)

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

RemoveInterceptor(Int32)

Declaration
public override IChannelInterceptor RemoveInterceptor(int index)
Parameters
Type Name Description
System.Int32 index
Returns
Type Description
IChannelInterceptor
Overrides

Implements

IMessageChannel
IPollableChannel