다음을 통해 공유


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

반환

스트림에서 큐에 대기 중인 메시지의 위치를 반환합니다.

적용 대상