diff options
| author | Neil Alexander <neilalexander@users.noreply.github.com> | 2022-11-16 10:28:22 +0000 |
|---|---|---|
| committer | Neil Alexander <neilalexander@users.noreply.github.com> | 2022-11-16 10:28:22 +0000 |
| commit | a916b041b16e3369c4784b648343c241f4fa6494 (patch) | |
| tree | a6a9fc211d7fcae9b3a0a1572d00604e01a52a34 /setup | |
| parent | 1e714bc3b641c09d958e78060ff1a7b90c79b500 (diff) | |
Detect consumer being deleted in `JetStreamConsumer`
Diffstat (limited to 'setup')
| -rw-r--r-- | setup/jetstream/helpers.go | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/setup/jetstream/helpers.go b/setup/jetstream/helpers.go index 1ec860b0..c1ce9583 100644 --- a/setup/jetstream/helpers.go +++ b/setup/jetstream/helpers.go @@ -2,6 +2,7 @@ package jetstream import ( "context" + "errors" "fmt" "github.com/getsentry/sentry-go" @@ -72,6 +73,9 @@ func JetStreamConsumer( // just timed out and we should try again. continue } + } else if errors.Is(err, nats.ErrConsumerDeleted) { + // The consumer was deleted so stop. + return } else { // Something else went wrong, so we'll panic. sentry.CaptureException(err) |