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
