[EJB3]MessageDriven bean never catch message

[mick keu]

Hi!
I hope someone could help me fixing my pb.

I've created a session bean that send a message in a queue (TaskMessagesQueue):

@Stateless
public class SenderAgentBean
{
  /** ConnectionFactory */
  @Resource(mappedName = "ConnectionFactory")
  private ConnectionFactory _connectionFactory;
 
  /** ConnectionFactory */
  @Resource(mappedName = "queue/TaskMessagesQueue")
  private Destination _destination;
 
 /**
   * send a JMS Message
   */
  public void sendMessage()
  {
    Connection connection = null;
    Session session = null;
 
    try
    {
      connection = _connectionFactory.createConnection();
      session = connection.createSession(true, Session.AUTO_ACKNOWLEDGE);
      MessageProducer producer = session.createProducer(_destination);
 
 
      MapMessage msg = session.createMapMessage();
 
      msg.setStringProperty("Action", "Backup");
 
      producer.send(msg);
 
    }
    catch (JMSException e)
    {
      closeJMSConnection(connection, session);
    }
    closeJMSConnection(connection, session);
 
  }
 

I've got a MessageDriven Bean that should catch the message (i use a "message selector"):

@MessageDriven(activationConfig = {
  @ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Queue"),
  @ActivationConfigProperty(propertyName = "destination", propertyValue = "queue/TaskMessagesQueue"),
  @ActivationConfigProperty(propertyName = "messagingType", propertyValue = "javax.jms.MessageListener"),
  @ActivationConfigProperty(propertyName = "messageSelector", propertyValue = "Action = 'Backup'"),
  @ActivationConfigProperty(propertyName = "acknowledgeMode", propertyValue = "Auto-acknowledge") })
public class BackupActivator implements MessageListener
{
 
  public void onMessage(Message msg)
  {
    System.out.println("LE MESSAGE EST PASSE");
  }
}
 

But it's not working... the message is never catch by the messageDriven bean...

the queue have bean created in Jboss...

<?xml version="1.0" encoding="UTF-8"?>

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

I've certainly miss something, but where...
If someone can help me...
Many thanks

ps : I hope I did not make too many mistakes, cause i don't really speak english.

[Jaikiran Pai]

Mick,

Welcome to JavaRanch

i use a "message selector"

I would suggest that you first get the application working without the message selector. If that works, then we know exactly where to concentrate to fix the problem. Message selectors follow a specific syntax (i don't have the document which is usually refer to, right now).

If it still does not work without the message selector, then post the console log from JBoss. By the way, which version of JBoss and Java do you use?

[mick keu]

hi Jaikiran !
Thanks for reply.

I tried to remove the message selector, without success...
Finally, i managed to get it working, changing :

 /** ConnectionFactory */
  @Resource(mappedName = "ConnectionFactory")
  private ConnectionFactory _connectionFactory;

by

  /** ConnectionFactory */
  @Resource(mappedName = "QueueConnectionFactory")
  private ConnectionFactory _connectionFactory;

So my problem seems to be solved. Perhaps it will be usefull for someone else.

Thanks for help.

PS : For information, i used JBOSS 4.2.2 GA and Java JDK 1.5.012.