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

더 자세히 ...

클래스
class	RabbitMqFixture
class	FakeRabbitMqConnectionFactory
class	FakeRabbitMqConnection
class	FakeRabbitMqChannel
class	FakeRabbitMqBasicProperties

Public 멤버 함수
async Task	ConnectAsync_DeclaresConfiguredTopology ()
async Task	PublishAsync_UsesMessageRouteAndSerializesEnvelope ()
async Task	PublishAsync_UsesConfiguredRoutingKeyWhenMessageRouteIsEmpty ()
async Task	SubscribeAsync_BindsRouteConsumesAndAcknowledgesHandledDelivery ()
async Task	SubscribeAsync_AllowsMultipleHandlersForSameRoute ()
async Task	SubscribeAsync_NacksDeliveryWhenHandlerFails ()
async Task	DisconnectAsync_CancelsConsumerAndClosesResources ()

Private 멤버 함수
record	PublishedMessage (string Exchange, string RoutingKey, bool Mandatory, FakeRabbitMqBasicProperties Properties, ReadOnlyMemory< byte > Body)

상세한 설명

Rabbit Mq Message Bus Tests 기능과 관련 상태를 캡슐화합니다.

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

멤버 함수 문서화

ConnectAsync_DeclaresConfiguredTopology()

async Task Dreamine.FullKit.Tests.Communication.RabbitMqMessageBusTests.ConnectAsync_DeclaresConfiguredTopology ( )

inline

Connect Async Declares Configured Topology 작업을 수행합니다.

반환값

Connect Async Declares Configured Topology 작업에서 생성한 Task 결과입니다.

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

    {
        var fixture = new RabbitMqFixture(new RabbitMqMessageBusOptions
        {
            ExchangeName = "dreamine.exchange",
            QueueName = "dreamine.queue",
            RoutingKey = "dreamine.route",
            ExchangeType = "topic",
            Durable = true,
            AutoDelete = true,
            Exclusive = true
        });
 
        await fixture.Bus.ConnectAsync();
 
        Assert.Equal(ConnectionState.Connected, fixture.Bus.State);
        Assert.Equal("exchange:dreamine.exchange:topic:True:True", fixture.Channel.Operations[0]);
        Assert.Equal("queue:dreamine.queue:True:True:True", fixture.Channel.Operations[1]);
        Assert.Equal("bind:dreamine.queue:dreamine.exchange:dreamine.route", fixture.Channel.Operations[2]);
    }

다음을 참조함 : Dreamine.FullKit.Tests.Communication.RabbitMqMessageBusTests.RabbitMqFixture.Bus.

DisconnectAsync_CancelsConsumerAndClosesResources()

async Task Dreamine.FullKit.Tests.Communication.RabbitMqMessageBusTests.DisconnectAsync_CancelsConsumerAndClosesResources ( )

inline

Disconnect Async Cancels Consumer And Closes Resources 작업을 수행합니다.

반환값

Disconnect Async Cancels Consumer And Closes Resources 작업에서 생성한 Task 결과입니다.

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

    {
        var fixture = new RabbitMqFixture(new RabbitMqMessageBusOptions());
 
        await fixture.Bus.ConnectAsync();
        await fixture.Bus.SubscribeAsync("route", (_, _) => Task.CompletedTask);
        await fixture.Bus.DisconnectAsync();
 
        Assert.Equal(ConnectionState.Disconnected, fixture.Bus.State);
        Assert.Contains("consumer-1", fixture.Channel.CancelledConsumerTags);
        Assert.True(fixture.Channel.Closed);
        Assert.True(fixture.Connection.Closed);
    }

PublishAsync_UsesConfiguredRoutingKeyWhenMessageRouteIsEmpty()

async Task Dreamine.FullKit.Tests.Communication.RabbitMqMessageBusTests.PublishAsync_UsesConfiguredRoutingKeyWhenMessageRouteIsEmpty ( )

inline

Publish Async Uses Configured Routing Key When Message Route Is Empty 작업을 수행합니다.

반환값

Publish Async Uses Configured Routing Key When Message Route Is Empty 작업에서 생성한 Task 결과입니다.

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

    {
        var fixture = new RabbitMqFixture(new RabbitMqMessageBusOptions
        {
            RoutingKey = "fallback.route"
        });
 
        await fixture.Bus.ConnectAsync();
 
        await fixture.Bus.PublishAsync(new MessageEnvelope { Name = "Rabbit.Publish" });
 
        Assert.Equal("fallback.route", fixture.Channel.PublishedMessages[0].RoutingKey);
    }

다음을 참조함 : Dreamine.FullKit.Tests.Communication.RabbitMqMessageBusTests.RabbitMqFixture.Bus.

PublishAsync_UsesMessageRouteAndSerializesEnvelope()

async Task Dreamine.FullKit.Tests.Communication.RabbitMqMessageBusTests.PublishAsync_UsesMessageRouteAndSerializesEnvelope ( )

inline

Publish Async Uses Message Route And Serializes Envelope 작업을 수행합니다.

반환값

Publish Async Uses Message Route And Serializes Envelope 작업에서 생성한 Task 결과입니다.

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

    {
        var fixture = new RabbitMqFixture(new RabbitMqMessageBusOptions
        {
            ExchangeName = "dreamine.exchange",
            RoutingKey = "fallback.route",
            PersistentMessages = true
        });
 
        await fixture.Bus.ConnectAsync();
 
        var message = new MessageEnvelope
        {
            Name = "Rabbit.Publish",
            Route = "message.route",
            Payload = [1, 2, 3],
            Headers = new Dictionary<string, string> { ["Protocol"] = "RabbitMQ" }
        };
 
        await fixture.Bus.PublishAsync(message);
 
        Assert.Single(fixture.Channel.PublishedMessages);
 
        var published = fixture.Channel.PublishedMessages[0];
        var roundTripped = JsonSerializer.Deserialize<MessageEnvelope>(published.Body.Span);
 
        Assert.Equal("dreamine.exchange", published.Exchange);
        Assert.Equal("message.route", published.RoutingKey);
        Assert.True(published.Properties.Persistent);
        Assert.Equal("application/json", published.Properties.ContentType);
        Assert.Equal(nameof(MessageEnvelope), published.Properties.Type);
        Assert.NotNull(roundTripped);
        Assert.Equal(message.Name, roundTripped.Name);
        Assert.Equal(message.Route, roundTripped.Route);
        Assert.Equal(message.Payload, roundTripped.Payload);
    }

다음을 참조함 : Dreamine.FullKit.Tests.Communication.RabbitMqMessageBusTests.RabbitMqFixture.Bus.

PublishedMessage()

record Dreamine.FullKit.Tests.Communication.RabbitMqMessageBusTests.PublishedMessage ( string Exchange, string RoutingKey, bool Mandatory, FakeRabbitMqBasicProperties Properties, ReadOnlyMemory< byte > Body )

sealedprivate

Published Message 기능과 관련 상태를 캡슐화합니다.

다음에 의해서 참조됨 : Dreamine.FullKit.Tests.Communication.RabbitMqMessageBusTests.FakeRabbitMqChannel.BasicPublish().

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

SubscribeAsync_AllowsMultipleHandlersForSameRoute()

async Task Dreamine.FullKit.Tests.Communication.RabbitMqMessageBusTests.SubscribeAsync_AllowsMultipleHandlersForSameRoute ( )

inline

Subscribe Async Allows Multiple Handlers For Same Route 작업을 수행합니다.

반환값

Subscribe Async Allows Multiple Handlers For Same Route 작업에서 생성한 Task 결과입니다.

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

    {
        var fixture = new RabbitMqFixture(new RabbitMqMessageBusOptions
        {
            ExchangeName = "dreamine.exchange",
            QueueName = "dreamine.queue"
        });
        var calls = new List<string>();
 
        await fixture.Bus.ConnectAsync();
        await fixture.Bus.SubscribeAsync(
            "custom.route",
            (_, _) =>
            {
                calls.Add("first");
                return Task.CompletedTask;
            });
        await fixture.Bus.SubscribeAsync(
            "custom.route",
            (_, _) =>
            {
                calls.Add("second");
                return Task.CompletedTask;
            });
 
        var delivery = new RabbitMqDelivery(
            13,
            "custom.route",
            JsonSerializer.SerializeToUtf8Bytes(new MessageEnvelope
            {
                Name = "Rabbit.Receive",
                Route = "custom.route"
            }));
 
        await fixture.Channel.DeliverAsync(delivery);
 
        Assert.Equal(["first", "second"], calls);
        Assert.Equal([13UL], fixture.Channel.AckedDeliveryTags);
        Assert.Empty(fixture.Channel.NackedDeliveryTags);
    }

SubscribeAsync_BindsRouteConsumesAndAcknowledgesHandledDelivery()

async Task Dreamine.FullKit.Tests.Communication.RabbitMqMessageBusTests.SubscribeAsync_BindsRouteConsumesAndAcknowledgesHandledDelivery ( )

inline

Subscribe Async Binds Route Consumes And Acknowledges Handled Delivery 작업을 수행합니다.

반환값

Subscribe Async Binds Route Consumes And Acknowledges Handled Delivery 작업에서 생성한 Task 결과입니다.

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

    {
        var fixture = new RabbitMqFixture(new RabbitMqMessageBusOptions
        {
            ExchangeName = "dreamine.exchange",
            QueueName = "dreamine.queue"
        });
 
        await fixture.Bus.ConnectAsync();
 
        MessageEnvelope? handled = null;
        await fixture.Bus.SubscribeAsync(
            "custom.route",
            (message, _) =>
            {
                handled = message;
                return Task.CompletedTask;
            });
 
        var delivery = new RabbitMqDelivery(
            7,
            "custom.route",
            JsonSerializer.SerializeToUtf8Bytes(new MessageEnvelope
            {
                Name = "Rabbit.Receive",
                Route = "custom.route",
                Payload = [9, 8, 7]
            }));
 
        await fixture.Channel.DeliverAsync(delivery);
 
        Assert.NotNull(handled);
        Assert.Equal("Rabbit.Receive", handled.Name);
        Assert.Contains("bind:dreamine.queue:dreamine.exchange:custom.route", fixture.Channel.Operations);
        Assert.Equal("consume:dreamine.queue:False", fixture.Channel.Operations.Last(x => x.StartsWith("consume:", StringComparison.Ordinal)));
        Assert.Equal([7UL], fixture.Channel.AckedDeliveryTags);
        Assert.Empty(fixture.Channel.NackedDeliveryTags);
    }

다음을 참조함 : Dreamine.FullKit.Tests.Communication.RabbitMqMessageBusTests.RabbitMqFixture.Bus.

SubscribeAsync_NacksDeliveryWhenHandlerFails()

async Task Dreamine.FullKit.Tests.Communication.RabbitMqMessageBusTests.SubscribeAsync_NacksDeliveryWhenHandlerFails ( )

inline

Subscribe Async Nacks Delivery When Handler Fails 작업을 수행합니다.

반환값

Subscribe Async Nacks Delivery When Handler Fails 작업에서 생성한 Task 결과입니다.

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

    {
        var fixture = new RabbitMqFixture(new RabbitMqMessageBusOptions
        {
            RequeueOnHandlerError = true
        });
 
        await fixture.Bus.ConnectAsync();
        await fixture.Bus.SubscribeAsync(
            "failing.route",
            (_, _) => throw new InvalidOperationException("handler failed"));
 
        var delivery = new RabbitMqDelivery(
            11,
            "failing.route",
            JsonSerializer.SerializeToUtf8Bytes(new MessageEnvelope
            {
                Name = "Rabbit.Receive",
                Route = "failing.route"
            }));
 
        await Assert.ThrowsAsync<InvalidOperationException>(() => fixture.Channel.DeliverAsync(delivery));
 
        Assert.Equal([11UL], fixture.Channel.NackedDeliveryTags);
        Assert.True(fixture.Channel.LastNackRequeue);
        Assert.Empty(fixture.Channel.AckedDeliveryTags);
    }

다음을 참조함 : Dreamine.FullKit.Tests.Communication.RabbitMqMessageBusTests.RabbitMqFixture.Bus.

---

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

• RabbitMqMessageBusTests.cs