You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ta...@apache.org on 2006/12/29 01:16:41 UTC
svn commit: r490876 - in
/incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/test/activemq:
io/DataOutputStreamTest.h transport/ResponseCorrelatorTest.h
Author: tabish
Date: Thu Dec 28 16:16:39 2006
New Revision: 490876
URL: http://svn.apache.org/viewvc?view=rev&rev=490876
Log:
http://issues.apache.org/activemq/browse/AMQCPP-37
Modified:
incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/test/activemq/io/DataOutputStreamTest.h
incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/test/activemq/transport/ResponseCorrelatorTest.h
Modified: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/test/activemq/io/DataOutputStreamTest.h
URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/test/activemq/io/DataOutputStreamTest.h?view=diff&rev=490876&r1=490875&r2=490876
==============================================================================
--- incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/test/activemq/io/DataOutputStreamTest.h (original)
+++ incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/test/activemq/io/DataOutputStreamTest.h Thu Dec 28 16:16:39 2006
@@ -104,6 +104,17 @@
char tempChar3 = *(char*)(buffer+ix);
CPPUNIT_ASSERT( tempChar3 == arrayVal[2] );
ix += sizeof( tempChar3 );
+
+ std::string tempStr1( (char*)(buffer+ix), stringVal1.size() );
+ CPPUNIT_ASSERT( tempStr1 == stringVal1 );
+ ix += stringVal1.size() + 1;
+
+ uint16_t tempShort1 = util::Endian::byteSwap( *(uint16_t*)(buffer+ix) );
+ CPPUNIT_ASSERT( tempShort1 == stringVal2.size() );
+ ix += sizeof( tempShort1 );
+ std::string tempStr2( (char*)(buffer+ix), tempShort1 );
+ CPPUNIT_ASSERT( tempStr2 == stringVal2 );
+ ix += stringVal2.size();
}
Modified: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/test/activemq/transport/ResponseCorrelatorTest.h
URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/test/activemq/transport/ResponseCorrelatorTest.h?view=diff&rev=490876&r1=490875&r2=490876
==============================================================================
--- incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/test/activemq/transport/ResponseCorrelatorTest.h (original)
+++ incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/test/activemq/transport/ResponseCorrelatorTest.h Thu Dec 28 16:16:39 2006
@@ -553,7 +553,7 @@
}
// Wait to make sure we get the asynchronous message back.
- concurrent::Thread::sleep( 100 );
+ concurrent::Thread::sleep( 200 );
// Since our transport relays our original command back at us as a
// non-response message, check to make sure we received it and that