Author: cctrieloff
Date: Thu Jul 9 20:19:04 2009
New Revision: 792664
URL: http://svn.apache.org/viewvc?rev=792664&view=rev
Log:
Clean up for next commit to clean broker interface
Modified:
qpid/trunk/qpid/cpp/src/tests/IncompleteMessageList.cpp
qpid/trunk/qpid/cpp/src/tests/QueueTest.cpp
Modified: qpid/trunk/qpid/cpp/src/tests/IncompleteMessageList.cpp
URL:
http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/src/tests/IncompleteMessageList.cpp?rev=792664&r1=792663&r2=792664&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/tests/IncompleteMessageList.cpp (original)
+++ qpid/trunk/qpid/cpp/src/tests/IncompleteMessageList.cpp Thu Jul 9 20:19:04
2009
@@ -73,6 +73,7 @@
QPID_AUTO_TEST_CASE(testProcessWithIncomplete)
{
+ Queue::shared_ptr queue;
IncompleteMessageList list;
SequenceNumber counter(1);
boost::intrusive_ptr<Message> middle;
@@ -82,7 +83,7 @@
list.add(msg);
if (i == 2) {
//mark a message in the middle as incomplete
- msg->enqueueAsync();
+ msg->enqueueAsync(queue, 0);
middle = msg;
}
}
Modified: qpid/trunk/qpid/cpp/src/tests/QueueTest.cpp
URL:
http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/src/tests/QueueTest.cpp?rev=792664&r1=792663&r2=792664&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/tests/QueueTest.cpp (original)
+++ qpid/trunk/qpid/cpp/src/tests/QueueTest.cpp Thu Jul 9 20:19:04 2009
@@ -88,7 +88,7 @@
//Test basic delivery:
intrusive_ptr<Message> msg1 = create_message("e", "A");
- msg1->enqueueAsync();//this is done on enqueue which is not called from
process
+ msg1->enqueueAsync(queue, 0);//this is done on enqueue which is not called
from process
queue->process(msg1);
sleep(2);
@@ -103,7 +103,7 @@
QPID_AUTO_TEST_CASE(testAsyncMessageCount){
Queue::shared_ptr queue(new Queue("my_test_queue", true));
intrusive_ptr<Message> msg1 = create_message("e", "A");
- msg1->enqueueAsync();//this is done on enqueue which is not called from
process
+ msg1->enqueueAsync(queue, 0);//this is done on enqueue which is not called
from process
queue->process(msg1);
sleep(2);
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:[email protected]
