mdb doesn't catch messages in point2point

[Esteban Sanchez]

Hello,

I'm trying to send messages to a mdb from a JSF backing-bean in JBoss 4.2.3. I'm including below all the code I've added to my app to get this running. The problem is, the method onMessage in the mdb MDBInitImport never gets called.

Here is the code I have so far:

In the backing-bean

   ...............................
QueueConnection connection = null;
QueueSession session = null;
try {
  InitialContext ctx = new InitialContext();
  Destination _destination = (Destination)
  ctx.lookup("queue/QueueImport");
  QueueConnectionFactory _connectionFactory = (QueueConnectionFactory)  ctx.lookup("QueueConnectionFactory");
  connection = _connectionFactory.createQueueConnection();
  session = connection.createQueueSession(false,
QueueSession.AUTO_ACKNOWLEDGE);
  MessageProducer producer = session.createProducer(_destination);
 
  // prepare msg
  ObjectMessage msg = session.createObjectMessage();
  msg.setObject(obj);
  long sent = System.currentTimeMillis(); 
  msg.setLongProperty("sent", sent);
  producer.send(msg);
  connection.close();
  session.close();
} catch (JMSException jmse) {
 
     ................

The mdb

   ...............................
package es.sd.soporte.ejb;
 
import javax.ejb.ActivationConfigProperty;
import javax.ejb.MessageDriven;
import javax.jms.Message;
import javax.jms.MessageListener;
 
@MessageDriven(mappedName="mdb/MDBInitImport" ,activationConfig = {
@ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Queue"),
@ActivationConfigProperty(propertyName = "destination", propertyValue = "queue/QueueImport"),
@ActivationConfigProperty(propertyName = "messagingType", propertyValue = "javax.jms.MessageListener"),
@ActivationConfigProperty(propertyName = "acknowledgeMode", propertyValue = "Auto-acknowledge") })
 
public class MDBInitImport implements MessageListener {
 
  public MDBInitImport() {}
 
  public void onMessage(Message msg) {
    System.out.println("Received, this=" + hashCode());
  }
}
     ................

The jbossmp-destinations-service.xml

     ................
<mbean code="org.jboss.mq.server.jmx.Queue" name="jboss.mq.destination:service=Queue, 
name=QueueImport">
    <depends optional-attribute-name="DestinationManager">
      jboss.mq:service=DestinationManager
    </depends>
</mbean>
  
</server>
     ................

Thank you very much for your help

[Peter Johnson]

I tried your code and it works for me. I used JBossAS 4.2.2 with JDK 1.5.0_16.

Are you getting any stack traces in the console log?

[Esteban Sanchez]

Hi,

thanks for your answer. Nothing in the console.

I'm using JBoss 4.2.3 with default configuration and Richfaces 3.2.1.

Could it be the cause, a wrong server configuration?. I didn't change anything from config files so JBoss has all the testing queues etc. Should I change to "minimal" JBoss configuration?.

Cheers

[Martijn Verburg]

Have you tried looking on the JMS console to see if the Queue is correctly registered and that messages are on it?

[Esteban Sanchez]

No messages in the queue according to the console. But the queue is there. Am I missing a config param or something in some config file?

Thanks

[Martijn Verburg]

Try posting a message to that queue and see if it stays there (it should). If the message then disappears then chances are your MDB (or another client to the Queue) is taking that message.