summaryrefslogtreecommitdiff
path: root/cpp/tests/ClientChannelTest.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/tests/ClientChannelTest.cpp')
-rw-r--r--cpp/tests/ClientChannelTest.cpp11
1 files changed, 0 insertions, 11 deletions
diff --git a/cpp/tests/ClientChannelTest.cpp b/cpp/tests/ClientChannelTest.cpp
index 7f7cfeda89..d041106a23 100644
--- a/cpp/tests/ClientChannelTest.cpp
+++ b/cpp/tests/ClientChannelTest.cpp
@@ -166,20 +166,13 @@ class ClientChannelTest : public CppUnit::TestCase
void testGetFragmentedMessage() {
string longStr(FRAME_MAX*2, 'x'); // Longer than max frame size.
channel.publish(Message(longStr), exchange, qname);
- // FIXME aconway 2007-03-21: Remove couts.
- cout << "==== Fragmented publish:" << endl
- << connection.conversation << endl;
Message getMsg;
- cout << "==== Fragmented get:" << endl
- << connection.conversation << endl;
CPPUNIT_ASSERT(channel.get(getMsg, queue));
}
void testConsumeFragmentedMessage() {
string xx(FRAME_MAX*2, 'x');
channel.publish(Message(xx), exchange, qname);
- cout << "==== Fragmented publish:" << endl
- << connection.conversation << endl;
channel.start();
string tag;
channel.consume(queue, tag, &listener);
@@ -190,10 +183,6 @@ class ClientChannelTest : public CppUnit::TestCase
while (listener.messages.size() != 2)
CPPUNIT_ASSERT(listener.monitor.wait(1*TIME_SEC));
}
- // FIXME aconway 2007-03-21:
- cout << "==== Fragmented consme 2 messages:" << endl
- << connection.conversation << endl;
-
CPPUNIT_ASSERT_EQUAL(xx, listener.messages[0].getData());
CPPUNIT_ASSERT_EQUAL(yy, listener.messages[1].getData());
}