X

Class QueueChannel

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

Constructors

| Edit this page View Source

QueueChannel(IApplicationContext, ILogger)

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

QueueChannel(IApplicationContext, Int32, ILogger)

Declaration
public QueueChannel(IApplicationContext context, int capacity, ILogger logger = null)
Parameters
Type Name Description
IApplicationContext context
System.Int32 capacity
ILogger logger
| Edit this page View Source

QueueChannel(IApplicationContext, String, ILogger)

Declaration
public QueueChannel(IApplicationContext context, string name, ILogger logger = null)
Parameters
Type Name Description
IApplicationContext context
System.String name
ILogger logger
| Edit this page View Source

QueueChannel(IApplicationContext, System.Threading.Channels.Channel<IMessage>, ILogger)

Declaration
public QueueChannel(IApplicationContext context, System.Threading.Channels.Channel<IMessage> channel, ILogger logger = null)
Parameters
Type Name Description
IApplicationContext context
System.Threading.Channels.Channel<IMessage> channel
ILogger logger
| Edit this page View Source

QueueChannel(IApplicationContext, System.Threading.Channels.Channel<IMessage>, String, ILogger)

Declaration
public QueueChannel(IApplicationContext context, System.Threading.Channels.Channel<IMessage> channel, string name, ILogger logger = null)
Parameters
Type Name Description
IApplicationContext context
System.Threading.Channels.Channel<IMessage> channel
System.String name
ILogger logger
| Edit this page View Source

QueueChannel(ILogger)

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

Properties

| Edit this page View Source

QueueSize

Declaration
public int QueueSize { get; }
Property Value
Type Description
System.Int32
| Edit this page View Source

RemainingCapacity

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

Methods

| Edit this page View Source

Clear()

Declaration
public IList<IMessage> Clear()
Returns
Type Description
IList<IMessage>
| Edit this page View Source

DoReceiveInternal(CancellationToken)

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

DoSendInternal(IMessage, CancellationToken)

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

Purge(IMessageSelector)

Declaration
public IList<IMessage> Purge(IMessageSelector messageSelector)
Parameters
Type Name Description
IMessageSelector messageSelector
Returns
Type Description
IList<IMessage>

Implements

IMessageChannel
IPollableChannel