You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ta...@apache.org on 2008/11/10 23:14:49 UTC
svn commit: r712854 -
/activemq/activemq-cpp/trunk/src/main/activemq/cmsutil/CmsTemplate.h
Author: tabish
Date: Mon Nov 10 14:14:49 2008
New Revision: 712854
URL: http://svn.apache.org/viewvc?rev=712854&view=rev
Log:
Cleanup
Modified:
activemq/activemq-cpp/trunk/src/main/activemq/cmsutil/CmsTemplate.h
Modified: activemq/activemq-cpp/trunk/src/main/activemq/cmsutil/CmsTemplate.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/cmsutil/CmsTemplate.h?rev=712854&r1=712853&r2=712854&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/src/main/activemq/cmsutil/CmsTemplate.h (original)
+++ activemq/activemq-cpp/trunk/src/main/activemq/cmsutil/CmsTemplate.h Mon Nov 10 14:14:49 2008
@@ -42,7 +42,7 @@
* CMS resources internally.
* <p>
* Before using <code>CmsTemplate</code> the user must first set
- * the destination (either by name or by setting the destiation
+ * the destination (either by name or by setting the destination
* object directly) and then call <code>init</code> to initialize
* the object for use.
* <p>
@@ -98,8 +98,10 @@
public:
- ProducerExecutor(ProducerCallback* action,
- CmsTemplate* parent, cms::Destination* destination){
+ ProducerExecutor( ProducerCallback* action,
+ CmsTemplate* parent,
+ cms::Destination* destination ){
+
this->action = action;
this->parent = parent;
this->destination = destination;
@@ -107,10 +109,10 @@
virtual ~ProducerExecutor() {}
- virtual void doInCms(cms::Session* session) throw (cms::CMSException);
+ virtual void doInCms( cms::Session* session ) throw ( cms::CMSException );
- virtual cms::Destination* getDestination(cms::Session* session AMQCPP_UNUSED)
- throw (cms::CMSException) {
+ virtual cms::Destination* getDestination( cms::Session* session AMQCPP_UNUSED )
+ throw ( cms::CMSException ) {
return destination;
}
};
@@ -127,18 +129,19 @@
public:
- ResolveProducerExecutor(ProducerCallback* action,
- CmsTemplate* parent, const std::string& destinationName)
+ ResolveProducerExecutor( ProducerCallback* action,
+ CmsTemplate* parent,
+ const std::string& destinationName )
:
- ProducerExecutor(action, parent, NULL) {
+ ProducerExecutor( action, parent, NULL ) {
this->destinationName = destinationName;
}
virtual ~ResolveProducerExecutor() {}
- virtual cms::Destination* getDestination(cms::Session* session)
- throw (cms::CMSException) ;
+ virtual cms::Destination* getDestination( cms::Session* session )
+ throw ( cms::CMSException );
};
/**
@@ -155,16 +158,16 @@
public:
SendExecutor( MessageCreator* messageCreator,
- CmsTemplate* parent) {
+ CmsTemplate* parent ) {
this->messageCreator = messageCreator;
this->parent = parent;
}
virtual ~SendExecutor() {}
- virtual void doInCms(cms::Session* session,
- cms::MessageProducer* producer) throw (cms::CMSException) {
- parent->doSend(session, producer, messageCreator);
+ virtual void doInCms( cms::Session* session,
+ cms::MessageProducer* producer ) throw ( cms::CMSException ) {
+ parent->doSend( session, producer, messageCreator );
}
};
@@ -183,10 +186,11 @@
CmsTemplate* parent;
public:
+
ReceiveExecutor( CmsTemplate* parent,
- cms::Destination* destination,
- const std::string& selector,
- bool noLocal) {
+ cms::Destination* destination,
+ const std::string& selector,
+ bool noLocal ) {
this->parent = parent;
this->destination = destination;
this->selector = selector;
@@ -196,11 +200,11 @@
virtual ~ReceiveExecutor() {}
- virtual void doInCms(cms::Session* session)
+ virtual void doInCms( cms::Session* session )
throw (cms::CMSException);
- virtual cms::Destination* getDestination(cms::Session* session AMQCPP_UNUSED)
- throw (cms::CMSException) {
+ virtual cms::Destination* getDestination( cms::Session* session AMQCPP_UNUSED )
+ throw ( cms::CMSException ) {
return destination;
}
@@ -221,10 +225,10 @@
public:
- ResolveReceiveExecutor(CmsTemplate* parent,
- const std::string& selector,
- bool noLocal,
- const std::string& destinationName)
+ ResolveReceiveExecutor( CmsTemplate* parent,
+ const std::string& selector,
+ bool noLocal,
+ const std::string& destinationName )
:
ReceiveExecutor( parent, NULL, selector, noLocal) {
@@ -233,8 +237,8 @@
virtual ~ResolveReceiveExecutor() {}
- virtual cms::Destination* getDestination(cms::Session* session)
- throw (cms::CMSException);
+ virtual cms::Destination* getDestination( cms::Session* session )
+ throw ( cms::CMSException );
};
private:
@@ -283,7 +287,7 @@
* @param defaultDestination
* the default destination
*/
- virtual void setDefaultDestination(cms::Destination* defaultDestination) {
+ virtual void setDefaultDestination( cms::Destination* defaultDestination ) {
this->defaultDestination = defaultDestination;
}
@@ -312,7 +316,7 @@
* @param defaultDestinationName
* the name of the destination for send/receive to by default.
*/
- virtual void setDefaultDestinationName(const std::string& defaultDestinationName) {
+ virtual void setDefaultDestinationName( const std::string& defaultDestinationName ) {
if( defaultDestinationName != this->defaultDestinationName ) {
this->defaultDestination = NULL;
this->defaultDestinationName = defaultDestinationName;
@@ -340,11 +344,11 @@
virtual void setPubSubDomain( bool pubSubDomain ) {
if( pubSubDomain != isPubSubDomain() ) {
this->defaultDestination = NULL;
- CmsDestinationAccessor::setPubSubDomain(pubSubDomain);
+ CmsDestinationAccessor::setPubSubDomain( pubSubDomain );
}
}
- virtual void setMessageIdEnabled(bool messageIdEnabled) {
+ virtual void setMessageIdEnabled( bool messageIdEnabled ) {
this->messageIdEnabled = messageIdEnabled;
}
@@ -352,7 +356,7 @@
return this->messageIdEnabled;
}
- virtual void setMessageTimestampEnabled(bool messageTimestampEnabled) {
+ virtual void setMessageTimestampEnabled( bool messageTimestampEnabled ) {
this->messageTimestampEnabled = messageTimestampEnabled;
}
@@ -360,7 +364,7 @@
return this->messageTimestampEnabled;
}
- virtual void setNoLocal(bool noLocal) {
+ virtual void setNoLocal( bool noLocal ) {
this->noLocal = noLocal;
}
@@ -368,7 +372,7 @@
return this->noLocal;
}
- virtual void setReceiveTimeout(long long receiveTimeout) {
+ virtual void setReceiveTimeout( long long receiveTimeout ) {
this->receiveTimeout = receiveTimeout;
}
@@ -384,7 +388,7 @@
* @see #setPriority
* @see #setTimeToLive
*/
- virtual void setExplicitQosEnabled(bool explicitQosEnabled) {
+ virtual void setExplicitQosEnabled( bool explicitQosEnabled ) {
this->explicitQosEnabled = explicitQosEnabled;
}
@@ -412,7 +416,7 @@
*
* @see #setDeliveryMode(int)
*/
- virtual void setDeliveryPersistent(bool deliveryPersistent) {
+ virtual void setDeliveryPersistent( bool deliveryPersistent ) {
this->deliveryMode = (deliveryPersistent ? 0 : 1 );
}
@@ -424,7 +428,7 @@
* @param deliveryMode the delivery mode to use
* @see #isExplicitQosEnabled
*/
- virtual void setDeliveryMode(int deliveryMode) {
+ virtual void setDeliveryMode( int deliveryMode ) {
this->deliveryMode = deliveryMode;
}
@@ -442,7 +446,7 @@
*
* @see #isExplicitQosEnabled
*/
- virtual void setPriority(int priority) {
+ virtual void setPriority( int priority ) {
this->priority = priority;
}
@@ -461,7 +465,7 @@
*
* @see #isExplicitQosEnabled
*/
- virtual void setTimeToLive(long long timeToLive) {
+ virtual void setTimeToLive( long long timeToLive ) {
this->timeToLive = timeToLive;
}
@@ -478,7 +482,7 @@
* the action to perform within a CMS Session
* @throws cms::CMSException thrown if an error occurs.
*/
- virtual void execute(SessionCallback* action) throw (cms::CMSException);
+ virtual void execute( SessionCallback* action ) throw ( cms::CMSException );
/**
* Executes the given action and provides it with a CMS Session and
@@ -488,7 +492,7 @@
* the action to perform
* @throws cms::CMSException thrown if an error occurs.
*/
- virtual void execute(ProducerCallback* action) throw (cms::CMSException);
+ virtual void execute( ProducerCallback* action ) throw ( cms::CMSException );
/**
* Executes the given action and provides it with a CMS Session and
@@ -500,8 +504,8 @@
* the action to perform
* @throws cms::CMSException thrown if an error occurs.
*/
- virtual void execute(cms::Destination* dest,
- ProducerCallback* action) throw (cms::CMSException);
+ virtual void execute( cms::Destination* dest, ProducerCallback* action )
+ throw (cms::CMSException);
/**
* Executes the given action and provides it with a CMS Session and
@@ -514,8 +518,9 @@
* the action to perform
* @throws cms::CMSException thrown if an error occurs.
*/
- virtual void execute(const std::string& destinationName,
- ProducerCallback* action) throw (cms::CMSException);
+ virtual void execute( const std::string& destinationName,
+ ProducerCallback* action )
+ throw ( cms::CMSException );
/**
* Convenience method for sending a message to the default destination.
@@ -525,7 +530,7 @@
* @throws cms::CMSException thrown if an error occurs.
*/
virtual void send(MessageCreator* messageCreator)
- throw (cms::CMSException);
+ throw ( cms::CMSException );
/**
* Convenience method for sending a message to the specified destination.
@@ -536,9 +541,9 @@
* Responsible for creating the message to be sent
* @throws cms::CMSException thrown if an error occurs.
*/
- virtual void send(cms::Destination* dest,
- MessageCreator* messageCreator)
- throw (cms::CMSException);
+ virtual void send( cms::Destination* dest,
+ MessageCreator* messageCreator )
+ throw ( cms::CMSException );
/**
* Convenience method for sending a message to the specified destination.
@@ -549,9 +554,9 @@
* Responsible for creating the message to be sent
* @throws cms::CMSException thrown if an error occurs.
*/
- virtual void send(const std::string& destinationName,
- MessageCreator* messageCreator)
- throw (cms::CMSException);
+ virtual void send( const std::string& destinationName,
+ MessageCreator* messageCreator )
+ throw ( cms::CMSException );
/**
* Performs a synchronous read from the default destination.
@@ -559,7 +564,7 @@
* @throws cms::CMSException thrown if an error occurs
*/
virtual cms::Message* receive()
- throw (cms::CMSException);
+ throw ( cms::CMSException );
/**
* Performs a synchronous read from the specified destination.
@@ -568,8 +573,8 @@
* @return the message
* @throws cms::CMSException thrown if an error occurs
*/
- virtual cms::Message* receive(cms::Destination* destination )
- throw (cms::CMSException);
+ virtual cms::Message* receive( cms::Destination* destination )
+ throw ( cms::CMSException );
/**
* Performs a synchronous read from the specified destination.
@@ -579,8 +584,8 @@
* @return the message
* @throws cms::CMSException thrown if an error occurs
*/
- virtual cms::Message* receive(const std::string& destinationName )
- throw (cms::CMSException);
+ virtual cms::Message* receive( const std::string& destinationName )
+ throw ( cms::CMSException );
/**
* Performs a synchronous read consuming only messages identified by the
@@ -591,8 +596,8 @@
* @return the message
* @throws cms::CMSException thrown if an error occurs
*/
- virtual cms::Message* receiveSelected(const std::string& selector )
- throw (cms::CMSException);
+ virtual cms::Message* receiveSelected( const std::string& selector )
+ throw ( cms::CMSException );
/**
* Performs a synchronous read from the specified destination, consuming
@@ -606,8 +611,8 @@
* @throws cms::CMSException thrown if an error occurs
*/
virtual cms::Message* receiveSelected( cms::Destination* destination,
- const std::string& selector )
- throw (cms::CMSException);
+ const std::string& selector )
+ throw ( cms::CMSException );
/**
* Performs a synchronous read from the specified destination, consuming
@@ -622,8 +627,8 @@
* @throws cms::CMSException thrown if an error occurs
*/
virtual cms::Message* receiveSelected( const std::string& destinationName,
- const std::string& selector )
- throw (cms::CMSException);
+ const std::string& selector )
+ throw ( cms::CMSException );
protected:
@@ -632,13 +637,13 @@
* before any other methds are called.
*/
void init()
- throw (cms::CMSException, decaf::lang::exceptions::IllegalStateException);
+ throw ( cms::CMSException, decaf::lang::exceptions::IllegalStateException );
/**
* Clears all internal resources.
*/
void destroy()
- throw (cms::CMSException, decaf::lang::exceptions::IllegalStateException);
+ throw ( cms::CMSException, decaf::lang::exceptions::IllegalStateException );
private:
@@ -664,14 +669,14 @@
* if the default destination is invalid.
*/
void checkDefaultDestination()
- throw (decaf::lang::exceptions::IllegalStateException);
+ throw ( decaf::lang::exceptions::IllegalStateException );
/**
* Gets the connection, creating it if it doesn't already exist.
* @return the connection
* @throws cms::CMSException if any of the CMS methods throw.
*/
- cms::Connection* getConnection() throw (cms::CMSException);
+ cms::Connection* getConnection() throw ( cms::CMSException );
/**
* Creates a session initialized with the proper values.
@@ -679,7 +684,7 @@
* @return the session
* @throws cms::CMSException if any of the CMS methods throw.
*/
- PooledSession* takeSession() throw (cms::CMSException);
+ PooledSession* takeSession() throw ( cms::CMSException );
/**
* Closes, but does not destroy the pooled session resource.
@@ -687,7 +692,7 @@
* a pooled session resource
* @throws cms::CMSException thrown if the CMS methods throw.
*/
- void returnSession( PooledSession*& session ) throw (cms::CMSException);
+ void returnSession( PooledSession*& session ) throw ( cms::CMSException );
/**
* Allocates a producer initialized with the proper values.
@@ -700,8 +705,8 @@
* @return the producer
* @throws cms::CMSException thrown by the CMS API
*/
- cms::MessageProducer* createProducer(cms::Session* session,
- cms::Destination* dest) throw (cms::CMSException);
+ cms::MessageProducer* createProducer( cms::Session* session,
+ cms::Destination* dest ) throw ( cms::CMSException );
/**
* Closes and destroys a producer resource
@@ -722,10 +727,10 @@
* @return the consumer
* @throws cms::CMSException thrown by the CMS API
*/
- cms::MessageConsumer* createConsumer(cms::Session* session,
- cms::Destination* dest,
- const std::string& selector,
- bool noLocal ) throw (cms::CMSException);
+ cms::MessageConsumer* createConsumer( cms::Session* session,
+ cms::Destination* dest,
+ const std::string& selector,
+ bool noLocal ) throw ( cms::CMSException );
/**
* Closes and destroys a consumer resource
@@ -752,9 +757,9 @@
* creates the message to be sent
* @throws cms::CMSException thrown if the CMS API throws.
*/
- void doSend(cms::Session* session,
- cms::MessageProducer* producer,
- MessageCreator* messageCreator) throw (cms::CMSException);
+ void doSend( cms::Session* session,
+ cms::MessageProducer* producer,
+ MessageCreator* messageCreator ) throw ( cms::CMSException );
/**
* Receives a message from a destination.
@@ -763,8 +768,8 @@
* @return the message that was read
* @throws cms::CMSException thrown if the CMS API throws.
*/
- cms::Message* doReceive(cms::MessageConsumer* consumer )
- throw (cms::CMSException);
+ cms::Message* doReceive( cms::MessageConsumer* consumer )
+ throw ( cms::CMSException );
/**
* Resolves the default destination and returns it.
@@ -773,8 +778,9 @@
* @return the default destination
* @throws cms::CMSException if an error occurs
*/
- cms::Destination* resolveDefaultDestination(cms::Session* session)
- throw (cms::CMSException);
+ cms::Destination* resolveDefaultDestination( cms::Session* session )
+ throw ( cms::CMSException );
+
};
}}