activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From nmitt...@apache.org
Subject svn commit: r474565 - /incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/examples/main.cpp
Date Mon, 13 Nov 2006 23:21:10 GMT
Author: nmittler
Date: Mon Nov 13 15:21:09 2006
New Revision: 474565

URL: http://svn.apache.org/viewvc?view=rev&rev=474565
Log:
cleaning up the spaces/tabs in the example ActiveMQ CPP main.cpp

Modified:
    incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/examples/main.cpp

Modified: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/examples/main.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/examples/main.cpp?view=diff&rev=474565&r1=474564&r2=474565
==============================================================================
--- incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/examples/main.cpp (original)
+++ incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/examples/main.cpp Mon Nov 13 15:21:09
2006
@@ -37,29 +37,29 @@
 
 class HelloWorldProducer : public Runnable {
 private:
-	
-	Connection* connection;
-	Session* session;
-	Destination* destination;
-	MessageProducer* producer;
-	int numMessages;
+    
+    Connection* connection;
+    Session* session;
+    Destination* destination;
+    MessageProducer* producer;
+    int numMessages;
     bool useTopic;
 
 public:
-	
-	HelloWorldProducer( int numMessages, bool useTopic = false ){
-		connection = NULL;
-    	session = NULL;
-    	destination = NULL;
-    	producer = NULL;
-    	this->numMessages = numMessages;
+    
+    HelloWorldProducer( int numMessages, bool useTopic = false ){
+        connection = NULL;
+        session = NULL;
+        destination = NULL;
+        producer = NULL;
+        this->numMessages = numMessages;
         this->useTopic = useTopic;
-	}
-	
-	virtual ~HelloWorldProducer(){
-		cleanup();
-	}
-	
+    }
+    
+    virtual ~HelloWorldProducer(){
+        cleanup();
+    }
+    
     virtual void run() {
         try {
             // Create a ConnectionFactory
@@ -90,15 +90,15 @@
             string text = (string)"Hello world! from thread " + threadIdStr;
             
             for( int ix=0; ix<numMessages; ++ix ){
-	            TextMessage* message = session->createTextMessage( text );
+                TextMessage* message = session->createTextMessage( text );
 
-    	        // Tell the producer to send the message
-        	    printf( "Sent message from thread %s\n", threadIdStr.c_str() );
-            	producer->send( message );
-            	
-            	delete message;
+                // Tell the producer to send the message
+                printf( "Sent message from thread %s\n", threadIdStr.c_str() );
+                producer->send( message );
+                
+                delete message;
             }
-			
+            
         }catch ( CMSException& e ) {
             e.printStackTrace();
         }
@@ -107,65 +107,65 @@
 private:
 
     void cleanup(){
-    				
-			// Destroy resources.
-			try{                        
-            	if( destination != NULL ) delete destination;
-			}catch ( CMSException& e ) {}
-			destination = NULL;
-			
-			try{
-	            if( producer != NULL ) delete producer;
-			}catch ( CMSException& e ) {}
-			producer = NULL;
-			
-    		// Close open resources.
-    		try{
-    			if( session != NULL ) session->close();
-    			if( connection != NULL ) connection->close();
-			}catch ( CMSException& e ) {}
-
-			try{
-            	if( session != NULL ) delete session;
-			}catch ( CMSException& e ) {}
-			session = NULL;
-			
+                    
+            // Destroy resources.
+            try{                        
+                if( destination != NULL ) delete destination;
+            }catch ( CMSException& e ) {}
+            destination = NULL;
+            
             try{
-            	if( connection != NULL ) delete connection;
-			}catch ( CMSException& e ) {}
-    		connection = NULL;
+                if( producer != NULL ) delete producer;
+            }catch ( CMSException& e ) {}
+            producer = NULL;
+            
+            // Close open resources.
+            try{
+                if( session != NULL ) session->close();
+                if( connection != NULL ) connection->close();
+            }catch ( CMSException& e ) {}
+
+            try{
+                if( session != NULL ) delete session;
+            }catch ( CMSException& e ) {}
+            session = NULL;
+            
+            try{
+                if( connection != NULL ) delete connection;
+            }catch ( CMSException& e ) {}
+            connection = NULL;
     }
 };
 
 class HelloWorldConsumer : public ExceptionListener, 
                            public MessageListener,
                            public Runnable {
-	
+    
 private:
-	
-	Connection* connection;
-	Session* session;
-	Destination* destination;
-	MessageConsumer* consumer;
-	long waitMillis;
+    
+    Connection* connection;
+    Session* session;
+    Destination* destination;
+    MessageConsumer* consumer;
+    long waitMillis;
     bool useTopic;
-		
+        
 public: 
 
-	HelloWorldConsumer( long waitMillis, bool useTopic = false ){
-		connection = NULL;
-    	session = NULL;
-    	destination = NULL;
-    	consumer = NULL;
-    	this->waitMillis = waitMillis;
+    HelloWorldConsumer( long waitMillis, bool useTopic = false ){
+        connection = NULL;
+        session = NULL;
+        destination = NULL;
+        consumer = NULL;
+        this->waitMillis = waitMillis;
         this->useTopic = useTopic;
-	}
-    virtual ~HelloWorldConsumer(){    	
-    	cleanup();
+    }
+    virtual ~HelloWorldConsumer(){      
+        cleanup();
     }
     
     virtual void run() {
-    	    	
+                
         try {
 
             // Create a ConnectionFactory
@@ -195,7 +195,7 @@
             consumer->setMessageListener( this );
             
             // Sleep while asynchronous messages come in.
-            Thread::sleep( waitMillis );		
+            Thread::sleep( waitMillis );        
             
         } catch (CMSException& e) {
             e.printStackTrace();
@@ -204,13 +204,13 @@
     
     // Called from the consumer since this class is a registered MessageListener.
     virtual void onMessage( const Message* message ){
-    	
+        
         static int count = 0;
         
         try
         {
             count++;
-    	    const TextMessage* textMessage = 
+            const TextMessage* textMessage = 
                 dynamic_cast< const TextMessage* >( message );
             string text = textMessage->getText();
             printf( "Message #%d Received: %s\n", count, text.c_str() );
@@ -228,39 +228,39 @@
 private:
 
     void cleanup(){
-    	
+        
         //*************************************************
         // Always close destination, consumers and producers before
         // you destroy their sessions and connection.
         //*************************************************
         
-		// Destroy resources.
-		try{                        
-        	if( destination != NULL ) delete destination;
-		}catch (CMSException& e) {}
-		destination = NULL;
-		
-		try{
+        // Destroy resources.
+        try{                        
+            if( destination != NULL ) delete destination;
+        }catch (CMSException& e) {}
+        destination = NULL;
+        
+        try{
             if( consumer != NULL ) delete consumer;
-		}catch (CMSException& e) {}
-		consumer = NULL;
-		
-		// Close open resources.
-		try{
-			if( session != NULL ) session->close();
-			if( connection != NULL ) connection->close();
-		}catch (CMSException& e) {}
-		
+        }catch (CMSException& e) {}
+        consumer = NULL;
+        
+        // Close open resources.
+        try{
+            if( session != NULL ) session->close();
+            if( connection != NULL ) connection->close();
+        }catch (CMSException& e) {}
+        
         // Now Destroy them
         try{
-        	if( session != NULL ) delete session;
-		}catch (CMSException& e) {}
-		session = NULL;
-		
-		try{
-        	if( connection != NULL ) delete connection;
-		}catch (CMSException& e) {}
-		connection = NULL;
+            if( session != NULL ) delete session;
+        }catch (CMSException& e) {}
+        session = NULL;
+        
+        try{
+            if( connection != NULL ) delete connection;
+        }catch (CMSException& e) {}
+        connection = NULL;
     }
 };
     
@@ -278,19 +278,19 @@
     bool useTopics = false;  
 
     HelloWorldProducer producer( 1000, useTopics );
-	HelloWorldConsumer consumer( 8000, useTopics );
-	
-	// Start the consumer thread.
-	Thread consumerThread( &consumer );
-	consumerThread.start();
-	
-	// Start the producer thread.
-	Thread producerThread( &producer );
-	producerThread.start();
-
-	// Wait for the threads to complete.
-	producerThread.join();
-	consumerThread.join();
+    HelloWorldConsumer consumer( 8000, useTopics );
+    
+    // Start the consumer thread.
+    Thread consumerThread( &consumer );
+    consumerThread.start();
+    
+    // Start the producer thread.
+    Thread producerThread( &producer );
+    producerThread.start();
+
+    // Wait for the threads to complete.
+    producerThread.join();
+    consumerThread.join();
 
     std::cout << "-----------------------------------------------------\n";    
     std::cout << "Finished with the example, ignore errors from this" 



Mime
View raw message