add missing queues configurations

Signed-off-by: Gabriele Santomaggio <[email protected]>

Author: Gsantomaggio

RabbitMQ.AMQP.Client/IEntities.cs

@@ -35,13 +35,18 @@ public enum OverFlowStrategy
     {
         DropHead,
         RejectPublish,
-
         RejectPublishDlx
         // DROP_HEAD("drop-head"),
         // REJECT_PUBLISH("reject-publish"),
         // REJECT_PUBLISH_DLX("reject-publish-dlx");
     }
 
+    public enum LeaderLocatorStrategy
+    {
+        ClientLocal,
+        Balanced
+    }
+
     public interface IQueueSpecification : IEntityInfoSpecification<IQueueInfo>
     {
         public string QueueName { get; }
@@ -92,6 +97,10 @@ public interface IStreamSpecification
         public IStreamSpecification MaxSegmentSizeBytes(ByteCapacity maxSegmentSize);
 
         public IStreamSpecification InitialClusterSize(int initialClusterSize);
+        
+        public IStreamSpecification LeaderLocator(LeaderLocatorStrategy leaderLocatorStrategy);
+        
+        public IStreamSpecification FileSizePerChunk(ByteCapacity fileSizePerChunk);
 
         public IQueueSpecification Queue();
     }

RabbitMQ.AMQP.Client/Impl/AmqpQueueSpecification.cs

@@ -397,6 +397,25 @@ public IStreamSpecification InitialClusterSize(int initialClusterSize)
             return this;
         }
 
+        public IStreamSpecification LeaderLocator(LeaderLocatorStrategy leaderLocatorStrategy)
+        {
+            _parent._queueArguments["x-queue-leader-locator"] = leaderLocatorStrategy switch
+            {
+                LeaderLocatorStrategy.ClientLocal => "client-local",
+                LeaderLocatorStrategy.Balanced => "balanced",
+                _ => throw new ArgumentOutOfRangeException(nameof(leaderLocatorStrategy), leaderLocatorStrategy, null)
+            };
+            return this;
+        }
+
+        public IStreamSpecification FileSizePerChunk(ByteCapacity fileSizePerChunk)
+        {
+            Utils.ValidatePositive("x-stream-file-size-per-chunk", fileSizePerChunk);
+            _parent._queueArguments["x-stream-file-size-per-chunk"] = (long)fileSizePerChunk;
+            return this;
+            
+        }
+
         public IQueueSpecification Queue()
         {
             return _parent;

RabbitMQ.AMQP.Client/PublicAPI.Unshipped.txt

@@ -499,7 +499,9 @@ RabbitMQ.AMQP.Client.Impl.AmqpRpcServerBuilder.RequestQueue(RabbitMQ.AMQP.Client
 RabbitMQ.AMQP.Client.Impl.AmqpRpcServerBuilder.RequestQueue(string! requestQueue) -> RabbitMQ.AMQP.Client.IRpcServerBuilder!
 RabbitMQ.AMQP.Client.Impl.AmqpStreamSpecification
 RabbitMQ.AMQP.Client.Impl.AmqpStreamSpecification.AmqpStreamSpecification(RabbitMQ.AMQP.Client.Impl.AmqpQueueSpecification! parent) -> void
+RabbitMQ.AMQP.Client.Impl.AmqpStreamSpecification.FileSizePerChunk(RabbitMQ.AMQP.Client.ByteCapacity! fileSizePerChunk) -> RabbitMQ.AMQP.Client.IStreamSpecification!
 RabbitMQ.AMQP.Client.Impl.AmqpStreamSpecification.InitialClusterSize(int initialClusterSize) -> RabbitMQ.AMQP.Client.IStreamSpecification!
+RabbitMQ.AMQP.Client.Impl.AmqpStreamSpecification.LeaderLocator(RabbitMQ.AMQP.Client.LeaderLocatorStrategy leaderLocatorStrategy) -> RabbitMQ.AMQP.Client.IStreamSpecification!
 RabbitMQ.AMQP.Client.Impl.AmqpStreamSpecification.MaxAge(System.TimeSpan maxAge) -> RabbitMQ.AMQP.Client.IStreamSpecification!
 RabbitMQ.AMQP.Client.Impl.AmqpStreamSpecification.MaxSegmentSizeBytes(RabbitMQ.AMQP.Client.ByteCapacity! maxSegmentSize) -> RabbitMQ.AMQP.Client.IStreamSpecification!
 RabbitMQ.AMQP.Client.Impl.AmqpStreamSpecification.Queue() -> RabbitMQ.AMQP.Client.IQueueSpecification!
@@ -680,12 +682,17 @@ RabbitMQ.AMQP.Client.IRpcServerBuilder.ReplyPostProcessor(System.Func<RabbitMQ.A
 RabbitMQ.AMQP.Client.IRpcServerBuilder.RequestQueue(RabbitMQ.AMQP.Client.IQueueSpecification! requestQueue) -> RabbitMQ.AMQP.Client.IRpcServerBuilder!
 RabbitMQ.AMQP.Client.IRpcServerBuilder.RequestQueue(string! requestQueue) -> RabbitMQ.AMQP.Client.IRpcServerBuilder!
 RabbitMQ.AMQP.Client.IStreamSpecification
+RabbitMQ.AMQP.Client.IStreamSpecification.FileSizePerChunk(RabbitMQ.AMQP.Client.ByteCapacity! fileSizePerChunk) -> RabbitMQ.AMQP.Client.IStreamSpecification!
 RabbitMQ.AMQP.Client.IStreamSpecification.InitialClusterSize(int initialClusterSize) -> RabbitMQ.AMQP.Client.IStreamSpecification!
+RabbitMQ.AMQP.Client.IStreamSpecification.LeaderLocator(RabbitMQ.AMQP.Client.LeaderLocatorStrategy leaderLocatorStrategy) -> RabbitMQ.AMQP.Client.IStreamSpecification!
 RabbitMQ.AMQP.Client.IStreamSpecification.MaxAge(System.TimeSpan maxAge) -> RabbitMQ.AMQP.Client.IStreamSpecification!
 RabbitMQ.AMQP.Client.IStreamSpecification.MaxSegmentSizeBytes(RabbitMQ.AMQP.Client.ByteCapacity! maxSegmentSize) -> RabbitMQ.AMQP.Client.IStreamSpecification!
 RabbitMQ.AMQP.Client.IStreamSpecification.Queue() -> RabbitMQ.AMQP.Client.IQueueSpecification!
 RabbitMQ.AMQP.Client.IUriSelector
 RabbitMQ.AMQP.Client.IUriSelector.Select(System.Collections.Generic.ICollection<System.Uri!>! uris) -> System.Uri!
+RabbitMQ.AMQP.Client.LeaderLocatorStrategy
+RabbitMQ.AMQP.Client.LeaderLocatorStrategy.Balanced = 1 -> RabbitMQ.AMQP.Client.LeaderLocatorStrategy
+RabbitMQ.AMQP.Client.LeaderLocatorStrategy.ClientLocal = 0 -> RabbitMQ.AMQP.Client.LeaderLocatorStrategy
 RabbitMQ.AMQP.Client.LifeCycleCallBack
 RabbitMQ.AMQP.Client.MessageHandler
 RabbitMQ.AMQP.Client.MetricsReporter