IQueueAdapter 接口

定义

命名空间:

Orleans.Streams

程序集:

Orleans.Streaming.dll

包:

Microsoft.Orleans.Streaming v8.2.0

流队列存储适配器。 这是一个抽象层，用于隐藏基础队列系统的实现详细信息。

public interface IQueueAdapter

type IQueueAdapter = interface

Public Interface IQueueAdapter

派生

Orleans.Providers.MemoryAdapterFactory<TSerializer>

Orleans.Providers.Streams.Generator.GeneratorAdapterFactory

Orleans.ServiceBus.Providers.EventHubAdapterFactory

Orleans.Streaming.EventHubs.EventHubAdapterFactory

属性

Direction	获取此队列适配器的方向： ReadOnly、 WriteOnly或 ReadWrite。
IsRewindable	获取一个值，该值指示这是否是可回退的流适配器 - 支持从以前的时间点订阅。
Name	获取适配器的名称。 主要用于日志记录

方法

CreateReceiver(QueueId)	为指定的 queueId 创建队列接收器
QueueMessageBatchAsync<T>(StreamId, IEnumerable<T>, StreamSequenceToken, Dictionary<String,Object>)	将一组事件作为与提供的 streamId 关联的单个批写入队列。

扩展方法

QueueMessageAsync<T>(IQueueAdapter, StreamId, T, StreamSequenceToken, Dictionary<String,Object>)

将一组事件作为与提供的 streamId关联的单个批写入队列。