Skip to content

Commit

Permalink
deletetion
Browse files Browse the repository at this point in the history
Signed-off-by: Gabriele Santomaggio <[email protected]>
  • Loading branch information
Gsantomaggio committed May 31, 2024
1 parent ee6fe6a commit 8dd3aca
Show file tree
Hide file tree
Showing 3 changed files with 4 additions and 4 deletions.
2 changes: 1 addition & 1 deletion RabbitMQ.AMQP.Client/AmqpQueueSpecification.cs
Original file line number Diff line number Diff line change
Expand Up @@ -33,7 +33,7 @@ internal DefaultQueueInfo(Map response)

this._leader = (string)response["leader"];
var replicas = (string[])response["replicas"];
this._replicas = replicas.Length == 0 ? [] : [..replicas];
this._replicas = replicas.Length == 0 ? [] : [.. replicas];
this._messageCount = ((ulong)response["message_count"]);
this._consumerCount = ((uint)response["consumer_count"]);
}
Expand Down
4 changes: 2 additions & 2 deletions RabbitMQ.AMQP.Client/IMessage.cs
Original file line number Diff line number Diff line change
Expand Up @@ -11,10 +11,10 @@ public interface IMessage

string CorrelationId();
IMessage CorrelationId(string id);

string ReplyTo();
IMessage ReplyTo(string id);

string Subject();
IMessage Subject(string subject);

Expand Down
2 changes: 1 addition & 1 deletion Tests/ManagementTests.cs
Original file line number Diff line number Diff line change
Expand Up @@ -128,7 +128,7 @@ public async void DeclareQueueWithQueueInfoValidation()
Assert.Equal("validate_queue_info", queueInfo.Name());
Assert.Equal((ulong)0, queueInfo.MessageCount());
Assert.Equal((uint)0, queueInfo.ConsumerCount());
Assert.Equal(QueueType.CLASSIC , queueInfo.Type());
Assert.Equal(QueueType.CLASSIC, queueInfo.Type());
Assert.Single(queueInfo.Replicas());
Assert.NotNull(queueInfo.Leader());
Assert.True(queueInfo.Durable());
Expand Down

0 comments on commit 8dd3aca

Please sign in to comment.