IQueueAdapter Интерфейс

Ссылка

Определение

Пространство имен:: Orleans.Streams

Сборка:: Orleans.dll

Сборка:: Orleans.Core.dll

Сборка:: Orleans.Streaming.dll

Пакет:: Microsoft.Orleans.Core v1.5.10

Пакет:: Microsoft.Orleans.Core v2.4.5

Пакет:: Microsoft.Orleans.Core v3.6.5

Пакет:: Microsoft.Orleans.Streaming v7.2.5

Пакет:: Microsoft.Orleans.Streaming v8.0.0

Пакет:: Microsoft.Orleans.Streaming v8.1.0

Пакет:: Microsoft.Orleans.Streaming v8.2.0

Исходный код:: IQueueAdapter.cs

Важно!

Некоторые сведения относятся к предварительной версии продукта, в которую до выпуска могут быть внесены существенные изменения. Майкрософт не предоставляет никаких гарантий, явных или подразумеваемых, относительно приведенных здесь сведений.

Адаптер хранилища очередей потоковой передачи. Это уровень абстракции, который скрывает сведения о реализации базовой системы очередей.

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>(Guid, String, IEnumerable<T>, StreamSequenceToken, Dictionary<String,Object>)	Записывает набор событий в очередь в виде одного пакета, связанного с предоставленным streamId.
QueueMessageBatchAsync<T>(StreamId, IEnumerable<T>, StreamSequenceToken, Dictionary<String,Object>)	Записывает набор событий в очередь в виде одного пакета, связанного с предоставленным streamId.

Методы расширения

QueueMessageAsync<T>(IQueueAdapter, StreamId, T, StreamSequenceToken, Dictionary<String,Object>)	Записывает набор событий в очередь в виде одного пакета, связанного с предоставленным `streamId`.
QueueMessageAsync<T>(IQueueAdapter, Guid, String, T, StreamSequenceToken, Dictionary<String,Object>)	Записывает набор событий в очередь в виде одного пакета, связанного с предоставленным streamId.

Применяется к

Поделиться через