My AsynchronousConsumer Won't Listen!

[George Berish]

Hi,

I have a WebStart downloaded Java SWING client that I want to have listen continuously to a server side Queue.

I am using a JBoss local server that has a Queue configured and bound to a JNDI name of "queue/goAdminOut".

I know that the queue exists and has a message waiting, because I can see it on the JBoss JMX web-console (see console screen print below).

Here is the relevant code.

1. Two classes that mimic my client.

TestConsumerView
-- A JFrame that stays alive till it is closed.

TestConsumer
-- An object that is instantiated as a field in TestConsumerView
-- It establishes the connection, session and message consumer with a selector. It also sets a Listener on the consumer.

2. The command screen print when I run TestConsumerView

3. A screen print from the JBoss JMX web console confirming that the message is in the queue.

TestConsumerView Code

import javax.swing.JFrame;
 
class TestConsumerView extends JFrame {
  // members
  private static final long    serialVersionUID = 1;
  private TestConsumer consumer;
  // main ()
  public static void main(String args[]) {
    System.out.println ("** BEGIN: TestConsumerView.main ()");
    System.out.println ("** instantiate TestConsumerView");
    new TestConsumerView();
    System.out.println ("\n** TestConsumerView instantiated");
    System.out.println ("** END:   TestConsumerView.main ()");
  }
  // constructor
  private TestConsumerView () {
    super ();
    System.out.println ("\n**** BEGIN: TestConsumerView.constructor");
    consumer = new TestConsumer ();
    this.setDefaultCloseOperation(EXIT_ON_CLOSE);
    this.setVisible (true);
    System.out.println ("\n**** END:   TestConsumerView.constructor");
  }
}

TestConsumer Code

import javax.swing.JFrame;
 
class TestConsumerView extends JFrame {
  // members
  private static final long    serialVersionUID = 1;
  private TestConsumer consumer;
  // main ()
  public static void main(String args[]) {
    System.out.println ("** BEGIN: TestConsumerView.main ()");
    System.out.println ("** instantiate TestConsumerView");
    new TestConsumerView();
    System.out.println ("\n** TestConsumerView instantiated");
    System.out.println ("** END:   TestConsumerView.main ()");
  }
  // constructor
  private TestConsumerView () {
    super ();
    System.out.println ("\n**** BEGIN: TestConsumerView.constructor");
    consumer = new TestConsumer ();
    this.setDefaultCloseOperation(EXIT_ON_CLOSE);
    this.setVisible (true);
    System.out.println ("\n**** END:   TestConsumerView.constructor");
  }
}

Screen Output

** BEGIN: TestConsumerView.main ()
** instantiate TestConsumerView
 
**** BEGIN: TestConsumerView.constructor
 
****** BEGIN: TestConsumer.constructor
****** calling connect ()
 
******** BEGIN: TestConsumer.connect ()
******** InitialContext Returned
 
 
******** Connection instantiated
******** Session instantiated
******** MessageConsumer instantiated with the selector phrase = Selector='ABCD'
******** add a MessageListener to consumer
 
********** TCListener.constructor called
 
******** MessageListener added
******** Connection started
******** END:   TestConsumer.connect ()
 
****** call to connnect () completed
****** END:   TestConsumer.constructor
 
**** END:   TestConsumerView.constructor
 
** TestConsumerView instantiated
** END:   TestConsumerView.main ()

WEB CONSOLE OUTPUT

[SpyTextMessage {
Header { 
   jmsDestination  : QUEUE.goAdminOut
   jmsDeliveryMode : 2
   jmsExpiration   : 0
   jmsPriority     : 4
   jmsMessageID    : ID:9-11218101942431
   jmsTimeStamp    : 1121810194243
   jmsCorrelationID: null
   jmsReplyTo      : null
   jmsType         : null
   jmsRedelivered  : false
   jmsProperties   : {Selector='ABCD'}
   jmsPropReadWrite: false
   msgReadOnly     : true
   producerClientId: ID:9
}
Body {
   text            :The DialogPack was received
}
}]

[George Berish]

SORRY! I mistakenly put two copies of TestConsumerView above and left out TestConsumer.

Here is the missing code:

import java.util.Hashtable;
import javax.jms.JMSException;
import javax.jms.ConnectionFactory;
import javax.jms.Connection;
import javax.jms.Message;
import javax.jms.MessageConsumer;
import javax.jms.MessageListener;
import javax.jms.Destination;
import javax.jms.Session;
import javax.naming.Context;
import javax.naming.InitialContext;
import javax.naming.NamingException;
 
public class TestConsumer {
 
  // constructor
  public TestConsumer () {
    super ();
    System.out.println ("\n****** BEGIN: TestConsumer.constructor");
    System.out.println ("****** calling connect ()");
    connect ();
    System.out.println ("\n****** call to connnect () completed");
    System.out.println ("****** END:   TestConsumer.constructor");
  }
 
  // members
  private final String selector = "Selector='ABCD'";
  private Session session;
 
  // members - inner class
  private class TCListener implements MessageListener {
 
    TCListener () {
      super ();
      System.out.println ("\n********** TCListener.constructor called\n");
    }
    public void onMessage (Message msg) {
      try {
        System.out.println ("    ** BEGIN: TestConsumer.Listen.onMessage ()");
        System.out.println ("       Msg property 'Selector'=" + "\"" + msg.getStringProperty ("Selector") + "\"");
      } catch (JMSException e) {
        System.out.println ("       JMSException");
      }
      System.out.println ("    ** END:   TestConsumer.Listen.onMessage ()");
    }
  }
 
  // methods
  private void connect () {
    System.out.println ("\n******** BEGIN: TestConsumer.connect ()");
    try {
       Hashtable<String, String> env =
         new Hashtable<String, String> ();
       env.put(Context.INITIAL_CONTEXT_FACTORY,
              "org.jboss.naming.HttpNamingContextFactory");
       env.put(Context.PROVIDER_URL,
              "http://localhost:8080/invoker/JNDIFactory");
       env.put(Context.URL_PKG_PREFIXES,
               "org.jboss.naming :-o	 rg.jnp.interfaces");
      Context jndiContext = new InitialContext(env);
      System.out.println ("******** InitialContext Returned\n");
      ConnectionFactory factory = (ConnectionFactory)
          jndiContext.lookup("HTTPConnectionFactory");
      Connection connection = factory.createConnection();
      System.out.println ("\n******** Connection instantiated");
      session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
      System.out.println ("******** Session instantiated");
      Destination destination = (Destination) jndiContext.lookup("queue/goAdminOut");
      MessageConsumer consumer = session.createConsumer(destination, selector);
      System.out.println ("******** MessageConsumer instantiated with the selector phrase = " + selector);
      System.out.println ("******** add a MessageListener to consumer");
      consumer.setMessageListener (new TCListener ());
      System.out.println ("******** MessageListener added");
      connection.start ();
      System.out.println ("******** Connection started");
 
    } catch (NamingException e) {
      System.out.println ("******** Naming Exception");
    } catch (JMSException e) {
      System.out.println ("******** JMS Execption");
    }
    System.out.println ("******** END:   TestConsumer.connect ()");
  }
}

[Jaikiran Pai]

Hi,
Are your send and receive operations in the same transactions? If yes, then the send and receive operations need to be separated out into 2 different transactions.

If they are already in different transaction, then try sending/receiving the message without the message selector, so that you can narrow down on the problem.