Dreamine.FullKit.Tests.Communication.RabbitMqMessageBusTests.FakeRabbitMqChannel 클래스 참조

더 자세히 ...

Dreamine.FullKit.Tests.Communication.RabbitMqMessageBusTests.FakeRabbitMqChannel에 대한 상속 다이어그램 :

Dreamine.FullKit.Tests.Communication.RabbitMqMessageBusTests.FakeRabbitMqChannel에 대한 협력 다이어그램:

Public 멤버 함수
void	ExchangeDeclare (string exchange, string type, bool durable, bool autoDelete)
void	QueueDeclare (string queue, bool durable, bool exclusive, bool autoDelete)
void	QueueBind (string queue, string exchange, string routingKey)
IRabbitMqBasicProperties	CreateBasicProperties ()
void	BasicPublish (string exchange, string routingKey, bool mandatory, IRabbitMqBasicProperties properties, ReadOnlyMemory< byte > body)
string	BasicConsume (string queue, bool autoAck, Func< RabbitMqDelivery, CancellationToken, Task > onReceived)
Task	DeliverAsync (RabbitMqDelivery delivery)
void	BasicAck (ulong deliveryTag, bool multiple)
void	BasicNack (ulong deliveryTag, bool multiple, bool requeue)
void	BasicReject (ulong deliveryTag, bool requeue)
void	BasicCancel (string consumerTag)
void	Close ()
void	Dispose ()

속성
bool	IsOpen [get]
bool	Closed [get, private set]
bool	LastNackRequeue [get, private set]
List< string >	Operations = [] [get]
List< PublishedMessage >	PublishedMessages = [] [get]
List< ulong >	AckedDeliveryTags = [] [get]
List< ulong >	NackedDeliveryTags = [] [get]
List< ulong >	RejectedDeliveryTags = [] [get]
List< string >	CancelledConsumerTags = [] [get]

Private 속성
Func< RabbitMqDelivery, CancellationToken, Task >?	_onReceived

상세한 설명

Fake Rabbit Mq Channel 기능과 관련 상태를 캡슐화합니다.

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

멤버 함수 문서화

BasicAck()

void Dreamine.FullKit.Tests.Communication.RabbitMqMessageBusTests.FakeRabbitMqChannel.BasicAck ( ulong deliveryTag, bool multiple )

inline

Basic Ack 작업을 수행합니다.

매개변수

deliveryTag	delivery Tag에 사용할 ulong 값입니다.
multiple	multiple에 사용할 bool 값입니다.

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

        {
            AckedDeliveryTags.Add(deliveryTag);
        }

다음을 참조함 : AckedDeliveryTags.

BasicCancel()

void Dreamine.FullKit.Tests.Communication.RabbitMqMessageBusTests.FakeRabbitMqChannel.BasicCancel ( string consumerTag )

inline

Basic Cancel 작업을 수행합니다.

매개변수

consumerTag

consumer Tag에 사용할 string 값입니다.

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

        {
            CancelledConsumerTags.Add(consumerTag);
        }

다음을 참조함 : CancelledConsumerTags.

BasicConsume()

string Dreamine.FullKit.Tests.Communication.RabbitMqMessageBusTests.FakeRabbitMqChannel.BasicConsume ( string queue, bool autoAck, Func< RabbitMqDelivery, CancellationToken, Task > onReceived )

inline

Basic Consume 작업을 수행합니다.

매개변수

queue	queue에 사용할 string 값입니다.
autoAck	auto Ack에 사용할 bool 값입니다.
onReceived	on Received에 사용할 Func<RabbitMqDelivery, CancellationToken, Task> 값입니다.

반환값

Basic Consume 작업에서 생성한 string 결과입니다.

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

        {
            Operations.Add($"consume:{queue}:{autoAck}");
            _onReceived = onReceived;
            return "consumer-1";
        }

다음을 참조함 : _onReceived, Operations.

BasicNack()

void Dreamine.FullKit.Tests.Communication.RabbitMqMessageBusTests.FakeRabbitMqChannel.BasicNack ( ulong deliveryTag, bool multiple, bool requeue )

inline

Basic Nack 작업을 수행합니다.

매개변수

deliveryTag	delivery Tag에 사용할 ulong 값입니다.
multiple	multiple에 사용할 bool 값입니다.
requeue	requeue에 사용할 bool 값입니다.

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

        {
            NackedDeliveryTags.Add(deliveryTag);
            LastNackRequeue = requeue;
        }

다음을 참조함 : LastNackRequeue, NackedDeliveryTags.

BasicPublish()

void Dreamine.FullKit.Tests.Communication.RabbitMqMessageBusTests.FakeRabbitMqChannel.BasicPublish ( string exchange, string routingKey, bool mandatory, IRabbitMqBasicProperties properties, ReadOnlyMemory< byte > body )

inline

Basic Publish 작업을 수행합니다.

매개변수

exchange	exchange에 사용할 string 값입니다.
routingKey	routing Key에 사용할 string 값입니다.
mandatory	mandatory에 사용할 bool 값입니다.
properties	properties에 사용할 IRabbitMqBasicProperties 값입니다.
body	body에 사용할 ReadOnlyMemory<byte> 값입니다.

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

        {
            PublishedMessages.Add(new PublishedMessage(
                exchange,
                routingKey,
                mandatory,
                new FakeRabbitMqBasicProperties
                {
                    Persistent = properties.Persistent,
                    ContentType = properties.ContentType,
                    Type = properties.Type
                },
                body.ToArray()));
        }

다음을 참조함 : Dreamine.FullKit.Tests.Communication.RabbitMqMessageBusTests.PublishedMessage(), PublishedMessages.

이 함수 내부에서 호출하는 함수들에 대한 그래프입니다.:

BasicReject()

void Dreamine.FullKit.Tests.Communication.RabbitMqMessageBusTests.FakeRabbitMqChannel.BasicReject ( ulong deliveryTag, bool requeue )

inline

Basic Reject 작업을 수행합니다.

매개변수

deliveryTag	delivery Tag에 사용할 ulong 값입니다.
requeue	requeue에 사용할 bool 값입니다.

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

        {
            RejectedDeliveryTags.Add(deliveryTag);
        }

다음을 참조함 : RejectedDeliveryTags.

Close()

void Dreamine.FullKit.Tests.Communication.RabbitMqMessageBusTests.FakeRabbitMqChannel.Close ( )

inline

Close 작업을 수행합니다.

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

        {
            Closed = true;
        }

다음을 참조함 : Closed.

CreateBasicProperties()

IRabbitMqBasicProperties Dreamine.FullKit.Tests.Communication.RabbitMqMessageBusTests.FakeRabbitMqChannel.CreateBasicProperties ( )

inline

Basic Properties 값을 생성합니다.

반환값

Create Basic Properties 작업에서 생성한 IRabbitMqBasicProperties 결과입니다.

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

        {
            return new FakeRabbitMqBasicProperties();
        }

DeliverAsync()

Task Dreamine.FullKit.Tests.Communication.RabbitMqMessageBusTests.FakeRabbitMqChannel.DeliverAsync ( RabbitMqDelivery delivery )

inline

Deliver Async 작업을 수행합니다.

매개변수

delivery

delivery에 사용할 RabbitMqDelivery 값입니다.

반환값

Deliver Async 작업에서 생성한 Task 결과입니다.

예외

InvalidOperationException

현재 객체 상태에서 Deliver Async 작업을 수행할 수 없는 경우 발생합니다.

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

        {
            return _onReceived?.Invoke(delivery, CancellationToken.None)
                ?? throw new InvalidOperationException("Consumer is not registered.");
        }

다음을 참조함 : _onReceived.

Dispose()

void Dreamine.FullKit.Tests.Communication.RabbitMqMessageBusTests.FakeRabbitMqChannel.Dispose ( )

inline

이 인스턴스가 소유한 리소스를 해제합니다.

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

        {
            Closed = true;
        }

다음을 참조함 : Closed.

ExchangeDeclare()

void Dreamine.FullKit.Tests.Communication.RabbitMqMessageBusTests.FakeRabbitMqChannel.ExchangeDeclare ( string exchange, string type, bool durable, bool autoDelete )

inline

Exchange Declare 작업을 수행합니다.

매개변수

exchange	exchange에 사용할 string 값입니다.
type	type에 사용할 string 값입니다.
durable	durable에 사용할 bool 값입니다.
autoDelete	auto Delete에 사용할 bool 값입니다.

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

        {
            Operations.Add($"exchange:{exchange}:{type}:{durable}:{autoDelete}");
        }

다음을 참조함 : Operations.

QueueBind()

void Dreamine.FullKit.Tests.Communication.RabbitMqMessageBusTests.FakeRabbitMqChannel.QueueBind ( string queue, string exchange, string routingKey )

inline

Queue Bind 작업을 수행합니다.

매개변수

queue	queue에 사용할 string 값입니다.
exchange	exchange에 사용할 string 값입니다.
routingKey	routing Key에 사용할 string 값입니다.

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

        {
            Operations.Add($"bind:{queue}:{exchange}:{routingKey}");
        }

다음을 참조함 : Operations.

QueueDeclare()

void Dreamine.FullKit.Tests.Communication.RabbitMqMessageBusTests.FakeRabbitMqChannel.QueueDeclare ( string queue, bool durable, bool exclusive, bool autoDelete )

inline

Queue Declare 작업을 수행합니다.

매개변수

queue	queue에 사용할 string 값입니다.
durable	durable에 사용할 bool 값입니다.
exclusive	exclusive에 사용할 bool 값입니다.
autoDelete	auto Delete에 사용할 bool 값입니다.

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

        {
            Operations.Add($"queue:{queue}:{durable}:{exclusive}:{autoDelete}");
        }

다음을 참조함 : Operations.

멤버 데이터 문서화

_onReceived

Func<RabbitMqDelivery, CancellationToken, Task>? Dreamine.FullKit.Tests.Communication.RabbitMqMessageBusTests.FakeRabbitMqChannel._onReceived

private

on Received 값을 보관합니다.

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

다음에 의해서 참조됨 : BasicConsume(), DeliverAsync().

속성 문서화

AckedDeliveryTags

List<ulong> Dreamine.FullKit.Tests.Communication.RabbitMqMessageBusTests.FakeRabbitMqChannel.AckedDeliveryTags = []

get

Acked Delivery Tags 값을 가져옵니다.

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

{ get; } = [];

다음에 의해서 참조됨 : BasicAck().

CancelledConsumerTags

List<string> Dreamine.FullKit.Tests.Communication.RabbitMqMessageBusTests.FakeRabbitMqChannel.CancelledConsumerTags = []

get

Cancelled Consumer Tags 값을 가져옵니다.

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

{ get; } = [];

다음에 의해서 참조됨 : BasicCancel().

Closed

bool Dreamine.FullKit.Tests.Communication.RabbitMqMessageBusTests.FakeRabbitMqChannel.Closed

getprivate set

Closed 값을 가져오거나 설정합니다.

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

{ get; private set; }

다음에 의해서 참조됨 : Close(), Dispose().

IsOpen

bool Dreamine.FullKit.Tests.Communication.RabbitMqMessageBusTests.FakeRabbitMqChannel.IsOpen

get

Is Open 값을 가져옵니다.

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

LastNackRequeue

bool Dreamine.FullKit.Tests.Communication.RabbitMqMessageBusTests.FakeRabbitMqChannel.LastNackRequeue

getprivate set

Last Nack Requeue 값을 가져오거나 설정합니다.

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

{ get; private set; }

다음에 의해서 참조됨 : BasicNack().

NackedDeliveryTags

List<ulong> Dreamine.FullKit.Tests.Communication.RabbitMqMessageBusTests.FakeRabbitMqChannel.NackedDeliveryTags = []

get

Nacked Delivery Tags 값을 가져옵니다.

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

{ get; } = [];

다음에 의해서 참조됨 : BasicNack().

Operations

List<string> Dreamine.FullKit.Tests.Communication.RabbitMqMessageBusTests.FakeRabbitMqChannel.Operations = []

get

Operations 값을 가져옵니다.

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

{ get; } = [];

다음에 의해서 참조됨 : BasicConsume(), ExchangeDeclare(), QueueBind(), QueueDeclare().

PublishedMessages

List<PublishedMessage> Dreamine.FullKit.Tests.Communication.RabbitMqMessageBusTests.FakeRabbitMqChannel.PublishedMessages = []

get

Published Messages 값을 가져옵니다.

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

{ get; } = [];

다음에 의해서 참조됨 : BasicPublish().

RejectedDeliveryTags

List<ulong> Dreamine.FullKit.Tests.Communication.RabbitMqMessageBusTests.FakeRabbitMqChannel.RejectedDeliveryTags = []

get

Rejected Delivery Tags 값을 가져옵니다.

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

{ get; } = [];

다음에 의해서 참조됨 : BasicReject().

---

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

• RabbitMqMessageBusTests.cs