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

더 자세히 ...

Public 멤버 함수
async Task	Queue_DropsOldestWhenFullAddingToBack ()
async Task	Queue_DropsNewestWhenFullAddingToFront ()
async Task	Queue_ThrowsWhenFullAndDroppingDisabled ()
void	QueuedOutboundMessage_TracksExpirationAndFailure ()

정적 Private 멤버 함수
static QueuedOutboundMessage	Create (string name)

상세한 설명

Outbound Queue Tests 기능과 관련 상태를 캡슐화합니다.

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

멤버 함수 문서화

Create()

QueuedOutboundMessage Dreamine.FullKit.Tests.Communication.OutboundQueueTests.Create ( string name )

inlinestaticprivate

값을 생성합니다.

매개변수

name	name에 사용할 string 값입니다.

반환값

Create 작업에서 생성한 QueuedOutboundMessage 결과입니다.

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

    {
        return new QueuedOutboundMessage(new MessageEnvelope { Name = name });
    }

다음에 의해서 참조됨 : Queue_DropsNewestWhenFullAddingToFront(), Queue_DropsOldestWhenFullAddingToBack(), Queue_ThrowsWhenFullAndDroppingDisabled().

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

Queue_DropsNewestWhenFullAddingToFront()

async Task Dreamine.FullKit.Tests.Communication.OutboundQueueTests.Queue_DropsNewestWhenFullAddingToFront ( )

inline

Queue Drops Newest When Full Adding To Front 작업을 수행합니다.

반환값

Queue Drops Newest When Full Adding To Front 작업에서 생성한 Task 결과입니다.

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

    {
        var queue = new InMemoryOutboundMessageQueue(new OutboundQueueOptions
        {
            MaxQueueSize = 2,
            DropOldestWhenFull = true
        });
 
        await queue.EnqueueAsync(Create("one"));
        await queue.EnqueueAsync(Create("two"));
        await queue.EnqueueFrontAsync(Create("zero"));
 
        Assert.Equal("zero", (await queue.TryDequeueAsync())!.Message.Name);
        Assert.Equal("one", (await queue.TryDequeueAsync())!.Message.Name);
    }

다음을 참조함 : Create().

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

Queue_DropsOldestWhenFullAddingToBack()

async Task Dreamine.FullKit.Tests.Communication.OutboundQueueTests.Queue_DropsOldestWhenFullAddingToBack ( )

inline

Queue Drops Oldest When Full Adding To Back 작업을 수행합니다.

반환값

Queue Drops Oldest When Full Adding To Back 작업에서 생성한 Task 결과입니다.

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

    {
        var queue = new InMemoryOutboundMessageQueue(new OutboundQueueOptions
        {
            MaxQueueSize = 2,
            DropOldestWhenFull = true
        });
 
        await queue.EnqueueAsync(Create("one"));
        await queue.EnqueueAsync(Create("two"));
        await queue.EnqueueAsync(Create("three"));
 
        Assert.Equal("two", (await queue.TryDequeueAsync())!.Message.Name);
        Assert.Equal("three", (await queue.TryDequeueAsync())!.Message.Name);
        Assert.Null(await queue.TryDequeueAsync());
    }

다음을 참조함 : Create().

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

Queue_ThrowsWhenFullAndDroppingDisabled()

async Task Dreamine.FullKit.Tests.Communication.OutboundQueueTests.Queue_ThrowsWhenFullAndDroppingDisabled ( )

inline

Queue Throws When Full And Dropping Disabled 작업을 수행합니다.

반환값

Queue Throws When Full And Dropping Disabled 작업에서 생성한 Task 결과입니다.

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

    {
        var queue = new InMemoryOutboundMessageQueue(new OutboundQueueOptions
        {
            MaxQueueSize = 1,
            DropOldestWhenFull = false
        });
 
        await queue.EnqueueAsync(Create("one"));
 
        await Assert.ThrowsAsync<InvalidOperationException>(
            async () => await queue.EnqueueAsync(Create("two")));
    }

다음을 참조함 : Create().

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

QueuedOutboundMessage_TracksExpirationAndFailure()

void Dreamine.FullKit.Tests.Communication.OutboundQueueTests.QueuedOutboundMessage_TracksExpirationAndFailure ( )

inline

Queued Outbound Message Tracks Expiration And Failure 작업을 수행합니다.

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

    {
        var queued = new QueuedOutboundMessage(
            new MessageEnvelope { Name = "Job" },
            new DateTimeOffset(2026, 6, 7, 0, 0, 0, TimeSpan.Zero),
            attemptCount: 2,
            lastError: null);
 
        var failed = queued.WithFailure(new InvalidOperationException("bad"));
 
        Assert.False(queued.IsExpired(null, queued.EnqueuedAt.AddDays(1)));
        Assert.True(queued.IsExpired(TimeSpan.FromSeconds(1), queued.EnqueuedAt.AddSeconds(2)));
        Assert.Equal(3, failed.AttemptCount);
        Assert.Equal("bad", failed.LastError);
        Assert.Same(queued.Message, failed.Message);
    }

---

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

• OutboundQueueTests.cs