activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject svn commit: r619088 - in /activemq/activemq-cpp/trunk/src/test-integration/integration/connector/openwire: OpenwireSimpleTest.cpp OpenwireSimpleTest.h
Date Wed, 06 Feb 2008 18:07:39 GMT
Author: tabish
Date: Wed Feb  6 10:07:22 2008
New Revision: 619088

URL: http://svn.apache.org/viewvc?rev=619088&view=rev
Log:
http://issues.apache.org/activemq/browse/AMQCPP-166

Test for this issue.

Modified:
    activemq/activemq-cpp/trunk/src/test-integration/integration/connector/openwire/OpenwireSimpleTest.cpp
    activemq/activemq-cpp/trunk/src/test-integration/integration/connector/openwire/OpenwireSimpleTest.h

Modified: activemq/activemq-cpp/trunk/src/test-integration/integration/connector/openwire/OpenwireSimpleTest.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/test-integration/integration/connector/openwire/OpenwireSimpleTest.cpp?rev=619088&r1=619087&r2=619088&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/src/test-integration/integration/connector/openwire/OpenwireSimpleTest.cpp
(original)
+++ activemq/activemq-cpp/trunk/src/test-integration/integration/connector/openwire/OpenwireSimpleTest.cpp
Wed Feb  6 10:07:22 2008
@@ -530,3 +530,88 @@
     }
     AMQ_CATCH_RETHROW( ActiveMQException )
 }
+
+void OpenwireSimpleTest::testMapMessageSend() {
+
+    try {
+        TestSupport testSupport(IntegrationCommon::getInstance().getOpenwireURL(), cms::Session::CLIENT_ACKNOWLEDGE
);
+        testSupport.initialize();
+
+        if( IntegrationCommon::debug ) {
+            cout << "Starting activemqcms test (sending "
+                 << IntegrationCommon::defaultMsgCount
+                 << " messages per type and sleeping "
+                 << IntegrationCommon::defaultDelay
+                 << " milli-seconds) ...\n"
+                 << endl;
+        }
+
+        // Create CMS Object for Comms
+        cms::Session* session = testSupport.getSession();
+        cms::Queue* queue = session->createQueue( UUID::randomUUID().toString() );
+        cms::MessageConsumer* consumer = session->createConsumer( queue );
+        cms::MessageProducer* producer = session->createProducer( queue );
+
+        unsigned char byteValue = 'A';
+        char charValue = 'B';
+        bool booleanValue = true;
+        short shortValue = 2048;
+        int intValue = 655369;
+        long long longValue = 0xFFFFFFFF00000000ULL;
+        float floatValue = 45.6545f;
+        double doubleValue = 654564.654654;
+        std::string stringValue = "The test string";
+
+        cms::MapMessage* mapMessage = session->createMapMessage();
+
+        mapMessage->setString( "stringKey", stringValue );
+        mapMessage->setBoolean( "boolKey", booleanValue );
+        mapMessage->setByte( "byteKey", byteValue );
+        mapMessage->setChar( "charKey", charValue );
+        mapMessage->setShort( "shortKey", shortValue );
+        mapMessage->setInt( "intKey", intValue );
+        mapMessage->setLong( "longKey", longValue );
+        mapMessage->setFloat( "floatKey", floatValue );
+        mapMessage->setDouble( "doubleKey", doubleValue );
+
+        std::vector<unsigned char> bytes;
+        bytes.push_back( 65 );
+        bytes.push_back( 66 );
+        bytes.push_back( 67 );
+        bytes.push_back( 68 );
+        bytes.push_back( 69 );
+        mapMessage->setBytes( "bytesKey", bytes );
+
+        // Send some text messages
+        producer->send( mapMessage );
+
+        delete mapMessage;
+
+        cms::Message* message = consumer->receive( 1500 );
+        CPPUNIT_ASSERT( message != NULL );
+
+        cms::MapMessage* recvMapMessage = dynamic_cast<MapMessage*>( message );
+        CPPUNIT_ASSERT( recvMapMessage != NULL );
+        CPPUNIT_ASSERT( recvMapMessage->getString( "stringKey" ) == stringValue );
+        CPPUNIT_ASSERT( recvMapMessage->getBoolean( "boolKey" ) == booleanValue );
+        CPPUNIT_ASSERT( recvMapMessage->getByte( "byteKey" ) == byteValue );
+        CPPUNIT_ASSERT( recvMapMessage->getChar( "charKey" ) == charValue );
+        CPPUNIT_ASSERT( recvMapMessage->getShort( "shortKey" ) == shortValue );
+        CPPUNIT_ASSERT( recvMapMessage->getInt( "intKey" ) == intValue );
+        CPPUNIT_ASSERT( recvMapMessage->getLong( "longKey" ) == longValue );
+        CPPUNIT_ASSERT( recvMapMessage->getFloat( "floatKey" ) == floatValue );
+        CPPUNIT_ASSERT( recvMapMessage->getDouble( "doubleKey" ) == doubleValue );
+        CPPUNIT_ASSERT( recvMapMessage->getBytes( "bytesKey" ) == bytes );
+
+        delete message;
+
+        if( IntegrationCommon::debug ) {
+            printf("Shutting Down\n" );
+        }
+
+        delete producer;
+        delete consumer;
+        delete queue;
+    }
+    AMQ_CATCH_RETHROW( ActiveMQException )
+}

Modified: activemq/activemq-cpp/trunk/src/test-integration/integration/connector/openwire/OpenwireSimpleTest.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/test-integration/integration/connector/openwire/OpenwireSimpleTest.h?rev=619088&r1=619087&r2=619088&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/src/test-integration/integration/connector/openwire/OpenwireSimpleTest.h
(original)
+++ activemq/activemq-cpp/trunk/src/test-integration/integration/connector/openwire/OpenwireSimpleTest.h
Wed Feb  6 10:07:22 2008
@@ -30,15 +30,16 @@
     class OpenwireSimpleTest : public CppUnit::TestFixture
     {
         CPPUNIT_TEST_SUITE( OpenwireSimpleTest );
-        CPPUNIT_TEST( testAutoAck );
-        CPPUNIT_TEST( testClientAck );
-        CPPUNIT_TEST( testProducerWithNullDestination );
-        CPPUNIT_TEST( testSyncReceive );
-        CPPUNIT_TEST( testMultipleConnections );
-        CPPUNIT_TEST( testMultipleSessions );
-        CPPUNIT_TEST( testReceiveAlreadyInQueue );
-        CPPUNIT_TEST( testQuickCreateAndDestroy );
-        CPPUNIT_TEST( testWithZeroConsumerPrefetch );
+//        CPPUNIT_TEST( testAutoAck );
+//        CPPUNIT_TEST( testClientAck );
+//        CPPUNIT_TEST( testProducerWithNullDestination );
+//        CPPUNIT_TEST( testSyncReceive );
+//        CPPUNIT_TEST( testMultipleConnections );
+//        CPPUNIT_TEST( testMultipleSessions );
+//        CPPUNIT_TEST( testReceiveAlreadyInQueue );
+//        CPPUNIT_TEST( testQuickCreateAndDestroy );
+//        CPPUNIT_TEST( testWithZeroConsumerPrefetch );
+        CPPUNIT_TEST( testMapMessageSend );
         CPPUNIT_TEST_SUITE_END();
 
     public:
@@ -55,6 +56,7 @@
         virtual void testReceiveAlreadyInQueue();
         virtual void testQuickCreateAndDestroy();
         virtual void testWithZeroConsumerPrefetch();
+        virtual void testMapMessageSend();
 
     };
 



Mime
View raw message