You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by rh...@apache.org on 2008/08/15 10:42:16 UTC

svn commit: r686175 - in /incubator/qpid/branches/qpid.0-10/java: client/src/main/java/org/apache/qpid/client/BasicMessageConsumer.java systests/src/main/java/org/apache/qpid/client/MessageListenerTest.java

Author: rhs
Date: Fri Aug 15 01:42:15 2008
New Revision: 686175

URL: http://svn.apache.org/viewvc?rev=686175&view=rev
Log:
updated qpid.0-10/java to match trunk/qpid/java@686172

Modified:
    incubator/qpid/branches/qpid.0-10/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer.java
    incubator/qpid/branches/qpid.0-10/java/systests/src/main/java/org/apache/qpid/client/MessageListenerTest.java

Modified: incubator/qpid/branches/qpid.0-10/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer.java
URL: http://svn.apache.org/viewvc/incubator/qpid/branches/qpid.0-10/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer.java?rev=686175&r1=686174&r2=686175&view=diff
==============================================================================
--- incubator/qpid/branches/qpid.0-10/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer.java (original)
+++ incubator/qpid/branches/qpid.0-10/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer.java Fri Aug 15 01:42:15 2008
@@ -280,7 +280,7 @@
                     Object o = _synchronousQueue.poll();
                     while (o != null)
                     {
-                        messageListener.onMessage((Message) o);
+                        notifyMessage((AbstractJMSMessage) o);
                         o = _synchronousQueue.poll();
                     }
                 }

Modified: incubator/qpid/branches/qpid.0-10/java/systests/src/main/java/org/apache/qpid/client/MessageListenerTest.java
URL: http://svn.apache.org/viewvc/incubator/qpid/branches/qpid.0-10/java/systests/src/main/java/org/apache/qpid/client/MessageListenerTest.java?rev=686175&r1=686174&r2=686175&view=diff
==============================================================================
--- incubator/qpid/branches/qpid.0-10/java/systests/src/main/java/org/apache/qpid/client/MessageListenerTest.java (original)
+++ incubator/qpid/branches/qpid.0-10/java/systests/src/main/java/org/apache/qpid/client/MessageListenerTest.java Fri Aug 15 01:42:15 2008
@@ -152,6 +152,16 @@
         // Should have recieved all async messages
         assertEquals(MSG_COUNT, receivedCount);
 
+        _clientConnection.close();
+
+        Connection conn = getConnection("guest", "guest");
+        Session clientSession = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);
+        Queue queue = clientSession.createQueue("message-listener-test-queue");
+        MessageConsumer cons = clientSession.createConsumer(queue);
+        conn.start();
+
+        // check that the messages were actually dequeued
+        assertTrue(cons.receive(2000) == null);
     }
 
     public void onMessage(Message message)