From 9247aeb198fbb75c0ead8bf8ffa46539957b386f Mon Sep 17 00:00:00 2001 From: "Tristan (HouseCat) Hyams" Date: Sun, 31 Mar 2024 10:27:54 -0500 Subject: [PATCH] More letter renaming. --- src/HouseofCat.RabbitMQ/Options/PublisherOptions.cs | 2 +- src/HouseofCat.RabbitMQ/Publisher/Publisher.cs | 2 +- src/HouseofCat.RabbitMQ/README.md | 5 ++--- src/HouseofCat.RabbitMQ/SampleRabbitOptions.json | 3 +-- tests/RabbitMQ.Console.Tests/RabbitMQ.PubSubTests.json | 3 +-- tests/RabbitMQ.Console.Tests/RabbitMQ.PublisherTests.json | 1 - .../RabbitMQ.Console.Tests/RabbitMQ.RabbitServiceTests.json | 3 +-- tests/RabbitMQ.Console.Tests/Tests/PublisherTests.cs | 2 +- .../RabbitMQ.ConsumerDataflows.json | 3 +-- 9 files changed, 9 insertions(+), 15 deletions(-) diff --git a/src/HouseofCat.RabbitMQ/Options/PublisherOptions.cs b/src/HouseofCat.RabbitMQ/Options/PublisherOptions.cs index d5fa0ac8..a4286670 100644 --- a/src/HouseofCat.RabbitMQ/Options/PublisherOptions.cs +++ b/src/HouseofCat.RabbitMQ/Options/PublisherOptions.cs @@ -5,7 +5,7 @@ namespace HouseofCat.RabbitMQ; public class PublisherOptions { public bool CreatePublishReceipts { get; set; } - public int LetterQueueBufferSize { get; set; } = 10_000; + public int MessageQueueBufferSize { get; set; } = 10_000; public BoundedChannelFullMode BehaviorWhenFull { get; set; } = BoundedChannelFullMode.Wait; public bool Compress { get; set; } diff --git a/src/HouseofCat.RabbitMQ/Publisher/Publisher.cs b/src/HouseofCat.RabbitMQ/Publisher/Publisher.cs index d7151014..1ff0f9ab 100644 --- a/src/HouseofCat.RabbitMQ/Publisher/Publisher.cs +++ b/src/HouseofCat.RabbitMQ/Publisher/Publisher.cs @@ -175,7 +175,7 @@ public async Task StartAutoPublishAsync(Func process private void SetupPublisher(Func processReceiptAsync = null) { _messageQueue = Channel.CreateBounded( - new BoundedChannelOptions(Options.PublisherOptions.LetterQueueBufferSize) + new BoundedChannelOptions(Options.PublisherOptions.MessageQueueBufferSize) { FullMode = Options.PublisherOptions.BehaviorWhenFull }); diff --git a/src/HouseofCat.RabbitMQ/README.md b/src/HouseofCat.RabbitMQ/README.md index 4ce48dc7..7d22f9c1 100644 --- a/src/HouseofCat.RabbitMQ/README.md +++ b/src/HouseofCat.RabbitMQ/README.md @@ -5,7 +5,7 @@ Review tutorials and documentation under `./guides/rabbitmq`. Sample Config File -```javascript +```json { "FactoryOptions": { "Uri": "amqp://guest:guest@localhost:5672/", @@ -27,8 +27,7 @@ Sample Config File "UseTransientChannels": false }, "PublisherOptions": { - "LetterQueueBufferSize": 100, - "PriorityLetterQueueBufferSize": 100, + "MessageQueueBufferSize": 100, "BehaviorWhenFull": 0, "AutoPublisherSleepInterval": 1, "CreatePublishReceipts": true, diff --git a/src/HouseofCat.RabbitMQ/SampleRabbitOptions.json b/src/HouseofCat.RabbitMQ/SampleRabbitOptions.json index bacd0ea2..19642cef 100644 --- a/src/HouseofCat.RabbitMQ/SampleRabbitOptions.json +++ b/src/HouseofCat.RabbitMQ/SampleRabbitOptions.json @@ -30,8 +30,7 @@ "UseTransientChannels": false }, "PublisherOptions": { - "LetterQueueBufferSize": 100, - "PriorityLetterQueueBufferSize": 100, + "MessageQueueBufferSize": 100, "BehaviorWhenFull": 0, "AutoPublisherSleepInterval": 0, "CreatePublishReceipts": true, diff --git a/tests/RabbitMQ.Console.Tests/RabbitMQ.PubSubTests.json b/tests/RabbitMQ.Console.Tests/RabbitMQ.PubSubTests.json index 799ac87b..eecbca91 100644 --- a/tests/RabbitMQ.Console.Tests/RabbitMQ.PubSubTests.json +++ b/tests/RabbitMQ.Console.Tests/RabbitMQ.PubSubTests.json @@ -19,8 +19,7 @@ "UseTransientChannels": false }, "PublisherOptions": { - "LetterQueueBufferSize": 100, - "PriorityLetterQueueBufferSize": 100, + "MessageQueueBufferSize": 100, "BehaviorWhenFull": 0, "AutoPublisherSleepInterval": 1, "CreatePublishReceipts": true, diff --git a/tests/RabbitMQ.Console.Tests/RabbitMQ.PublisherTests.json b/tests/RabbitMQ.Console.Tests/RabbitMQ.PublisherTests.json index f2aa3300..90ac5ee0 100644 --- a/tests/RabbitMQ.Console.Tests/RabbitMQ.PublisherTests.json +++ b/tests/RabbitMQ.Console.Tests/RabbitMQ.PublisherTests.json @@ -20,7 +20,6 @@ }, "PublisherOptions": { "LetterQueueBufferSize": 100, - "PriorityLetterQueueBufferSize": 100, "BehaviorWhenFull": 0, "AutoPublisherSleepInterval": 1, "CreatePublishReceipts": true, diff --git a/tests/RabbitMQ.Console.Tests/RabbitMQ.RabbitServiceTests.json b/tests/RabbitMQ.Console.Tests/RabbitMQ.RabbitServiceTests.json index d0b9b8e2..ce2fbbf9 100644 --- a/tests/RabbitMQ.Console.Tests/RabbitMQ.RabbitServiceTests.json +++ b/tests/RabbitMQ.Console.Tests/RabbitMQ.RabbitServiceTests.json @@ -19,8 +19,7 @@ "UseTransientChannels": false }, "PublisherOptions": { - "LetterQueueBufferSize": 100, - "PriorityLetterQueueBufferSize": 100, + "MessageQueueBufferSize": 100, "BehaviorWhenFull": 0, "AutoPublisherSleepInterval": 1, "CreatePublishReceipts": true, diff --git a/tests/RabbitMQ.Console.Tests/Tests/PublisherTests.cs b/tests/RabbitMQ.Console.Tests/Tests/PublisherTests.cs index a748bcb4..594dfaa0 100644 --- a/tests/RabbitMQ.Console.Tests/Tests/PublisherTests.cs +++ b/tests/RabbitMQ.Console.Tests/Tests/PublisherTests.cs @@ -68,7 +68,7 @@ public static async Task RunAutoPublisherStandaloneAsync() PublisherOptions = new PublisherOptions { CreatePublishReceipts = true, - LetterQueueBufferSize = 10_000, + MessageQueueBufferSize = 10_000, BehaviorWhenFull = BoundedChannelFullMode.Wait, Compress = false, Encrypt = false, diff --git a/tests/RabbitMQ.ConsumerDataflows.Tests/RabbitMQ.ConsumerDataflows.json b/tests/RabbitMQ.ConsumerDataflows.Tests/RabbitMQ.ConsumerDataflows.json index d0b9b8e2..ce2fbbf9 100644 --- a/tests/RabbitMQ.ConsumerDataflows.Tests/RabbitMQ.ConsumerDataflows.json +++ b/tests/RabbitMQ.ConsumerDataflows.Tests/RabbitMQ.ConsumerDataflows.json @@ -19,8 +19,7 @@ "UseTransientChannels": false }, "PublisherOptions": { - "LetterQueueBufferSize": 100, - "PriorityLetterQueueBufferSize": 100, + "MessageQueueBufferSize": 100, "BehaviorWhenFull": 0, "AutoPublisherSleepInterval": 1, "CreatePublishReceipts": true,