Open vpaskovic opened 5 years ago
@vpaskovic The queue name is 'shard.videos' right? But you got 'videos' and 'shard.videos' mixed.
Just reopen this issue if it's still not working.
Hi @stevenklar when I put 'shard.videos' in \Amqp::consume('shard.videos', there is Error, as it does not accept queue name with dots. So there is still a problem.
Right now I'm not sure if we support this. Must be tested.
/Reopen
I am having issue using sharding. I want to achieve having one queue that has 6 consumers but with sharding to achieve that each consumer is on one CPU.
After enabling rabbitmq-plugins enable rabbitmq_sharding
and setting up config
making policy
rabbitmqctl set_policy videos-shard "^shard.videos$" "{""shards-per-node"": 1,""routing-key"": ""fc_analyze""}"
with
\Amqp::publish('fc_analyze', 'this is message');
I get it to wright queue but can not get consumer in that queue using this code
Please help and advice. Thank you