More letter renaming.

houseofcat · Mar 31, 2024 · 9247aeb · 9247aeb
1 parent 1bfc7ba
commit 9247aeb
Show file tree

Hide file tree

Showing 9 changed files with 9 additions and 15 deletions.
diff --git 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
@@ -175,7 +175,7 @@ public async Task StartAutoPublishAsync(Func<IPublishReceipt, ValueTask> process
     private void SetupPublisher(Func<IPublishReceipt, ValueTask> processReceiptAsync = null)
     {
         _messageQueue = Channel.CreateBounded<IMessage>(
-        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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -19,8 +19,7 @@
     "UseTransientChannels": false
   },
   "PublisherOptions": {
-    "LetterQueueBufferSize": 100,
-    "PriorityLetterQueueBufferSize": 100,
+    "MessageQueueBufferSize": 100,
     "BehaviorWhenFull": 0,
     "AutoPublisherSleepInterval": 1,
     "CreatePublishReceipts": true,