At the moment messages are picked up on a simple NATS topic. When the next message arrives, all the messages up to that point are read in. This means that the first plan activity gets run n times for each new plan+activity added.
We need to use jetstream queues rather than topics, it seems. Creating ticket as this was not a 5-minute job.
At the moment messages are picked up on a simple NATS topic. When the next message arrives, all the messages up to that point are read in. This means that the first plan activity gets run n times for each new plan+activity added.
We need to use jetstream queues rather than topics, it seems. Creating ticket as this was not a 5-minute job.