From 64d6fe605929b5a822a73f11f5d189f095db18af Mon Sep 17 00:00:00 2001 From: Quaternions Date: Wed, 11 Dec 2024 21:07:39 -0800 Subject: [PATCH] validation: consumers are not durable --- validation/src/publish_fix.rs | 1 - validation/src/publish_new.rs | 1 - validation/src/validator.rs | 1 - 3 files changed, 3 deletions(-) diff --git a/validation/src/publish_fix.rs b/validation/src/publish_fix.rs index d38a5ae..c119942 100644 --- a/validation/src/publish_fix.rs +++ b/validation/src/publish_fix.rs @@ -33,7 +33,6 @@ impl Publisher{ Ok(Self{ messages:nats.get_stream("submissions_publish_new").await.map_err(NatsStartupError::GetStream)? .create_consumer_strict(async_nats::jetstream::consumer::pull::Config{ - durable_name:Some("pull".to_owned()), ..Default::default() }).await.map_err(NatsStartupError::ConsumerCreateStrict)? .messages().await.map_err(NatsStartupError::Stream)?, diff --git a/validation/src/publish_new.rs b/validation/src/publish_new.rs index 07f6456..1a81c62 100644 --- a/validation/src/publish_new.rs +++ b/validation/src/publish_new.rs @@ -37,7 +37,6 @@ impl Publisher{ Ok(Self{ messages:nats.get_stream("submissions_publish_new").await.map_err(NatsStartupError::GetStream)? .create_consumer_strict(async_nats::jetstream::consumer::pull::Config{ - durable_name:Some("pull".to_owned()), ..Default::default() }).await.map_err(NatsStartupError::ConsumerCreateStrict)? .messages().await.map_err(NatsStartupError::Stream)?, diff --git a/validation/src/validator.rs b/validation/src/validator.rs index c171a3c..07c7116 100644 --- a/validation/src/validator.rs +++ b/validation/src/validator.rs @@ -51,7 +51,6 @@ impl Validator{ Ok(Self{ messages:nats.get_stream("submissions_validate").await.map_err(NatsStartupError::GetStream)? .create_consumer_strict(async_nats::jetstream::consumer::pull::Config{ - durable_name:Some("pull".to_owned()), ..Default::default() }).await.map_err(NatsStartupError::ConsumerCreateStrict)? .messages().await.map_err(NatsStartupError::Stream)?,