Skip to content

Commit c92fbd5

Browse files
committed
Fix merge
Signed-off-by: Gabriele Santomaggio <[email protected]>
1 parent 581f30e commit c92fbd5

File tree

4 files changed

+5
-5
lines changed

4 files changed

+5
-5
lines changed

RabbitMQ.AMQP.Client/IRecoveryConfiguration.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -60,6 +60,6 @@ public interface IBackOffDelayPolicy
6060
/// or when the user wants to disable the backoff delay policy.
6161
/// </summary>
6262
bool IsActive();
63-
63+
6464
int CurrentAttempt { get; }
6565
}

RabbitMQ.AMQP.Client/Impl/AmqpManagement.cs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -388,8 +388,8 @@ public override string ToString()
388388

389389
return info;
390390
}
391-
392-
391+
392+
393393
internal void ChangeStatus(State newState, Error? error)
394394
{
395395
OnNewStatus(newState, error);

RabbitMQ.AMQP.Client/Impl/ConnectionSettings.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -295,7 +295,7 @@ public static BackOffDelayPolicy Create()
295295
{
296296
return new BackOffDelayPolicy();
297297
}
298-
298+
299299
public static BackOffDelayPolicy Create(int maxAttempt)
300300
{
301301
return new BackOffDelayPolicy(maxAttempt);

Tests/ManagementTests.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -111,7 +111,7 @@ await management.Request(messageId, "", "", "",
111111
public async Task RaiseManagementClosedException()
112112
{
113113
var management = new TestAmqpManagement();
114-
await Assert.ThrowsAsync<AmqpClosedException>(async () =>
114+
await Assert.ThrowsAsync<AmqpNotOpenException>(async () =>
115115
await management.Request(new Message(), [200]));
116116
Assert.Equal(State.Closed, management.State);
117117
}

0 commit comments

Comments
 (0)