activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From nmitt...@apache.org
Subject svn commit: r396330 - /incubator/activemq/trunk/cms/test/main.cpp
Date Sun, 23 Apr 2006 22:09:14 GMT
Author: nmittler
Date: Sun Apr 23 15:09:13 2006
New Revision: 396330

URL: http://svn.apache.org/viewcvs?rev=396330&view=rev
Log:
Fixed handling of bytes message for Jira issue AMQ-685

Modified:
    incubator/activemq/trunk/cms/test/main.cpp

Modified: incubator/activemq/trunk/cms/test/main.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/cms/test/main.cpp?rev=396330&r1=396329&r2=396330&view=diff
==============================================================================
--- incubator/activemq/trunk/cms/test/main.cpp (original)
+++ incubator/activemq/trunk/cms/test/main.cpp Sun Apr 23 15:09:13 2006
@@ -16,6 +16,7 @@
  */
  
 #include <activemq/ActiveMQTextMessage.h>
+#include <activemq/ActiveMQBytesMessage.h>
 #include <cms/TopicConnectionFactory.h>
 #include <cms/TopicConnection.h>
 #include <cms/TopicSession.h>
@@ -46,13 +47,13 @@
         
         try{
         	
-        	int numMessages = 1000;
-        	int sleepTime = 10;
+        	int messagesPerType = 3000;
+        	int sleepTime = 2;
         	
-        	printf("Starting activemqcms test (sending %d messages and sleeping %d seconds)
...\n", numMessages, sleepTime );
+        	printf("Starting activemqcms test (sending %d messages per type and sleeping %d
seconds) ...\n", messagesPerType, sleepTime );
             
             // START SNIPPET: demo
-            cms::TopicConnectionFactory* connectionFactory = new activemq::ActiveMQConnectionFactory(
"127.0.0.1:61626" );
+            cms::TopicConnectionFactory* connectionFactory = new activemq::ActiveMQConnectionFactory(
"127.0.0.1:61613" );
             cms::TopicConnection* connection = connectionFactory->createTopicConnection();
             connection->setExceptionListener( this );
             connection->start();
@@ -62,22 +63,46 @@
             subscriber->setMessageListener( this );
             cms::TopicPublisher* publisher = session->createPublisher( topic );
             
+            // Send some text messages.
             const char* text = "this is a test!";
-            cms::TextMessage* msg = session->createTextMessage( text );
-                        
-            for( int ix=0; ix<numMessages; ++ix ){                
-                publisher->publish( msg );
-                doSleep();
+            cms::TextMessage* textMsg = session->createTextMessage( text );          
             
+            for( int ix=0; ix<messagesPerType; ++ix ){                
+                publisher->publish( textMsg );
+                doSleep();               
             }
+            
+            // Send some bytes messages.
+            char buf[10];
+            memset( buf, 0, 10 );
+            buf[0] = 0;
+            buf[1] = 1;
+            buf[2] = 2;
+            buf[3] = 3;
+            buf[4] = 0;
+            buf[5] = 4;
+            buf[6] = 5;
+            buf[7] = 6;
+            cms::BytesMessage* bytesMsg = session->createBytesMessage();
+            bytesMsg->setData( buf, 10 );
+            for( int ix=0; ix<messagesPerType; ++ix ){                
+                publisher->publish( bytesMsg ); 
+                doSleep();               
+            }        
             // END SNIPPET: demo
             
             sleep( sleepTime );
             
             printf("received: %d\n", numReceived );
             
-            delete publisher;
+            sleep( 5 );
+            
+            printf("unsubscribing\n" );
+            delete publisher;                      
             subscriber->close();
             delete subscriber;
+            
+            sleep( 5 );            
+            
             session->close();
             delete session;
             connection->close();
@@ -90,14 +115,26 @@
     }
     
     virtual void onMessage( const cms::Message* message ){
+        
+        // Got a text message.
         const cms::TextMessage* txtMsg = dynamic_cast<const cms::TextMessage*>(message);
-        if( txtMsg == NULL ){
-            printf("received non-text message\n" );
-            return;
+        if( txtMsg != NULL ){
+            //printf("received text msg: %s\n", txtMsg->getText() );
+        }
+        
+        // Got a bytes msg.
+        const cms::BytesMessage* bytesMsg = dynamic_cast<const cms::BytesMessage*>(message);
+        if( bytesMsg != NULL ){
+            /*printf("received bytes msg: " );
+            const char* bytes = bytesMsg->getData();
+            int numBytes = bytesMsg->getNumBytes();
+            for( int ix=0; ix<numBytes; ++ix ){
+            	printf("[%d]", bytes[ix] );
+            }
+            printf("\n");*/
         }
         
         numReceived++;
-        //printf( "[%d]: %s\n", ++ix, txtMsg->getMessage() );
     }
     
     virtual void onException( const cms::CMSException* error ){



Mime
View raw message