Skip to content

Commit

Permalink
Fix ordered consumer creation
Browse files Browse the repository at this point in the history
  • Loading branch information
@mtmk
mtmk committed Feb 19, 2025
1 parent 0e2e280 commit a543e36
Showing 1 changed file with 4 additions and 0 deletions.
4 changes: 4 additions & 0 deletions src/NATS.Client.JetStream/NatsJSOrderedConsumer.cs
View file
Original file line number Diff line number Diff line change
Expand Up @@ -314,6 +314,10 @@ private async Task<NatsJSConsumer> RecreateConsumer(string consumer, ulong seq,
catch (NatsJSApiNoResponseException)
{
}
catch (NatsJSApiException apiException) when (apiException.Error.Code == 503)
{
}

Check warning on line 320 in src/NATS.Client.JetStream/NatsJSOrderedConsumer.cs

View workflow job for this annotation

GitHub Actions / test (latest)

Check warning on line 320 in src/NATS.Client.JetStream/NatsJSOrderedConsumer.cs

View workflow job for this annotation

GitHub Actions / test (latest)

Check warning on line 320 in src/NATS.Client.JetStream/NatsJSOrderedConsumer.cs

View workflow job for this annotation

GitHub Actions / test (latest)

Check warning on line 320 in src/NATS.Client.JetStream/NatsJSOrderedConsumer.cs

View workflow job for this annotation

GitHub Actions / test (latest)

Check warning on line 320 in src/NATS.Client.JetStream/NatsJSOrderedConsumer.cs

View workflow job for this annotation

GitHub Actions / test (v2.9)

Check warning on line 320 in src/NATS.Client.JetStream/NatsJSOrderedConsumer.cs

View workflow job for this annotation

GitHub Actions / test (v2.9)

Check warning on line 320 in src/NATS.Client.JetStream/NatsJSOrderedConsumer.cs

View workflow job for this annotation

GitHub Actions / test (v2.9)

Check warning on line 320 in src/NATS.Client.JetStream/NatsJSOrderedConsumer.cs

View workflow job for this annotation

GitHub Actions / test (v2.9)

Check warning on line 320 in src/NATS.Client.JetStream/NatsJSOrderedConsumer.cs

View workflow job for this annotation

GitHub Actions / test (main)

Check warning on line 320 in src/NATS.Client.JetStream/NatsJSOrderedConsumer.cs

View workflow job for this annotation

GitHub Actions / test (main)

Check warning on line 320 in src/NATS.Client.JetStream/NatsJSOrderedConsumer.cs

View workflow job for this annotation

GitHub Actions / test (main)

Check warning on line 320 in src/NATS.Client.JetStream/NatsJSOrderedConsumer.cs

View workflow job for this annotation

GitHub Actions / test (main)

Check warning on line 320 in src/NATS.Client.JetStream/NatsJSOrderedConsumer.cs

View workflow job for this annotation

GitHub Actions / check 

Code should not contain multiple blank lines in a row

Check warning on line 320 in src/NATS.Client.JetStream/NatsJSOrderedConsumer.cs

View workflow job for this annotation

GitHub Actions / check 

Code should not contain multiple blank lines in a row

Check warning on line 320 in src/NATS.Client.JetStream/NatsJSOrderedConsumer.cs

View workflow job for this annotation

GitHub Actions / check 

Code should not contain multiple blank lines in a row

Check warning on line 320 in src/NATS.Client.JetStream/NatsJSOrderedConsumer.cs

View workflow job for this annotation

GitHub Actions / check 

Code should not contain multiple blank lines in a row

Check warning on line 320 in src/NATS.Client.JetStream/NatsJSOrderedConsumer.cs

View workflow job for this annotation

GitHub Actions / Windows (v2.9)

Check warning on line 320 in src/NATS.Client.JetStream/NatsJSOrderedConsumer.cs

View workflow job for this annotation

GitHub Actions / Windows (v2.9)

Check warning on line 320 in src/NATS.Client.JetStream/NatsJSOrderedConsumer.cs

View workflow job for this annotation

GitHub Actions / Windows (v2.9)

Check warning on line 320 in src/NATS.Client.JetStream/NatsJSOrderedConsumer.cs

View workflow job for this annotation

GitHub Actions / Windows (v2.9)

Check warning on line 320 in src/NATS.Client.JetStream/NatsJSOrderedConsumer.cs

View workflow job for this annotation

GitHub Actions / Windows (v2.9)

Check warning on line 320 in src/NATS.Client.JetStream/NatsJSOrderedConsumer.cs

View workflow job for this annotation

GitHub Actions / Windows (v2.9)

Check warning on line 320 in src/NATS.Client.JetStream/NatsJSOrderedConsumer.cs

View workflow job for this annotation

GitHub Actions / Windows (v2.9)

Check warning on line 320 in src/NATS.Client.JetStream/NatsJSOrderedConsumer.cs

View workflow job for this annotation

GitHub Actions / Windows (v2.9)

Check warning on line 320 in src/NATS.Client.JetStream/NatsJSOrderedConsumer.cs

View workflow job for this annotation

GitHub Actions / Windows (main)

Check warning on line 320 in src/NATS.Client.JetStream/NatsJSOrderedConsumer.cs

View workflow job for this annotation

GitHub Actions / Windows (main)

Check warning on line 320 in src/NATS.Client.JetStream/NatsJSOrderedConsumer.cs

View workflow job for this annotation

GitHub Actions / Windows (main)

Check warning on line 320 in src/NATS.Client.JetStream/NatsJSOrderedConsumer.cs

View workflow job for this annotation

GitHub Actions / Windows (main)

Check warning on line 320 in src/NATS.Client.JetStream/NatsJSOrderedConsumer.cs

View workflow job for this annotation

GitHub Actions / Windows (main)

Check warning on line 320 in src/NATS.Client.JetStream/NatsJSOrderedConsumer.cs

View workflow job for this annotation

GitHub Actions / Windows (main)

Check warning on line 320 in src/NATS.Client.JetStream/NatsJSOrderedConsumer.cs

View workflow job for this annotation

GitHub Actions / Windows (main)

Check warning on line 320 in src/NATS.Client.JetStream/NatsJSOrderedConsumer.cs

View workflow job for this annotation

GitHub Actions / Windows (main)

Check warning on line 320 in src/NATS.Client.JetStream/NatsJSOrderedConsumer.cs

View workflow job for this annotation

GitHub Actions / Windows (latest)

Check warning on line 320 in src/NATS.Client.JetStream/NatsJSOrderedConsumer.cs

View workflow job for this annotation

GitHub Actions / Windows (latest)

Check warning on line 320 in src/NATS.Client.JetStream/NatsJSOrderedConsumer.cs

View workflow job for this annotation

GitHub Actions / Windows (latest)

Check warning on line 320 in src/NATS.Client.JetStream/NatsJSOrderedConsumer.cs

View workflow job for this annotation

GitHub Actions / Windows (latest)

Check warning on line 320 in src/NATS.Client.JetStream/NatsJSOrderedConsumer.cs

View workflow job for this annotation

GitHub Actions / Windows (latest)

Check warning on line 320 in src/NATS.Client.JetStream/NatsJSOrderedConsumer.cs

View workflow job for this annotation

GitHub Actions / Windows (latest)

Check warning on line 320 in src/NATS.Client.JetStream/NatsJSOrderedConsumer.cs

View workflow job for this annotation

GitHub Actions / Windows (latest)

Check warning on line 320 in src/NATS.Client.JetStream/NatsJSOrderedConsumer.cs

View workflow job for this annotation

GitHub Actions / Windows (latest)

Check warning on line 320 in src/NATS.Client.JetStream/NatsJSOrderedConsumer.cs

View workflow job for this annotation

GitHub Actions / Linux (main)

Check warning on line 320 in src/NATS.Client.JetStream/NatsJSOrderedConsumer.cs

View workflow job for this annotation

GitHub Actions / Linux (main)

Check warning on line 320 in src/NATS.Client.JetStream/NatsJSOrderedConsumer.cs

View workflow job for this annotation

GitHub Actions / Linux (main)

Check warning on line 320 in src/NATS.Client.JetStream/NatsJSOrderedConsumer.cs

View workflow job for this annotation

GitHub Actions / Linux (main)

Check warning on line 320 in src/NATS.Client.JetStream/NatsJSOrderedConsumer.cs

View workflow job for this annotation

GitHub Actions / Linux (main)

Check warning on line 320 in src/NATS.Client.JetStream/NatsJSOrderedConsumer.cs

View workflow job for this annotation

GitHub Actions / Linux (main)

Check warning on line 320 in src/NATS.Client.JetStream/NatsJSOrderedConsumer.cs

View workflow job for this annotation

GitHub Actions / Linux (main)

Check warning on line 320 in src/NATS.Client.JetStream/NatsJSOrderedConsumer.cs

View workflow job for this annotation

GitHub Actions / Linux (main)

Check warning on line 320 in src/NATS.Client.JetStream/NatsJSOrderedConsumer.cs

View workflow job for this annotation

GitHub Actions / Linux (v2.9)

Check warning on line 320 in src/NATS.Client.JetStream/NatsJSOrderedConsumer.cs

View workflow job for this annotation

GitHub Actions / Linux (v2.9)

Check warning on line 320 in src/NATS.Client.JetStream/NatsJSOrderedConsumer.cs

View workflow job for this annotation

GitHub Actions / Linux (v2.9)

Check warning on line 320 in src/NATS.Client.JetStream/NatsJSOrderedConsumer.cs

View workflow job for this annotation

GitHub Actions / Linux (v2.9)

Check warning on line 320 in src/NATS.Client.JetStream/NatsJSOrderedConsumer.cs

View workflow job for this annotation

GitHub Actions / Linux (v2.9)

Check warning on line 320 in src/NATS.Client.JetStream/NatsJSOrderedConsumer.cs

View workflow job for this annotation

GitHub Actions / Linux (v2.9)

Check warning on line 320 in src/NATS.Client.JetStream/NatsJSOrderedConsumer.cs

View workflow job for this annotation

GitHub Actions / Linux (v2.9)

Check warning on line 320 in src/NATS.Client.JetStream/NatsJSOrderedConsumer.cs

View workflow job for this annotation

GitHub Actions / Linux (v2.9)

Check warning on line 320 in src/NATS.Client.JetStream/NatsJSOrderedConsumer.cs

View workflow job for this annotation

GitHub Actions / Linux (v2.9)

Check warning on line 320 in src/NATS.Client.JetStream/NatsJSOrderedConsumer.cs

View workflow job for this annotation

GitHub Actions / Linux (latest)

Check warning on line 320 in src/NATS.Client.JetStream/NatsJSOrderedConsumer.cs

View workflow job for this annotation

GitHub Actions / Linux (latest)

Check warning on line 320 in src/NATS.Client.JetStream/NatsJSOrderedConsumer.cs

View workflow job for this annotation

GitHub Actions / Linux (latest)

Check warning on line 320 in src/NATS.Client.JetStream/NatsJSOrderedConsumer.cs

View workflow job for this annotation

GitHub Actions / Linux (latest)

Check warning on line 320 in src/NATS.Client.JetStream/NatsJSOrderedConsumer.cs

View workflow job for this annotation

GitHub Actions / Linux (latest)

Check warning on line 320 in src/NATS.Client.JetStream/NatsJSOrderedConsumer.cs

View workflow job for this annotation

GitHub Actions / Linux (latest)

Check warning on line 320 in src/NATS.Client.JetStream/NatsJSOrderedConsumer.cs

View workflow job for this annotation

GitHub Actions / Linux (latest)

Check warning on line 320 in src/NATS.Client.JetStream/NatsJSOrderedConsumer.cs

View workflow job for this annotation

GitHub Actions / Linux (latest)

Check warning on line 320 in src/NATS.Client.JetStream/NatsJSOrderedConsumer.cs

View workflow job for this annotation

GitHub Actions / Linux (latest)


if (i == _opts.MaxResetAttempts)
{
Expand Down

0 comments on commit a543e36

Please sign in to comment.