IQueueAdapter Interface

Definição

Namespace:

Orleans.Streams

Assembly:

Orleans.Streaming.dll

Pacote:

Microsoft.Orleans.Streaming v8.2.0

Adaptador de armazenamento de fila de fluxo. Essa é uma camada de abstração que oculta os detalhes de implementação do sistema de enfileiramento subjacente.

public interface IQueueAdapter

type IQueueAdapter = interface

Public Interface IQueueAdapter

Derivado

Orleans.Providers.MemoryAdapterFactory<TSerializer>

Orleans.Providers.Streams.Generator.GeneratorAdapterFactory

Orleans.ServiceBus.Providers.EventHubAdapterFactory

Orleans.Streaming.EventHubs.EventHubAdapterFactory

Propriedades

Direction	Obtém a direção desse adaptador de fila: ReadOnly, WriteOnlyou ReadWrite.
IsRewindable	Obtém um valor que indica se este é um adaptador de fluxo rebobinável – dá suporte à assinatura do ponto anterior no tempo.
Name	Obtém o nome do adaptador. Principalmente para fins de registro em log

Métodos

CreateReceiver(QueueId)	Cria um receptor de fila para a queueId especificada
QueueMessageBatchAsync<T>(StreamId, IEnumerable<T>, StreamSequenceToken, Dictionary<String,Object>)	Grava um conjunto de eventos na fila como um único lote associado ao streamId fornecido.

Métodos de Extensão

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

Grava um conjunto de eventos na fila como um único lote associado ao fornecido streamId.