Class BaseMessageQueue

Namespace

Kook.Net.Queue

Assembly

Kook.Net.Core.dll

表示一个通用的消息队列抽象类。

public abstract class BaseMessageQueue : IMessageQueue

Inheritance

object

BaseMessageQueue

Implements

IMessageQueue

Derived

SynchronousImmediateMessageQueue

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Constructors

BaseMessageQueue(Func<JsonElement, Task>)

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

protected BaseMessageQueue(Func<JsonElement, Task> eventHandler)

Parameters

eventHandler Func<JsonElement, Task>

用于处理消息的事件处理程序。

Properties

EventHandler

获取消息队列的事件处理程序。

protected Func<JsonElement, Task> EventHandler { get; }

Property Value

Func<JsonElement, Task>

Methods

EnqueueAsync(JsonElement, int, CancellationToken)

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

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

Parameters

payload JsonElement

网管消息的有效负载。

sequence int

网关消息的序号。

cancellationToken CancellationToken

用于取消该操作的取消令牌。

Returns

Task

表示一个异步入队操作的任务。

StartAsync(CancellationToken)

启动消息队列的处理。

public abstract Task StartAsync(CancellationToken cancellationToken = default)

Parameters

cancellationToken CancellationToken

用于取消该操作的取消令牌。

Returns

Task

表示一个异步启动操作的任务。

StopAsync(CancellationToken)

停止消息队列的处理。

public abstract Task StopAsync(CancellationToken cancellationToken = default)

Parameters

cancellationToken CancellationToken

用于取消该操作的取消令牌。

Returns

Task

表示一个异步停止操作的任务。