Поделиться через


CachedMessageBlock<TCachedMessage>.Add<TQueueMessage> Метод

Определение

Добавьте сообщение из очереди в блок. Преобразует сообщение очереди в кэшированное сообщение и сохраняет его в конце блока.

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

Параметры типа

TQueueMessage

Параметры

queueMessage
TQueueMessage
dequeueTimeUtc
DateTime

Возвращаемое значение

Возвращает позицию сообщения в очереди в потоке.

Применяется к