I've manager to setup an environment with docker, rabbitmq and pipecat. Using the normal "seq 1 100 | ..." procedure described in the project's page I've managed to publish and consume messages. However, if I stop all consumers, publish some messages and then start 2 consumers only the first will get the messages. Only messages published after the consumers are connected seem to be correctly balanced between consumers.
Am I missing some concept or configuration?
Publisher
seq 1 100 | pipecat publish alex
Consumers
pipecat consume --autoack alex | xargs -I % sh -c '{ echo %; sleep 1; }'
Disclaimer: I've never used RabbitMQ before
I've manager to setup an environment with docker, rabbitmq and pipecat. Using the normal "seq 1 100 | ..." procedure described in the project's page I've managed to publish and consume messages. However, if I stop all consumers, publish some messages and then start 2 consumers only the first will get the messages. Only messages published after the consumers are connected seem to be correctly balanced between consumers.
Am I missing some concept or configuration?
Publisher
seq 1 100 | pipecat publish alex
Consumers
pipecat consume --autoack alex | xargs -I % sh -c '{ echo %; sleep 1; }'
Disclaimer: I've never used RabbitMQ before