Interface IPollableChannel

Namespace

Steeltoe.Messaging

Assembly

Steeltoe.Messaging.Abstractions.dll

A MessageChannel from which messages may be actively received through polling

public interface IPollableChannel : IMessageChannel, IServiceNameAware

Inherited Members

IMessageChannel.SendAsync(IMessage, CancellationToken)

IMessageChannel.Send(IMessage)

IMessageChannel.Send(IMessage, int)

IServiceNameAware.ServiceName

Methods

Receive()

Receive a message from this channel, blocking forever if necessary.

IMessage Receive()

Returns

IMessage

the message

Receive(int)

Receive a message from this channel, blocking until either a message is available or the specified timeout period elapses.

IMessage Receive(int timeout)

Parameters

timeout int

the timeout value in milliseconds

Returns

IMessage

the message or null

ReceiveAsync(CancellationToken)

Receive a message from this channel

ValueTask<IMessage> ReceiveAsync(CancellationToken cancellationToken = default)

Parameters

cancellationToken CancellationToken

token used to signal cancelation

Returns

ValueTask<IMessage>

a task to signal completion