activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject svn commit: r519935 - in /activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/core: ActiveMQProducer.cpp ActiveMQProducer.h
Date Mon, 19 Mar 2007 12:58:07 GMT
Author: tabish
Date: Mon Mar 19 05:58:07 2007
New Revision: 519935

URL: http://svn.apache.org/viewvc?view=rev&rev=519935
Log:
Cleaning up some code.

Modified:
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/core/ActiveMQProducer.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/core/ActiveMQProducer.h

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/core/ActiveMQProducer.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/core/ActiveMQProducer.cpp?view=diff&rev=519935&r1=519934&r2=519935
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/core/ActiveMQProducer.cpp (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/core/ActiveMQProducer.cpp Mon
Mar 19 05:58:07 2007
@@ -41,15 +41,15 @@
     }
 
     // Init Producer Data
-    this->session      = session;
+    this->session = session;
     this->producerInfo = producerInfo;
-    this->closed       = false;
+    this->closed = false;
 
     // Default the Delivery options
     this->defaultDeliveryMode = cms::DeliveryMode::PERSISTENT;
-    this->disableTimestamps   = false;
-    this->defaultPriority     = 4;
-    this->defaultTimeToLive   = 0;
+    this->disableTimestamps = false;
+    this->defaultPriority = 4;
+    this->defaultTimeToLive = 0;
 
     // Listen for our resource to close
     this->producerInfo->addListener( this );
@@ -111,9 +111,8 @@
 
 ////////////////////////////////////////////////////////////////////////////////
 void ActiveMQProducer::send( cms::Message* message, int deliveryMode,
-    int priority,
-    long long timeToLive )
-    throw ( cms::CMSException )
+                             int priority, long long timeToLive )
+                                throw ( cms::CMSException )
 {
     try
     {
@@ -125,7 +124,7 @@
         }
 
         send( producerInfo->getDestination(), message, deliveryMode,
-            priority, timeToLive );
+              priority, timeToLive );
     }
     AMQ_CATCH_RETHROW( ActiveMQException )
     AMQ_CATCHALL_THROW( ActiveMQException )
@@ -133,7 +132,7 @@
 
 ////////////////////////////////////////////////////////////////////////////////
 void ActiveMQProducer::send( const cms::Destination* destination,
-                             cms::Message* message) throw ( cms::CMSException )
+                             cms::Message* message ) throw ( cms::CMSException )
 {
     try
     {
@@ -145,7 +144,7 @@
         }
 
         send( destination, message, defaultDeliveryMode,
-            defaultPriority, defaultTimeToLive );
+              defaultPriority, defaultTimeToLive );
     }
     AMQ_CATCH_RETHROW( ActiveMQException )
     AMQ_CATCHALL_THROW( ActiveMQException )
@@ -154,7 +153,7 @@
 ////////////////////////////////////////////////////////////////////////////////
 void ActiveMQProducer::send( const cms::Destination* destination,
                              cms::Message* message, int deliveryMode,
-                             int priority, long long timeToLive)
+                             int priority, long long timeToLive )
     throw ( cms::CMSException )
 {
     try
@@ -182,13 +181,13 @@
 
         if( !disableTimestamps ) {
             long long timeStamp = Date::getCurrentTimeMilliseconds();
-            message->setCMSTimestamp(timeStamp);
+            message->setCMSTimestamp( timeStamp );
             if( timeToLive > 0LL ) {
                 expiration = timeToLive + timeStamp;
             }
         }
 
-        message->setCMSExpiration(expiration);
+        message->setCMSExpiration( expiration );
 
         session->send( message, this );
     }

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/core/ActiveMQProducer.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/core/ActiveMQProducer.h?view=diff&rev=519935&r1=519934&r2=519935
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/core/ActiveMQProducer.h (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/core/ActiveMQProducer.h Mon
Mar 19 05:58:07 2007
@@ -92,8 +92,9 @@
          * milliseconds.
          * @throws CMSException
          */
-        virtual void send( cms::Message* message, int deliveryMode, int priority,
-            long long timeToLive) throw ( cms::CMSException );
+        virtual void send( cms::Message* message, int deliveryMode,
+                           int priority, long long timeToLive )
+                               throw ( cms::CMSException );
 
         /**
          * Sends the message to the designated destination.
@@ -115,8 +116,9 @@
          * @throws CMSException
          */
         virtual void send( const cms::Destination* destination,
-            cms::Message* message, int deliveryMode, int priority,
-            long long timeToLive) throw ( cms::CMSException );
+                           cms::Message* message, int deliveryMode,
+                           int priority, long long timeToLive )
+                                throw ( cms::CMSException );
 
         /**
          * Sets the delivery mode for this Producer



Mime
View raw message