Send message to specific durable subscriber

[bcremers]

I've got a topic with 8 durable subscriptions. Is it possible to send a message to just one specific subscriber?

[jbertram]

If the subscribers are each using unique selectors then you could tailor a message for one specific subscriber.  I can't think of another way off the top of my head to do what you want.

[bcremers]

I'll try to explain the use case a bit further.

As said, the topic has 8 durable subscribers. On the topic, a variety of "event" messages are delivered. The subscribers already use selectors to filter out unwanted messages by event type.

This mechanism is working perfectly, but from time to time of course our business logic is faulty or data is corrupt and one or more of the subscribers (most often just one) can't process the message correctly, resulting in it being sent to the DLQ. In the message on the DLQ we can see the message properties _HQ_ORIG_ADDRESS (the topic) and _HQ_ORIG_QUEUE (the subscription). From this we can derive which of the subscribers failed in processing the message.

Now, after fixing the code, or cleaning up the data, we want to offer the message again to the topic, but only the failing subscriber should pick it up as we don't want the other subscribers to perform the same work twice.

What would be a viable strategy to achieve this?

I'll start investigating a more complex selector to see if i can get what I want from there. 

[jbertram]

Like I said before, the only way I can think of is using a selector.

Other than that you could re-architect your application to use queues so this scenario is easier to deal with but I suspect the work wouldn't be worth it.

[bcremers]

We implemented this by extending or message selectors on the messagedriven beans as Justin pointed out.

@ActivationConfigProperty(propertyName = "messageSelector",

                                        propertyValue = "... and (redeliveryProperty IS NULL OR redeliveryProperty = 'CLIENT_ID.SUBSCRIPTION_NAME)"),

In the redeliver process we then add a JMS property 'redeliverProperty' containing the value of _HQ_ORIG_QUEUE. This mechanism works like a charm.

[jbertram]

Nice work.  Thanks for posting back with your solution.