Szerkesztés

Megosztás a következőn keresztül:

CachedMessageBlock<TCachedMessage>.Add<TQueueMessage> Method

  • Reference

Definition

Namespace:
Orleans.Providers.Streams.Common
Assembly:
OrleansProviders.dll
Package:
Microsoft.Orleans.OrleansProviders v1.5.10
Package:
Microsoft.Orleans.OrleansProviders v2.4.5

Add a message from the queue to the block. Converts the queue message to a cached message and stores it at the end of the block.

public Orleans.Providers.Streams.Common.StreamPosition Add<TQueueMessage> (TQueueMessage queueMessage, DateTime dequeueTimeUtc, Orleans.Providers.Streams.Common.ICacheDataAdapter<TQueueMessage,TCachedMessage> dataAdapter);
member this.Add : 'QueueMessage * DateTime * Orleans.Providers.Streams.Common.ICacheDataAdapter<'QueueMessage, 'CachedMessage (requires 'CachedMessage : struct)> -> Orleans.Providers.Streams.Common.StreamPosition
Public Function Add(Of TQueueMessage) (queueMessage As TQueueMessage, dequeueTimeUtc As DateTime, dataAdapter As ICacheDataAdapter(Of TQueueMessage, TCachedMessage)) As StreamPosition

Type Parameters

TQueueMessage

Parameters

queueMessage
TQueueMessage
dequeueTimeUtc
DateTime
dataAdapter
ICacheDataAdapter<TQueueMessage,TCachedMessage>

Returns

StreamPosition

Returns the position of the queued message in the stream

Applies to