Continuing the discussion from Supporting Multiple SQS Queues for the same message type across different instances:
I have the same requirement of supporting queues with the same message type for different services as discussed in the above question.
The answer with regards to queueprefix worked perfectly for SQS, I’m trying to work out how to get this working for Redis.
If I set the queueprefix to “instance-service” with redis I see a pubsub channel created called "instance-service-mq:topic:in
If I publish a message using this approach: mqClient.Publish(ob1) I receive the object and can process it.
However, if I need the object to go to service2, I have tried the following:
mqClient.Publish("instance-service2-mq:topic", clientMsg); mqClient.Publish("instance-service2-mq:", clientMsg); mqClient.Publish("instance-service2-mq", clientMsg); mqClient.Publish("instance-service2", clientMsg);
none of which appear to reach the destination.
What am I missing here, and what is the correct way to publish / consume to a queue in the format “instance-service-messagename”