AzureQueueJsonDataAdapter

1. Documentation
2. API reference
3. Microsoft.Orleans.Streaming.AzureStorage
4. AzureQueueJsonDataAdapter

class

Namespace: Orleans.Providers.Streams.AzureQueue

NuGetSourceMarkdown

Data adapter that uses OrleansJsonSerializer for serializing stream event data with fallback support. This adapter is experimental and subject to change in future updates.

[System.Diagnostics.CodeAnalysis.Experimental(StreamingJsonSerializationExperimental, UrlFormat = https://github.com/dotnet/orleans/pull/9618)]
public class AzureQueueJsonDataAdapter : IQueueDataAdapter<string, IBatchContainer>, IQueueDataAdapter<string>

Constructors

• AzureQueueJsonDataAdapter(OrleansJsonSerializer, AzureQueueDataAdapterV2, AzureQueueJsonDataAdapterOptions, ILogger<AzureQueueJsonDataAdapter>) Initializes a new instance of the AzureQueueJsonDataAdapter class.

Methods

• FromQueueMessage(string, long) Creates a batch container from a cloud queue message
• ToQueueMessage(StreamId, IEnumerable<T>, StreamSequenceToken?, Dictionary<string, object>) Creates a cloud queue message from stream event data.