activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Joe Fernandez <joe.fernan...@ttmsolutions.com>
Subject Re: Cannot receive from Virtual Topic's consumer queue
Date Wed, 28 Oct 2009 14:48:38 GMT

Nope, that was my bad. Sorry for the confusion. Your code should work. I
tried something similar with ActiveMQ 5.3 and it worked fine for me. Here's
my code, which is using JNDI. 


            MessageListener listener = new MessageListener() {
             @Override
             public void onMessage(Message msg) {
                 if( msg == null)
                    return;
                 TextMessage txtMsg = (TextMessage) msg;
                 try {
                    System.out.println("Listener: message text = " +
                    txtMsg.getText());
                 } catch (Exception e) {
                 e.printStackTrace();
               }
             }
            };
            
            javax.naming.Context ctx = new InitialContext();            
            ConnectionFactory factory = (javax.jms.ConnectionFactory)
            ctx.lookup("localConnectionFactory");

            Connection conn = factory.createConnection();

            Topic myTopic = (Topic) ctx.lookup("BLAST");
            Queue myQueue = (javax.jms.Queue) ctx.lookup("Q.BLAST");
            
            Session topicSession = conn.createSession(false,
Session.AUTO_ACKNOWLEDGE);
            Session queueSession = conn.createSession(false,
Session.AUTO_ACKNOWLEDGE);

            MessageProducer topicSender =
topicSession.createProducer(myTopic);
            MessageConsumer queueConsumer =
queueSession.createConsumer(myQueue);

            queueConsumer.setMessageListener(listener);
            
            conn.start();
            
            TextMessage msg = topicSession.createTextMessage();
            msg.setText("Hello World");
            topicSender.send(msg);     

            // Give the listener some time to get the message
            Thread.sleep(1000);

            // close everything down
            topicSender.close();
            topicSession.close();
            queueSession.close();
            conn.close();            




Shyam Santhanam wrote:
> 
> 
> Joe Fernandez wrote:
>> 
>> If you activate your consumer after the messages have been published to
>> the topic, then the messages will not be forwarded on to the consumer's
>> queue.   
>> 
> 
> Sorry, but I thought I'm sending to the topic after setting up the
> consumer, just as you suggest.  What do you mean by "activate" the
> consumer? I assume this just means connecting to the queue and setting the
> message listener, or is there some other step required?
> 

-- 
View this message in context: http://www.nabble.com/Cannot-receive-from-Virtual-Topic%27s-consumer-queue-tp26093937p26096034.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.


Mime
View raw message