StrafesNET/maps-service
7
Fork 0
Code Issues 7 Pull Requests Packages Projects Releases Wiki Activity

validation: consumers are not durable

Browse Source
This commit is contained in:
Quaternions 2024-12-11 21:07:39 -08:00
parent 7f1054d509
commit 64d6fe6059
3 changed files with 0 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
validation/src/publish_fix.rs
View File

@ -33,7 +33,6 @@ impl Publisher{
Ok(Self{ Ok(Self{
messages:nats.get_stream("submissions_publish_new").await.map_err(NatsStartupError::GetStream)? messages:nats.get_stream("submissions_publish_new").await.map_err(NatsStartupError::GetStream)?
.create_consumer_strict(async_nats::jetstream::consumer::pull::Config{ .create_consumer_strict(async_nats::jetstream::consumer::pull::Config{
durable_name:Some("pull".to_owned()),
..Default::default() ..Default::default()
}).await.map_err(NatsStartupError::ConsumerCreateStrict)? }).await.map_err(NatsStartupError::ConsumerCreateStrict)?
.messages().await.map_err(NatsStartupError::Stream)?, .messages().await.map_err(NatsStartupError::Stream)?,

1
validation/src/publish_new.rs
View File

@ -37,7 +37,6 @@ impl Publisher{
Ok(Self{ Ok(Self{
messages:nats.get_stream("submissions_publish_new").await.map_err(NatsStartupError::GetStream)? messages:nats.get_stream("submissions_publish_new").await.map_err(NatsStartupError::GetStream)?
.create_consumer_strict(async_nats::jetstream::consumer::pull::Config{ .create_consumer_strict(async_nats::jetstream::consumer::pull::Config{
durable_name:Some("pull".to_owned()),
..Default::default() ..Default::default()
}).await.map_err(NatsStartupError::ConsumerCreateStrict)? }).await.map_err(NatsStartupError::ConsumerCreateStrict)?
.messages().await.map_err(NatsStartupError::Stream)?, .messages().await.map_err(NatsStartupError::Stream)?,

1
validation/src/validator.rs
View File

@ -51,7 +51,6 @@ impl Validator{
Ok(Self{ Ok(Self{
messages:nats.get_stream("submissions_validate").await.map_err(NatsStartupError::GetStream)? messages:nats.get_stream("submissions_validate").await.map_err(NatsStartupError::GetStream)?
.create_consumer_strict(async_nats::jetstream::consumer::pull::Config{ .create_consumer_strict(async_nats::jetstream::consumer::pull::Config{
durable_name:Some("pull".to_owned()),
..Default::default() ..Default::default()
}).await.map_err(NatsStartupError::ConsumerCreateStrict)? }).await.map_err(NatsStartupError::ConsumerCreateStrict)?
.messages().await.map_err(NatsStartupError::Stream)?, .messages().await.map_err(NatsStartupError::Stream)?,