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
|