Dreamine.Communication.Core.Queues.IOutboundMessageQueue 인터페이스 참조

더 자세히 ...

Dreamine.Communication.Core.Queues.IOutboundMessageQueue에 대한 상속 다이어그램 :

Public 멤버 함수
ValueTask	EnqueueAsync (QueuedOutboundMessage message, CancellationToken cancellationToken=default)
ValueTask	EnqueueFrontAsync (QueuedOutboundMessage message, CancellationToken cancellationToken=default)
ValueTask< QueuedOutboundMessage?>	TryDequeueAsync (CancellationToken cancellationToken=default)
void	Clear ()

속성
int	Count [get]

상세한 설명

연결이 끊긴 동안 송신 메시지를 보관하고 다시 꺼내는 큐 계약입니다.

IOutboundMessageQueue.cs 파일의 11 번째 라인에서 정의되었습니다.

멤버 함수 문서화

Clear()

void Dreamine.Communication.Core.Queues.IOutboundMessageQueue.Clear

(

)

큐에 저장된 모든 메시지를 제거합니다.

Dreamine.Communication.Core.Queues.InMemoryOutboundMessageQueue에서 구현되었습니다.

EnqueueAsync()

ValueTask Dreamine.Communication.Core.Queues.IOutboundMessageQueue.EnqueueAsync	(	QueuedOutboundMessage	message,
		CancellationToken	cancellationToken = default )

메시지를 큐의 뒤쪽에 비동기적으로 추가합니다.

매개변수

message	큐에 저장할 송신 대기 메시지입니다.
cancellationToken	추가 작업의 취소 요청을 감시하는 토큰입니다.

반환값

비동기 추가 작업입니다.

예외

ArgumentNullException	message 가 null인 경우 발생할 수 있습니다.
OperationCanceledException	작업 취소가 요청된 경우 발생할 수 있습니다.

Dreamine.Communication.Core.Queues.InMemoryOutboundMessageQueue에서 구현되었습니다.

EnqueueFrontAsync()

ValueTask Dreamine.Communication.Core.Queues.IOutboundMessageQueue.EnqueueFrontAsync	(	QueuedOutboundMessage	message,
		CancellationToken	cancellationToken = default )

재시도할 메시지를 큐의 앞쪽에 비동기적으로 다시 추가합니다.

매개변수

message	큐 앞쪽에 다시 저장할 메시지입니다.
cancellationToken	추가 작업의 취소 요청을 감시하는 토큰입니다.

반환값

비동기 앞쪽 추가 작업입니다.

예외

ArgumentNullException	message 가 null인 경우 발생할 수 있습니다.
OperationCanceledException	작업 취소가 요청된 경우 발생할 수 있습니다.

Dreamine.Communication.Core.Queues.InMemoryOutboundMessageQueue에서 구현되었습니다.

TryDequeueAsync()

ValueTask< QueuedOutboundMessage?> Dreamine.Communication.Core.Queues.IOutboundMessageQueue.TryDequeueAsync

(

CancellationToken

cancellationToken = default

)

큐에서 가장 오래된 메시지를 비동기적으로 제거해 반환합니다.

매개변수

cancellationToken

꺼내기 작업의 취소 요청을 감시하는 토큰입니다.

반환값

제거한 메시지이며, 큐가 비어 있으면 null입니다.

예외

OperationCanceledException

작업 취소가 요청된 경우 발생할 수 있습니다.

Dreamine.Communication.Core.Queues.InMemoryOutboundMessageQueue에서 구현되었습니다.

속성 문서화

Count

int Dreamine.Communication.Core.Queues.IOutboundMessageQueue.Count

get

현재 큐에 저장된 메시지 수를 가져옵니다.

Dreamine.Communication.Core.Queues.InMemoryOutboundMessageQueue에서 구현되었습니다.

IOutboundMessageQueue.cs 파일의 21 번째 라인에서 정의되었습니다.

{ get; }

---

이 인터페이스에 대한 문서화 페이지는 다음의 파일로부터 생성되었습니다.:

• IOutboundMessageQueue.cs