Implement support for MessageListener interface
-----------------------------------------------
Key: QPID-103
URL: http://issues.apache.org/jira/browse/QPID-103
Project: Qpid
Issue Type: Bug
Components: Java Client
Reporter: Marnie McCormack
Fix For: M2
See AMQSession.get/setMessageListener methods which currently throw
UnsupportedOperationException.
See javadoc/JMS spec.
The snippet below talks a little about the MessageListener interface (from JMS
specification):
9.3.1 Receiving Messages Asynchronously
In order to receive message asynchronously as they are delivered to the message
consumer, the client program needs to create a message listener that implements
the MessageListener interface. An implementation of the MessageListener
interface, called StockListener.java, might look like this:
import javax.jms.*;
public class StockListener implements MessageListener
{
public void onMessage(Message message) {
/* Unpack and handle the messages received */
...
}
}
The client program registers the MessageListener object with the
MessageConsumer object in the following way:
StockListener myListener = new StockListener();
/* Receiver is MessageConsumer object */
receiver.setMessageListener(myListener);
The Connection must be started for the message delivery to begin. The
MessageListener is asynchronously notified whenever a message has been
published to the Queue. This is done via the onMessage method in the
MessageListener interface. It is up to the client to process the message there.
JMS Example Code—April 12, 2002 105
9
public void onMessage(Message message)
{
String newStockData;
/* Unpack and handle the messages received */
newStockData = message.getText();
if(...)
{
/* Logic related to the data */
}
}
--
This message is automatically generated by JIRA.
-
If you think it was sent incorrectly contact one of the administrators:
http://issues.apache.org/jira/secure/Administrators.jspa
-
For more information on JIRA, see: http://www.atlassian.com/software/jira
