Class MessageRegistryQueue

Namespace

Microsoft.AutoGen.RuntimeGateway.Grpc

Assembly

Microsoft.AutoGen.RuntimeGateway.Grpc.dll

public sealed class MessageRegistryQueue

Inheritance

object

MessageRegistryQueue

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.ReferenceEquals(object, object)

object.ToString()

Methods

AddMessageAsync(string, CloudEvent)

public Task AddMessageAsync(string topic, CloudEvent message)

Parameters

topic string

message CloudEvent

Returns

Task

RemoveMessageAfterDelayAsync(string, CloudEvent, int)

public Task RemoveMessageAfterDelayAsync(string topic, CloudEvent message, int delay)

Parameters

topic string

message CloudEvent

delay int

Returns

Task

RemoveMessageAsync(string, CloudEvent)

public Task<bool> RemoveMessageAsync(string topic, CloudEvent message)

Parameters

topic string

message CloudEvent

Returns

Task<bool>

RemoveMessagesAsync(string)

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

Parameters

topic string

Returns

Task<List<CloudEvent>>