How to use wildcards with MDB's (on AS 7.1.3 and later)

[marco.rietveld]

What I would like to do is create an message driven bean (MDB) that listens to multiple queues: in order to do this, I thought I'd use the wildcard syntax that hornetq provides.

In essence, I'm creating an application which users will configure by adding their own "domains". Users can then configure the AS to add their own domain queues (like JBPM.TASK.DOMAIN.MINE, etc.) and I need a way to have my MDB pick up messages from whichever queues they might create. However, they might also decide that separate queues aren't necessary, and want to only use the (basic) JBPM.TASK queue.

The top of my MDB:

@MessageDriven(activationConfig = {

        @ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Queue"),

        @ActivationConfigProperty(propertyName = "destination", propertyValue = "java:/queue/JBPM.TASK.#") },

        name = "TaskMDB")

public class TaskMessageBean implements MessageListener {

Note the '#' at the end of the queue name.

See the attached file (used for deploying queues to AS 7.x) for an example of the queues that I'd use it with: in short, I'd like the MDB to receive messages from JBPM.TASK and JBPM.TASK.DOMAIN.TEST (among others).

When I test with jboss 7.1.1 (or 7.1.3), using the standalone-full profile, I see the following log. This makes me think that the wildcard is being literally interpreted.

21:00:29,388 INFO  [org.jboss.as.server] (management-handler-thread - 4) JBAS018559: Deployed "test-jms.war"

21:00:31,107 INFO  [org.hornetq.ra.inflow.HornetQActivation] (default-threads - 2) Attempting to reconnect org.hornetq.ra.inflow.HornetQActivationSpec(ra=org.hornetq.ra.HornetQResourceAdapter@609fb8b6 destination=java:/topic/JBPM.TASK.# destinationType=javax.jms.Queue ack=Auto-acknowledge durable=false clientID=null user=null maxSession=15)

21:00:31,107 INFO  [org.hornetq.ra.inflow.HornetQActivation] (default-threads - 1) Attempting to reconnect org.hornetq.ra.inflow.HornetQActivationSpec(ra=org.hornetq.ra.HornetQResourceAdapter@609fb8b6 destination=java:/queue/JBPM.SESSION.# destinationType=javax.jms.Queue ack=Auto-acknowledge durable=false clientID=null user=null maxSession=15)

21:00:31,122 INFO  [org.hornetq.ra.inflow.HornetQActivation] (default-threads - 2) awaiting topic/queue creation java:/topic/JBPM.TASK.#

21:00:31,124 INFO  [org.hornetq.ra.inflow.HornetQActivation] (default-threads - 1) awaiting topic/queue creation java:/queue/JBPM.SESSION.#

(The "java:/queue/JBPM.SESSION.#" is because of a second similar MDB that's setup to listen to queues whose names begin with JBPM.SESSION)

Thanks in advance!

[ataylor]

when using wildcards with JMS queues you will need to define them, ive added an example to my github repo, look at https://github.com/andytaylor/hornetq/tree/wildcard-queue/examples/jms/queue-wildcard

[marco.rietveld]

BOOYAH!

Andy, thank you! The tip, of course, is to do the wildconfiguration at the "queue" level instead of the MDB level. Queues are of course wildcarded, not MDB's -- hornetQ doesn't do anything with MDB's, it's on the app server to connect the MDB implementations to the queues that hornetq supplies.

By the way, I have a simple self-contained arquillian (AS 7) based test that illustrates this -- do you have any suggestions for a github repo that I could add it to?

[ataylor]

we have some javaee examples at https://github.com/hornetq/hornetq/tree/master/examples/javaee you could add it there.