[
https://issues.apache.org/jira/browse/QPID-103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel#action_12463343
]
Marnie McCormack commented on QPID-103:
---------------------------------------
I believe that this defect has been addressed as part of the drive for JMS
Compliance. Tejeswar - are you working on this ? I'd recommend a look at the
current trunk if so. If not, please unassign it ? Thanks.
> Implement support for MessageListener interface
> -----------------------------------------------
>
> Key: QPID-103
> URL: https://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:
https://issues.apache.org/jira/secure/Administrators.jspa
-
For more information on JIRA, see: http://www.atlassian.com/software/jira
