Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Concurrent consumers #11

Open
alexmipego opened this issue Jun 2, 2017 · 0 comments
Open

Concurrent consumers #11

alexmipego opened this issue Jun 2, 2017 · 0 comments

Comments

@alexmipego
Copy link

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

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

1 participant