Class MessageRegistryState

Namespace

Microsoft.AutoGen.RuntimeGateway.Grpc.Abstractions

Assembly

Microsoft.AutoGen.RuntimeGateway.Grpc.dll

Holds a dead-letter queue by topic type.

public class MessageRegistryState

Inheritance

object

MessageRegistryState

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Properties

DeadLetterQueue

Dictionary mapping topic types to a list of CloudEvents that failed delivery. we read from this queue on new sub and registration so that agents can potentially receive messages they missed

public ConcurrentDictionary<string, List<CloudEvent>> DeadLetterQueue { get; set; }

Property Value

ConcurrentDictionary<string, List<CloudEvent>>

EventBuffer

A Dictionary of events that have been recently delivered to agents. We keep them around for a short time to ensure that anyone subscribing to the topic within the next few seconds has a chance to receive them.

public ConcurrentDictionary<string, List<CloudEvent>> EventBuffer { get; set; }

Property Value

ConcurrentDictionary<string, List<CloudEvent>>