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/[EMAIL PROTECTED]
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)
