qpid-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Tejeswar Das (JIRA)" <qpid-...@incubator.apache.org>
Subject [jira] Assigned: (QPID-103) Implement support for MessageListener interface
Date Thu, 16 Nov 2006 15:05:37 GMT
     [ http://issues.apache.org/jira/browse/QPID-103?page=all ]

Tejeswar Das reassigned QPID-103:
---------------------------------

    Assignee: Tejeswar Das

> 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
>         Assigned To: Tejeswar Das
>             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

        

Mime
View raw message