Note

Access to this page requires authorization. You can try signing in or .

Access to this page requires authorization. You can try .

IQueueAdapter Interface

Definition

Namespace:
Orleans.Streams
Assembly:
Orleans.dll
Assembly:
Orleans.Streaming.dll
Assembly:
Orleans.Core.dll
Package:
Microsoft.Orleans.Core v1.5.10
Package:
Microsoft.Orleans.Streaming v10.0.0
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
Package:
Microsoft.Orleans.Streaming v9.0.0
Package:
Microsoft.Orleans.Streaming v9.1.2
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

Properties

Name Description
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

Name Description
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

Name Description
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.
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.

Applies to