🚧 bug(wip): nats is weird

Prismadic · Jan 28, 2024 · 4bf231c · 4bf231c
1 parent 1d51d86
commit 4bf231c
Showing 1 changed file with 3 additions and 5 deletions.
diff --git a/magnet/ic/field.py b/magnet/ic/field.py
@@ -196,10 +196,10 @@ async def on(self, category: str = 'no_category', stream: str = 'documents', ses
         self.stream = stream
         self.session = session
         self.config = ConsumerConfig(
-                    name=self.session
+                    name=f'{self.session}_1'
                     , deliver_group=self.session
-                    , durable_name=self.session
-                    , ack_wait=20
+                    , durable_name=f'{self.session}_1'
+                    , max_ack_pending=group_size
                 )
         _f('wait',f'connecting to {self.server}')
         try:
@@ -209,8 +209,6 @@ async def on(self, category: str = 'no_category', stream: str = 'documents', ses
                 await self.js.add_consumer(
                         stream=self.stream
                         , config=self.config
-                        , deliver_subject=self.session
-                        , max_ack_pending=group_size
                 )
             except:
                 _f('warn', f'consumer {self.session} exists, skipping create')