Class SynchronousImmediateMessageQueue

表示一个同步处理消息队列。

public class SynchronousImmediateMessageQueue : BaseMessageQueue, IMessageQueue

Inherited Members: BaseMessageQueue.EventHandler

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Remarks

此消息队列会在接收到网关事件后调用 EnqueueAsync(JsonElement, int, CancellationToken) 时立即使用构造函数中传入的 eventHandler 委托同步进行处理，处理完成后，该方法才会返回。

初始化一个 BaseMessageQueue 类的新实例。

public SynchronousImmediateMessageQueue(Func<JsonElement, Task> eventHandler)

将网关消息添加到队列中。

public override Task EnqueueAsync(JsonElement payload, int sequence, CancellationToken cancellationToken = default)

启动消息队列的处理。

public override Task StartAsync(CancellationToken cancellationToken = default)

停止消息队列的处理。

public override Task StopAsync(CancellationToken cancellationToken = default)