IQueueAdapter Interface

Reference

Definition

Namespace:: Orleans.Streams

Assembly:: Orleans.dll

Assembly:: Orleans.Core.dll

Assembly:: Orleans.Streaming.dll

Package:: Microsoft.Orleans.Core v1.5.10

Package:: Microsoft.Orleans.Core v2.4.5

Package:: Microsoft.Orleans.Core v3.6.5

Package:: Microsoft.Orleans.Streaming v7.2.5

Package:: Microsoft.Orleans.Streaming v8.0.0

Package:: Microsoft.Orleans.Streaming v8.1.0

Package:: Microsoft.Orleans.Streaming v8.2.0

Source:: IQueueAdapter.cs

Important

Some information relates to prerelease product that may be substantially modified before it’s released. Microsoft makes no warranties, express or implied, with respect to the information provided here.

Stream queue storage adapter. This is an abstraction layer that hides the implementation details of the underlying queuing system.

public interface IQueueAdapter

type IQueueAdapter = interface

Public Interface IQueueAdapter

Derived: Orleans.Providers.MemoryAdapterFactory<TSerializer>

Orleans.Providers.Streams.Generator.GeneratorAdapterFactory

Orleans.ServiceBus.Providers.EventHubAdapterFactory

Orleans.Streaming.EventHubs.EventHubAdapterFactory

Properties

Direction	Gets the direction of this queue adapter: ReadOnly, WriteOnly, or ReadWrite.
IsRewindable	Gets a value indicating whether this is a rewindable stream adapter - supports subscribing from previous point in time.
Name	Gets the name of the adapter. Primarily for logging purposes

Methods

CreateReceiver(QueueId)	Creates a queue receiver for the specified queueId
QueueMessageBatchAsync<T>(Guid, String, IEnumerable<T>, StreamSequenceToken, Dictionary<String,Object>)	Writes a set of events to the queue as a single batch associated with the provided streamId.
QueueMessageBatchAsync<T>(StreamId, IEnumerable<T>, StreamSequenceToken, Dictionary<String,Object>)	Writes a set of events to the queue as a single batch associated with the provided streamId.

Extension Methods

QueueMessageAsync<T>(IQueueAdapter, StreamId, T, StreamSequenceToken, Dictionary<String,Object>)	Writes a set of events to the queue as a single batch associated with the provided `streamId`.
QueueMessageAsync<T>(IQueueAdapter, Guid, String, T, StreamSequenceToken, Dictionary<String,Object>)	Writes a set of events to the queue as a single batch associated with the provided streamId.

Applies to

Delen via