From f5a1cf995f4956ec2dd83a60715b31ad065f7751 Mon Sep 17 00:00:00 2001 From: Gordon Sim Date: Fri, 31 Aug 2007 16:45:20 +0000 Subject: Pass QueuedMessage to queues consumers. This records the position of that message in the queue which is need to handle rlease and acquire. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@571518 13f79535-47bb-0310-9956-ffa450edef68 --- cpp/src/tests/BrokerChannelTest.cpp | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) (limited to 'cpp/src/tests/BrokerChannelTest.cpp') diff --git a/cpp/src/tests/BrokerChannelTest.cpp b/cpp/src/tests/BrokerChannelTest.cpp index 1e5a30f157..0787405eb7 100644 --- a/cpp/src/tests/BrokerChannelTest.cpp +++ b/cpp/src/tests/BrokerChannelTest.cpp @@ -256,13 +256,13 @@ class BrokerChannelTest : public CppUnit::TestCase queue->deliver(msg3); sleep(2); - Message::shared_ptr next = queue->dequeue(); + Message::shared_ptr next = queue->dequeue().payload; CPPUNIT_ASSERT_EQUAL(msg1, next); CPPUNIT_ASSERT_EQUAL((uint32_t) data1.size(), next->encodedContentSize()); - next = queue->dequeue(); + next = queue->dequeue().payload; CPPUNIT_ASSERT_EQUAL(msg2, next); CPPUNIT_ASSERT_EQUAL((uint32_t) data2.size(), next->encodedContentSize()); - next = queue->dequeue(); + next = queue->dequeue().payload; CPPUNIT_ASSERT_EQUAL(msg3, next); CPPUNIT_ASSERT_EQUAL((uint32_t) 0, next->encodedContentSize()); @@ -295,11 +295,11 @@ class BrokerChannelTest : public CppUnit::TestCase queue3->deliver(msg1); sleep(2); - Message::shared_ptr next = queue1->dequeue(); + Message::shared_ptr next = queue1->dequeue().payload; CPPUNIT_ASSERT_EQUAL(msg1, next); - next = queue2->dequeue(); + next = queue2->dequeue().payload; CPPUNIT_ASSERT_EQUAL(msg1, next); - next = queue3->dequeue(); + next = queue3->dequeue().payload; CPPUNIT_ASSERT_EQUAL(msg1, next); } -- cgit v1.2.1