QueueAdapterExtensions.QueueMessageAsync Method
Definition
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.
Overloads
| 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 |
| 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.
public static System.Threading.Tasks.Task QueueMessageAsync<T> (this Orleans.Streams.IQueueAdapter adapter, Orleans.Runtime.StreamId streamId, T evt, Orleans.Streams.StreamSequenceToken token, System.Collections.Generic.Dictionary<string,object> requestContext);static member QueueMessageAsync : Orleans.Streams.IQueueAdapter * Orleans.Runtime.StreamId * 'T * Orleans.Streams.StreamSequenceToken * System.Collections.Generic.Dictionary<string, obj> -> System.Threading.Tasks.Task<Extension()>
Public Function QueueMessageAsync(Of T) (adapter As IQueueAdapter, streamId As StreamId, evt As T, token As StreamSequenceToken, requestContext As Dictionary(Of String, Object)) As TaskType Parameters
- T
The queue element type.
Parameters
- adapter
- IQueueAdapter
The adapter.
- streamId
- StreamId
The stream identifier.
- evt
- T
The event.
- token
- StreamSequenceToken
The token.
- requestContext
- Dictionary<String,Object>
The request context.
Returns
A Task representing the operation.
Applies to
QueueMessageAsync<T>(IQueueAdapter, Guid, String, T, StreamSequenceToken, Dictionary<String,Object>)
- Source:
- IQueueAdapter.cs
Writes a set of events to the queue as a single batch associated with the provided streamId.
public static System.Threading.Tasks.Task QueueMessageAsync<T> (this Orleans.Streams.IQueueAdapter adapter, Guid streamGuid, string streamNamespace, T evt, Orleans.Streams.StreamSequenceToken token, System.Collections.Generic.Dictionary<string,object> requestContext);static member QueueMessageAsync : Orleans.Streams.IQueueAdapter * Guid * string * 'T * Orleans.Streams.StreamSequenceToken * System.Collections.Generic.Dictionary<string, obj> -> System.Threading.Tasks.Task<Extension()>
Public Function QueueMessageAsync(Of T) (adapter As IQueueAdapter, streamGuid As Guid, streamNamespace As String, evt As T, token As StreamSequenceToken, requestContext As Dictionary(Of String, Object)) As TaskType Parameters
- T
Parameters
- adapter
- IQueueAdapter
- streamGuid
- Guid
- streamNamespace
- String
- evt
- T
- token
- StreamSequenceToken
- requestContext
- Dictionary<String,Object>