Interface IMessageRegistryGrain

Namespace

Microsoft.AutoGen.RuntimeGateway.Grpc.Abstractions

Assembly

Microsoft.AutoGen.RuntimeGateway.Grpc.dll

public interface IMessageRegistryGrain : IGrainWithIntegerKey, IGrain, IAddressable

Methods

AddMessageToDeadLetterQueueAsync(string, CloudEvent)

Writes a message to the dead-letter queue for the given topic.

Task AddMessageToDeadLetterQueueAsync(string topic, CloudEvent message)

Parameters

topic string

message CloudEvent

Returns

Task

AddMessageToEventBufferAsync(string, CloudEvent)

Writes a message to the event buffer for the given topic.

Task AddMessageToEventBufferAsync(string topic, CloudEvent message)

Parameters

topic string

message CloudEvent

Returns

Task

RemoveMessagesAsync(string)

Removes all messages for the given topic from the dead-letter queue.

Task<List<CloudEvent>> RemoveMessagesAsync(string topic)

Parameters

topic string

The topic to remove messages for.

Returns

Task<List<CloudEvent>>

A task representing the asynchronous operation, with the list of removed messages as the result.