Mailing-List: contact users-help@activemq.apache.org; run by ezmlm
Precedence: bulk
Reply-To: users@activemq.apache.org
Received-SPF: pass (athena.apache.org: domain of lists@nabble.com designates
 216.139.236.158 as permitted sender)
Message-ID: <14546105.post@talk.nabble.com>
Date: Sun, 30 Dec 2007 02:44:08 -0800 (PST)
From: pcdinh <pcdinh@gmail.com>
To: users@activemq.apache.org
Subject: Can not receive MapMessage in ActiveMQ 5.0
MIME-Version: 1.0
Content-Type: text/plain; charset=us-ascii
Content-Transfer-Encoding: 7bit


ActiveMQ 5.0's QueueReceiver seems to have problems with MapMessage. It
always returns bull object when the timeout occurs or waits in a countless
time.

Receiver code

QueueConnectionFactory connFactory = new
ActiveMQConnectionFactory(ActiveMQConnection.DEFAULT_BROKER_URL);
QueueConnection conn = connFactory.createQueueConnection();

// This session is not transacted, and it uses automatic objectMessage
acknowledgement
QueueSession session = conn.createQueueSession(false,
QueueSession.AUTO_ACKNOWLEDGE);

// create destination
queue = session.createQueue("TestQueue");
QueueReceiver receiver = session.createReceiver(queue);

MapMessage message = (MapMessage) receiver.receive(8000);

 if (message instanceof MapMessage) {
            int age = message.getInt("age");
            float weight = message.getFloat("weight");
            String name = message.getString("name");
            String height = message.getObject("height").toString();
............
} else {
            System.out.println("Timeout!!!!!");
}

Sender code 

QueueConnectionFactory connFactory = new
ActiveMQConnectionFactory(ActiveMQConnection.DEFAULT_BROKER_URL);
QueueConnection conn = connFactory.createQueueConnection();
QueueSession session = conn.createQueueSession(false,
QueueSession.AUTO_ACKNOWLEDGE);

queue = session.createQueue("TestQueue");
QueueSender sender = session.createSender(queue);

MapMessage mapMessage = session.createMapMessage();
mapMessage.setInt("age", 88);
mapMessage.setFloat("weight", 234);
mapMessage.setString("name", "Smith");
mapMessage.setObject("height", new Double(150.32));
       
System.out.println("Sending the object message: " + mapMessage.toString());
sender.send(mapMessage);

Sender run smoothly because I checked its message in queue with ActiveMQ's
web console and see the message there. But when I run the receiver to get
the message, it does not work. ActiveMQ works fine with TextMessage.

I dont know if there is anything wrong with ActiveMQ 5. I would be grateful
if someone could point me the right direction

-- 
View this message in context: http://www.nabble.com/Can-not-receive-MapMessage-in-ActiveMQ-5.0-tp14546105s2354p14546105.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.