activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject svn commit: r957012 - in /activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/state: CommandVisitor.h CommandVisitorAdapter.h ConnectionState.h ConnectionStateTracker.cpp ConnectionStateTracker.h
Date Tue, 22 Jun 2010 20:17:47 GMT
Author: tabish
Date: Tue Jun 22 20:17:47 2010
New Revision: 957012

URL: http://svn.apache.org/viewvc?rev=957012&view=rev
Log:
Remove throw specifier from the classes in the state namespace.

Modified:
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/state/CommandVisitor.h
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/state/CommandVisitorAdapter.h
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/state/ConnectionState.h
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/state/ConnectionStateTracker.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/state/ConnectionStateTracker.h

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/state/CommandVisitor.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/state/CommandVisitor.h?rev=957012&r1=957011&r2=957012&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/state/CommandVisitor.h (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/state/CommandVisitor.h Tue
Jun 22 20:17:47 2010
@@ -72,121 +72,121 @@ namespace state {
         virtual ~CommandVisitor() {}
 
         virtual decaf::lang::Pointer<commands::Command> processTransactionInfo(
-            commands::TransactionInfo* info ) throw ( exceptions::ActiveMQException ) = 0;
+            commands::TransactionInfo* info ) = 0;
 
         virtual decaf::lang::Pointer<commands::Command> processRemoveInfo(
-            commands::RemoveInfo* info ) throw ( exceptions::ActiveMQException ) = 0;
+            commands::RemoveInfo* info ) = 0;
 
         virtual decaf::lang::Pointer<commands::Command> processConnectionInfo(
-            commands::ConnectionInfo* info ) throw ( exceptions::ActiveMQException ) = 0;
+            commands::ConnectionInfo* info ) = 0;
 
         virtual decaf::lang::Pointer<commands::Command> processSessionInfo(
-            commands::SessionInfo* info ) throw ( exceptions::ActiveMQException ) = 0;
+            commands::SessionInfo* info ) = 0;
 
         virtual decaf::lang::Pointer<commands::Command> processProducerInfo(
-            commands::ProducerInfo* info ) throw ( exceptions::ActiveMQException ) = 0;
+            commands::ProducerInfo* info ) = 0;
 
         virtual decaf::lang::Pointer<commands::Command> processConsumerInfo(
-            commands::ConsumerInfo* info ) throw ( exceptions::ActiveMQException ) = 0;
+            commands::ConsumerInfo* info ) = 0;
 
         virtual decaf::lang::Pointer<commands::Command> processRemoveConnection(
-            commands::ConnectionId* id ) throw ( exceptions::ActiveMQException ) = 0;
+            commands::ConnectionId* id ) = 0;
 
         virtual decaf::lang::Pointer<commands::Command> processRemoveSession(
-            commands::SessionId* id ) throw ( exceptions::ActiveMQException ) = 0;
+            commands::SessionId* id ) = 0;
 
         virtual decaf::lang::Pointer<commands::Command> processRemoveProducer(
-            commands::ProducerId* id ) throw ( exceptions::ActiveMQException ) = 0;
+            commands::ProducerId* id ) = 0;
 
         virtual decaf::lang::Pointer<commands::Command> processRemoveConsumer(
-            commands::ConsumerId* id ) throw ( exceptions::ActiveMQException ) = 0;
+            commands::ConsumerId* id ) = 0;
 
         virtual decaf::lang::Pointer<commands::Command> processDestinationInfo(
-            commands::DestinationInfo* info ) throw ( exceptions::ActiveMQException ) = 0;
+            commands::DestinationInfo* info ) = 0;
 
         virtual decaf::lang::Pointer<commands::Command> processRemoveDestination(
-            commands::DestinationInfo* info ) throw ( exceptions::ActiveMQException ) = 0;
+            commands::DestinationInfo* info ) = 0;
 
         virtual decaf::lang::Pointer<commands::Command> processRemoveSubscriptionInfo(
-            commands::RemoveSubscriptionInfo* info ) throw ( exceptions::ActiveMQException
) = 0;
+            commands::RemoveSubscriptionInfo* info ) = 0;
 
         virtual decaf::lang::Pointer<commands::Command> processMessage(
-            commands::Message* send ) throw ( exceptions::ActiveMQException ) = 0;
+            commands::Message* send ) = 0;
 
         virtual decaf::lang::Pointer<commands::Command> processMessageAck(
-            commands::MessageAck* ack ) throw ( exceptions::ActiveMQException ) = 0;
+            commands::MessageAck* ack ) = 0;
 
         virtual decaf::lang::Pointer<commands::Command> processMessagePull(
-            commands::MessagePull* pull ) throw ( exceptions::ActiveMQException ) = 0;
+            commands::MessagePull* pull ) = 0;
 
         virtual decaf::lang::Pointer<commands::Command> processBeginTransaction(
-            commands::TransactionInfo* info ) throw ( exceptions::ActiveMQException ) = 0;
+            commands::TransactionInfo* info ) = 0;
 
         virtual decaf::lang::Pointer<commands::Command> processPrepareTransaction(
-            commands::TransactionInfo* info ) throw ( exceptions::ActiveMQException ) = 0;
+            commands::TransactionInfo* info ) = 0;
 
         virtual decaf::lang::Pointer<commands::Command> processCommitTransactionOnePhase(
-            commands::TransactionInfo* info ) throw ( exceptions::ActiveMQException ) = 0;
+            commands::TransactionInfo* info ) = 0;
 
         virtual decaf::lang::Pointer<commands::Command> processCommitTransactionTwoPhase(
-            commands::TransactionInfo* info ) throw ( exceptions::ActiveMQException ) = 0;
+            commands::TransactionInfo* info ) = 0;
 
         virtual decaf::lang::Pointer<commands::Command> processRollbackTransaction(
-            commands::TransactionInfo* info ) throw ( exceptions::ActiveMQException ) = 0;
+            commands::TransactionInfo* info ) = 0;
 
         virtual decaf::lang::Pointer<commands::Command> processWireFormat(
-            commands::WireFormatInfo* info ) throw ( exceptions::ActiveMQException ) = 0;
+            commands::WireFormatInfo* info ) = 0;
 
         virtual decaf::lang::Pointer<commands::Command> processKeepAliveInfo(
-            commands::KeepAliveInfo* info ) throw ( exceptions::ActiveMQException ) = 0;
+            commands::KeepAliveInfo* info ) = 0;
 
         virtual decaf::lang::Pointer<commands::Command> processShutdownInfo(
-            commands::ShutdownInfo* info ) throw ( exceptions::ActiveMQException ) = 0;
+            commands::ShutdownInfo* info ) = 0;
 
         virtual decaf::lang::Pointer<commands::Command> processFlushCommand(
-            commands::FlushCommand* command ) throw ( exceptions::ActiveMQException ) = 0;
+            commands::FlushCommand* command ) = 0;
 
         virtual decaf::lang::Pointer<commands::Command> processBrokerInfo(
-            commands::BrokerInfo* info) throw ( exceptions::ActiveMQException ) = 0;
+            commands::BrokerInfo* info) = 0;
 
         virtual decaf::lang::Pointer<commands::Command> processRecoverTransactions(
-            commands::TransactionInfo* info ) throw ( exceptions::ActiveMQException ) = 0;
+            commands::TransactionInfo* info ) = 0;
 
         virtual decaf::lang::Pointer<commands::Command> processForgetTransaction(
-            commands::TransactionInfo* info ) throw ( exceptions::ActiveMQException ) = 0;
+            commands::TransactionInfo* info ) = 0;
 
         virtual decaf::lang::Pointer<commands::Command> processEndTransaction(
-            commands::TransactionInfo* info ) throw ( exceptions::ActiveMQException ) = 0;
+            commands::TransactionInfo* info ) = 0;
 
         virtual decaf::lang::Pointer<commands::Command> processMessageDispatchNotification(
-            commands::MessageDispatchNotification* notification ) throw ( exceptions::ActiveMQException
) = 0;
+            commands::MessageDispatchNotification* notification ) = 0;
 
         virtual decaf::lang::Pointer<commands::Command> processProducerAck(
-            commands::ProducerAck* ack ) throw ( exceptions::ActiveMQException ) = 0;
+            commands::ProducerAck* ack ) = 0;
 
         virtual decaf::lang::Pointer<commands::Command> processMessageDispatch(
-            commands::MessageDispatch* dispatch ) throw ( exceptions::ActiveMQException )
= 0;
+            commands::MessageDispatch* dispatch ) = 0;
 
         virtual decaf::lang::Pointer<commands::Command> processControlCommand(
-            commands::ControlCommand* command ) throw ( exceptions::ActiveMQException ) =
0;
+            commands::ControlCommand* command ) = 0;
 
         virtual decaf::lang::Pointer<commands::Command> processConnectionError(
-            commands::ConnectionError* error ) throw ( exceptions::ActiveMQException ) =
0;
+            commands::ConnectionError* error ) = 0;
 
         virtual decaf::lang::Pointer<commands::Command> processConnectionControl(
-            commands::ConnectionControl* control ) throw ( exceptions::ActiveMQException
) = 0;
+            commands::ConnectionControl* control ) = 0;
 
         virtual decaf::lang::Pointer<commands::Command> processConsumerControl(
-            commands::ConsumerControl* control ) throw ( exceptions::ActiveMQException )
= 0;
+            commands::ConsumerControl* control ) = 0;
 
         virtual decaf::lang::Pointer<commands::Command> processBrokerError(
-            commands::BrokerError* error ) throw ( exceptions::ActiveMQException ) = 0;
+            commands::BrokerError* error ) = 0;
 
         virtual decaf::lang::Pointer<commands::Command> processReplayCommand(
-            commands::ReplayCommand* replay ) throw ( exceptions::ActiveMQException ) = 0;
+            commands::ReplayCommand* replay ) = 0;
 
         virtual decaf::lang::Pointer<commands::Command> processResponse(
-            commands::Response* response ) throw ( exceptions::ActiveMQException ) = 0;
+            commands::Response* response ) = 0;
 
     };
 

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/state/CommandVisitorAdapter.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/state/CommandVisitorAdapter.h?rev=957012&r1=957011&r2=957012&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/state/CommandVisitorAdapter.h
(original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/state/CommandVisitorAdapter.h
Tue Jun 22 20:17:47 2010
@@ -69,229 +69,229 @@ namespace state {
         virtual ~CommandVisitorAdapter() {}
 
         virtual decaf::lang::Pointer<commands::Command> processRemoveConnection(
-            commands::ConnectionId* id AMQCPP_UNUSED ) throw ( exceptions::ActiveMQException
) {
+            commands::ConnectionId* id AMQCPP_UNUSED ) {
 
             return decaf::lang::Pointer<commands::Command>();
         }
 
         virtual decaf::lang::Pointer<commands::Command> processRemoveSession(
-            commands::SessionId* id AMQCPP_UNUSED ) throw ( exceptions::ActiveMQException
) {
+            commands::SessionId* id AMQCPP_UNUSED ) {
 
             return decaf::lang::Pointer<commands::Command>();
         }
 
         virtual decaf::lang::Pointer<commands::Command> processRemoveProducer(
-            commands::ProducerId* id AMQCPP_UNUSED ) throw ( exceptions::ActiveMQException
) {
+            commands::ProducerId* id AMQCPP_UNUSED ) {
 
             return decaf::lang::Pointer<commands::Command>();
         }
 
         virtual decaf::lang::Pointer<commands::Command> processRemoveConsumer(
-            commands::ConsumerId* id AMQCPP_UNUSED ) throw ( exceptions::ActiveMQException
) {
+            commands::ConsumerId* id AMQCPP_UNUSED ) {
 
             return decaf::lang::Pointer<commands::Command>();
         }
 
         virtual decaf::lang::Pointer<commands::Command> processDestinationInfo(
-            commands::DestinationInfo* info AMQCPP_UNUSED ) throw ( exceptions::ActiveMQException
) {
+            commands::DestinationInfo* info AMQCPP_UNUSED ) {
 
             return decaf::lang::Pointer<commands::Command>();
         }
 
         virtual decaf::lang::Pointer<commands::Command> processRemoveDestination(
-            commands::DestinationInfo* info AMQCPP_UNUSED ) throw ( exceptions::ActiveMQException
) {
+            commands::DestinationInfo* info AMQCPP_UNUSED ) {
 
             return decaf::lang::Pointer<commands::Command>();
         }
 
         virtual decaf::lang::Pointer<commands::Command> processRemoveSubscriptionInfo(
-            commands::RemoveSubscriptionInfo* info AMQCPP_UNUSED ) throw ( exceptions::ActiveMQException
) {
+            commands::RemoveSubscriptionInfo* info AMQCPP_UNUSED ) {
 
             return decaf::lang::Pointer<commands::Command>();
         }
 
         virtual decaf::lang::Pointer<commands::Command> processMessage(
-            commands::Message* send AMQCPP_UNUSED ) throw ( exceptions::ActiveMQException
) {
+            commands::Message* send AMQCPP_UNUSED ) {
 
             return decaf::lang::Pointer<commands::Command>();
         }
 
         virtual decaf::lang::Pointer<commands::Command> processMessageAck(
-            commands::MessageAck* ack AMQCPP_UNUSED ) throw ( exceptions::ActiveMQException
) {
+            commands::MessageAck* ack AMQCPP_UNUSED ) {
 
             return decaf::lang::Pointer<commands::Command>();
         }
 
         virtual decaf::lang::Pointer<commands::Command> processMessagePull(
-            commands::MessagePull* pull AMQCPP_UNUSED ) throw ( exceptions::ActiveMQException
) {
+            commands::MessagePull* pull AMQCPP_UNUSED ) {
 
             return decaf::lang::Pointer<commands::Command>();
         }
 
         virtual decaf::lang::Pointer<commands::Command> processBeginTransaction(
-            commands::TransactionInfo* info AMQCPP_UNUSED ) throw ( exceptions::ActiveMQException
) {
+            commands::TransactionInfo* info AMQCPP_UNUSED ) {
 
             return decaf::lang::Pointer<commands::Command>();
         }
 
         virtual decaf::lang::Pointer<commands::Command> processPrepareTransaction(
-            commands::TransactionInfo* info AMQCPP_UNUSED ) throw ( exceptions::ActiveMQException
) {
+            commands::TransactionInfo* info AMQCPP_UNUSED ) {
 
             return decaf::lang::Pointer<commands::Command>();
         }
 
         virtual decaf::lang::Pointer<commands::Command> processCommitTransactionOnePhase(
-            commands::TransactionInfo* info AMQCPP_UNUSED ) throw ( exceptions::ActiveMQException
) {
+            commands::TransactionInfo* info AMQCPP_UNUSED ) {
 
             return decaf::lang::Pointer<commands::Command>();
         }
 
         virtual decaf::lang::Pointer<commands::Command> processCommitTransactionTwoPhase(
-            commands::TransactionInfo* info AMQCPP_UNUSED ) throw ( exceptions::ActiveMQException
) {
+            commands::TransactionInfo* info AMQCPP_UNUSED ) {
 
             return decaf::lang::Pointer<commands::Command>();
         }
 
         virtual decaf::lang::Pointer<commands::Command> processRollbackTransaction(
-            commands::TransactionInfo* info AMQCPP_UNUSED ) throw ( exceptions::ActiveMQException
) {
+            commands::TransactionInfo* info AMQCPP_UNUSED ) {
 
             return decaf::lang::Pointer<commands::Command>();
         }
 
         virtual decaf::lang::Pointer<commands::Command> processWireFormat(
-            commands::WireFormatInfo* info AMQCPP_UNUSED ) throw ( exceptions::ActiveMQException
) {
+            commands::WireFormatInfo* info AMQCPP_UNUSED ) {
 
             return decaf::lang::Pointer<commands::Command>();
         }
 
         virtual decaf::lang::Pointer<commands::Command> processKeepAliveInfo(
-            commands::KeepAliveInfo* info AMQCPP_UNUSED ) throw ( exceptions::ActiveMQException
) {
+            commands::KeepAliveInfo* info AMQCPP_UNUSED ) {
 
             return decaf::lang::Pointer<commands::Command>();
         }
 
         virtual decaf::lang::Pointer<commands::Command> processShutdownInfo(
-            commands::ShutdownInfo* info AMQCPP_UNUSED ) throw ( exceptions::ActiveMQException
) {
+            commands::ShutdownInfo* info AMQCPP_UNUSED ) {
 
             return decaf::lang::Pointer<commands::Command>();
         }
 
         virtual decaf::lang::Pointer<commands::Command> processFlushCommand(
-            commands::FlushCommand* command AMQCPP_UNUSED ) throw ( exceptions::ActiveMQException
) {
+            commands::FlushCommand* command AMQCPP_UNUSED ) {
 
             return decaf::lang::Pointer<commands::Command>();
         }
 
         virtual decaf::lang::Pointer<commands::Command> processBrokerInfo(
-            commands::BrokerInfo* info AMQCPP_UNUSED ) throw ( exceptions::ActiveMQException
) {
+            commands::BrokerInfo* info AMQCPP_UNUSED ) {
 
             return decaf::lang::Pointer<commands::Command>();
         }
 
         virtual decaf::lang::Pointer<commands::Command> processRecoverTransactions(
-            commands::TransactionInfo* info AMQCPP_UNUSED ) throw ( exceptions::ActiveMQException
) {
+            commands::TransactionInfo* info AMQCPP_UNUSED ) {
 
             return decaf::lang::Pointer<commands::Command>();
         }
 
         virtual decaf::lang::Pointer<commands::Command> processForgetTransaction(
-            commands::TransactionInfo* info AMQCPP_UNUSED ) throw ( exceptions::ActiveMQException
) {
+            commands::TransactionInfo* info AMQCPP_UNUSED ) {
 
             return decaf::lang::Pointer<commands::Command>();
         }
 
         virtual decaf::lang::Pointer<commands::Command> processEndTransaction(
-            commands::TransactionInfo* info AMQCPP_UNUSED ) throw ( exceptions::ActiveMQException
) {
+            commands::TransactionInfo* info AMQCPP_UNUSED ) {
 
             return decaf::lang::Pointer<commands::Command>();
         }
 
         virtual decaf::lang::Pointer<commands::Command> processMessageDispatchNotification(
-            commands::MessageDispatchNotification* notification AMQCPP_UNUSED ) throw ( exceptions::ActiveMQException
) {
+            commands::MessageDispatchNotification* notification AMQCPP_UNUSED ) {
 
             return decaf::lang::Pointer<commands::Command>();
         }
 
         virtual decaf::lang::Pointer<commands::Command> processProducerAck(
-            commands::ProducerAck* ack AMQCPP_UNUSED ) throw ( exceptions::ActiveMQException
) {
+            commands::ProducerAck* ack AMQCPP_UNUSED ) {
 
             return decaf::lang::Pointer<commands::Command>();
         }
 
         virtual decaf::lang::Pointer<commands::Command> processMessageDispatch(
-            commands::MessageDispatch* dispatch AMQCPP_UNUSED ) throw ( exceptions::ActiveMQException
) {
+            commands::MessageDispatch* dispatch AMQCPP_UNUSED ) {
 
             return decaf::lang::Pointer<commands::Command>();
         }
 
         virtual decaf::lang::Pointer<commands::Command> processControlCommand(
-            commands::ControlCommand* command AMQCPP_UNUSED ) throw ( exceptions::ActiveMQException
) {
+            commands::ControlCommand* command AMQCPP_UNUSED ) {
 
             return decaf::lang::Pointer<commands::Command>();
         }
 
         virtual decaf::lang::Pointer<commands::Command> processConnectionError(
-            commands::ConnectionError* error AMQCPP_UNUSED ) throw ( exceptions::ActiveMQException
) {
+            commands::ConnectionError* error AMQCPP_UNUSED ) {
 
             return decaf::lang::Pointer<commands::Command>();
         }
 
         virtual decaf::lang::Pointer<commands::Command> processConnectionControl(
-            commands::ConnectionControl* control AMQCPP_UNUSED ) throw ( exceptions::ActiveMQException
) {
+            commands::ConnectionControl* control AMQCPP_UNUSED ) {
 
             return decaf::lang::Pointer<commands::Command>();
         }
 
         virtual decaf::lang::Pointer<commands::Command> processConsumerControl(
-            commands::ConsumerControl* control AMQCPP_UNUSED ) throw ( exceptions::ActiveMQException
) {
+            commands::ConsumerControl* control AMQCPP_UNUSED ) {
 
             return decaf::lang::Pointer<commands::Command>();
         }
 
         virtual decaf::lang::Pointer<commands::Command> processBrokerError(
-            commands::BrokerError* error AMQCPP_UNUSED ) throw ( exceptions::ActiveMQException
) {
+            commands::BrokerError* error AMQCPP_UNUSED ) {
 
             return decaf::lang::Pointer<commands::Command>();
         }
 
         virtual decaf::lang::Pointer<commands::Command> processReplayCommand(
-            commands::ReplayCommand* replay AMQCPP_UNUSED ) throw ( exceptions::ActiveMQException
) {
+            commands::ReplayCommand* replay AMQCPP_UNUSED ) {
 
             return decaf::lang::Pointer<commands::Command>();
         }
 
         virtual decaf::lang::Pointer<commands::Command> processResponse(
-            commands::Response* response AMQCPP_UNUSED ) throw ( exceptions::ActiveMQException
) {
+            commands::Response* response AMQCPP_UNUSED ) {
 
             return decaf::lang::Pointer<commands::Command>();
         }
 
         virtual decaf::lang::Pointer<commands::Command> processConnectionInfo(
-            commands::ConnectionInfo* info AMQCPP_UNUSED ) throw ( exceptions::ActiveMQException
) {
+            commands::ConnectionInfo* info AMQCPP_UNUSED ) {
 
             return decaf::lang::Pointer<commands::Command>();
         }
 
         virtual decaf::lang::Pointer<commands::Command> processSessionInfo(
-            commands::SessionInfo* info AMQCPP_UNUSED ) throw ( exceptions::ActiveMQException
) {
+            commands::SessionInfo* info AMQCPP_UNUSED ) {
 
             return decaf::lang::Pointer<commands::Command>();
         }
 
         virtual decaf::lang::Pointer<commands::Command> processProducerInfo(
-            commands::ProducerInfo* info AMQCPP_UNUSED ) throw ( exceptions::ActiveMQException
) {
+            commands::ProducerInfo* info AMQCPP_UNUSED ) {
 
             return decaf::lang::Pointer<commands::Command>();
         }
 
         virtual decaf::lang::Pointer<commands::Command> processConsumerInfo(
-            commands::ConsumerInfo* info AMQCPP_UNUSED ) throw ( exceptions::ActiveMQException
) {
+            commands::ConsumerInfo* info AMQCPP_UNUSED ) {
 
             return decaf::lang::Pointer<commands::Command>();
         }
 
         virtual decaf::lang::Pointer<commands::Command> processTransactionInfo(
-            commands::TransactionInfo* info ) throw ( exceptions::ActiveMQException ) {
+            commands::TransactionInfo* info ) {
 
             if( info != decaf::lang::Pointer<commands::Command>() ) {
                 switch( info->getType() ) {
@@ -320,7 +320,7 @@ namespace state {
         }
 
         virtual decaf::lang::Pointer<commands::Command> processRemoveInfo(
-            commands::RemoveInfo* info ) throw ( exceptions::ActiveMQException ) {
+            commands::RemoveInfo* info ) {
 
             if( info != decaf::lang::Pointer<commands::Command>() ) {
                 switch( info->getObjectId()->getDataStructureType() ) {

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/state/ConnectionState.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/state/ConnectionState.h?rev=957012&r1=957011&r2=957012&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/state/ConnectionState.h (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/state/ConnectionState.h Tue
Jun 22 20:17:47 2010
@@ -145,7 +145,7 @@ namespace state {
             return recoveringPullConsumers;
         }
 
-        void setConnectionInterruptProcessingComplete(bool connectionInterruptProcessingComplete)
{
+        void setConnectionInterruptProcessingComplete( bool connectionInterruptProcessingComplete
) {
             this->connectionInterruptProcessingComplete = connectionInterruptProcessingComplete;
         }
 

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/state/ConnectionStateTracker.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/state/ConnectionStateTracker.cpp?rev=957012&r1=957011&r2=957012&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/state/ConnectionStateTracker.cpp
(original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/state/ConnectionStateTracker.cpp
Tue Jun 22 20:17:47 2010
@@ -81,8 +81,7 @@ ConnectionStateTracker::~ConnectionState
 }
 
 ////////////////////////////////////////////////////////////////////////////////
-Pointer<Tracked> ConnectionStateTracker::track( const Pointer<Command>& command
)
-    throw( decaf::io::IOException ) {
+Pointer<Tracked> ConnectionStateTracker::track( const Pointer<Command>& command
) {
 
     try{
 
@@ -116,8 +115,7 @@ void ConnectionStateTracker::trackBack( 
 }
 
 ////////////////////////////////////////////////////////////////////////////////
-void ConnectionStateTracker::restore( const Pointer<transport::Transport>& transport
)
-    throw( decaf::io::IOException ) {
+void ConnectionStateTracker::restore( const Pointer<transport::Transport>& transport
) {
 
     try{
 
@@ -153,8 +151,7 @@ void ConnectionStateTracker::restore( co
 
 ////////////////////////////////////////////////////////////////////////////////
 void ConnectionStateTracker::doRestoreTransactions( const Pointer<transport::Transport>&
transport,
-                                                    const Pointer<ConnectionState>&
connectionState )
-    throw( decaf::io::IOException ) {
+                                                    const Pointer<ConnectionState>&
connectionState ) {
 
     try{
 
@@ -230,8 +227,7 @@ void ConnectionStateTracker::doRestoreTr
 
 ////////////////////////////////////////////////////////////////////////////////
 void ConnectionStateTracker::doRestoreSessions( const Pointer<transport::Transport>&
transport,
-                                                const Pointer<ConnectionState>&
connectionState )
-    throw( decaf::io::IOException ) {
+                                                const Pointer<ConnectionState>&
connectionState ) {
 
     try{
 
@@ -260,8 +256,7 @@ void ConnectionStateTracker::doRestoreSe
 
 ////////////////////////////////////////////////////////////////////////////////
 void ConnectionStateTracker::doRestoreConsumers( const Pointer<transport::Transport>&
transport,
-                                                 const Pointer<SessionState>& sessionState
)
-    throw( decaf::io::IOException ) {
+                                                 const Pointer<SessionState>& sessionState
) {
 
     try{
 
@@ -295,8 +290,7 @@ void ConnectionStateTracker::doRestoreCo
 
 ////////////////////////////////////////////////////////////////////////////////
 void ConnectionStateTracker::doRestoreProducers( const Pointer<transport::Transport>&
transport,
-                                                 const Pointer<SessionState>& sessionState
)
-    throw( decaf::io::IOException ) {
+                                                 const Pointer<SessionState>& sessionState
) {
 
     try{
 
@@ -317,8 +311,7 @@ void ConnectionStateTracker::doRestorePr
 
 ////////////////////////////////////////////////////////////////////////////////
 void ConnectionStateTracker::doRestoreTempDestinations( const Pointer<transport::Transport>&
transport,
-                                                        const Pointer<ConnectionState>&
connectionState )
-    throw( decaf::io::IOException ) {
+                                                        const Pointer<ConnectionState>&
connectionState ) {
 
     try{
 
@@ -335,8 +328,7 @@ void ConnectionStateTracker::doRestoreTe
 }
 
 ////////////////////////////////////////////////////////////////////////////////
-Pointer<Command> ConnectionStateTracker::processDestinationInfo( DestinationInfo* info
)
-    throw ( activemq::exceptions::ActiveMQException ) {
+Pointer<Command> ConnectionStateTracker::processDestinationInfo( DestinationInfo* info
) {
 
     try{
         if( info != NULL ) {
@@ -353,8 +345,7 @@ Pointer<Command> ConnectionStateTracker:
 }
 
 ////////////////////////////////////////////////////////////////////////////////
-Pointer<Command> ConnectionStateTracker::processRemoveDestination( DestinationInfo*
info )
-    throw ( activemq::exceptions::ActiveMQException ) {
+Pointer<Command> ConnectionStateTracker::processRemoveDestination( DestinationInfo*
info ) {
 
     try{
         if( info != NULL ) {
@@ -371,8 +362,7 @@ Pointer<Command> ConnectionStateTracker:
 }
 
 ////////////////////////////////////////////////////////////////////////////////
-Pointer<Command> ConnectionStateTracker::processProducerInfo( ProducerInfo* info )
-    throw ( activemq::exceptions::ActiveMQException ) {
+Pointer<Command> ConnectionStateTracker::processProducerInfo( ProducerInfo* info )
{
 
     try{
 
@@ -400,8 +390,7 @@ Pointer<Command> ConnectionStateTracker:
 }
 
 ////////////////////////////////////////////////////////////////////////////////
-Pointer<Command> ConnectionStateTracker::processRemoveProducer( ProducerId* id )
-    throw ( activemq::exceptions::ActiveMQException ) {
+Pointer<Command> ConnectionStateTracker::processRemoveProducer( ProducerId* id ) {
 
     try{
 
@@ -428,8 +417,7 @@ Pointer<Command> ConnectionStateTracker:
 }
 
 ////////////////////////////////////////////////////////////////////////////////
-Pointer<Command> ConnectionStateTracker::processConsumerInfo( ConsumerInfo* info )
-    throw ( activemq::exceptions::ActiveMQException ) {
+Pointer<Command> ConnectionStateTracker::processConsumerInfo( ConsumerInfo* info )
{
 
     try{
 
@@ -457,8 +445,7 @@ Pointer<Command> ConnectionStateTracker:
 }
 
 ////////////////////////////////////////////////////////////////////////////////
-Pointer<Command> ConnectionStateTracker::processRemoveConsumer( ConsumerId* id )
-    throw ( activemq::exceptions::ActiveMQException ) {
+Pointer<Command> ConnectionStateTracker::processRemoveConsumer( ConsumerId* id ) {
 
     try{
         if( id != NULL ) {
@@ -484,8 +471,7 @@ Pointer<Command> ConnectionStateTracker:
 }
 
 ////////////////////////////////////////////////////////////////////////////////
-Pointer<Command> ConnectionStateTracker::processSessionInfo( SessionInfo* info)
-    throw ( activemq::exceptions::ActiveMQException ) {
+Pointer<Command> ConnectionStateTracker::processSessionInfo( SessionInfo* info ) {
 
     try{
 
@@ -506,8 +492,7 @@ Pointer<Command> ConnectionStateTracker:
 }
 
 ////////////////////////////////////////////////////////////////////////////////
-Pointer<Command> ConnectionStateTracker::processRemoveSession( SessionId* id)
-    throw ( activemq::exceptions::ActiveMQException ) {
+Pointer<Command> ConnectionStateTracker::processRemoveSession( SessionId* id ) {
 
     try{
 
@@ -528,8 +513,7 @@ Pointer<Command> ConnectionStateTracker:
 }
 
 ////////////////////////////////////////////////////////////////////////////////
-Pointer<Command> ConnectionStateTracker::processConnectionInfo( ConnectionInfo* info
)
-    throw ( activemq::exceptions::ActiveMQException ) {
+Pointer<Command> ConnectionStateTracker::processConnectionInfo( ConnectionInfo* info
) {
 
     try{
 
@@ -546,8 +530,7 @@ Pointer<Command> ConnectionStateTracker:
 }
 
 ////////////////////////////////////////////////////////////////////////////////
-Pointer<Command> ConnectionStateTracker::processRemoveConnection( ConnectionId* id
)
-    throw ( activemq::exceptions::ActiveMQException ) {
+Pointer<Command> ConnectionStateTracker::processRemoveConnection( ConnectionId* id
) {
 
     try{
 
@@ -563,8 +546,7 @@ Pointer<Command> ConnectionStateTracker:
 }
 
 ////////////////////////////////////////////////////////////////////////////////
-Pointer<Command> ConnectionStateTracker::processMessage( Message* message )
-    throw ( activemq::exceptions::ActiveMQException ) {
+Pointer<Command> ConnectionStateTracker::processMessage( Message* message ) {
 
     try{
 
@@ -605,8 +587,7 @@ Pointer<Command> ConnectionStateTracker:
 }
 
 ////////////////////////////////////////////////////////////////////////////////
-Pointer<Command> ConnectionStateTracker::processMessageAck( MessageAck* ack )
-    throw ( activemq::exceptions::ActiveMQException ) {
+Pointer<Command> ConnectionStateTracker::processMessageAck( MessageAck* ack ) {
 
     try{
 
@@ -634,8 +615,7 @@ Pointer<Command> ConnectionStateTracker:
 }
 
 ////////////////////////////////////////////////////////////////////////////////
-Pointer<Command> ConnectionStateTracker::processBeginTransaction( TransactionInfo*
info )
-    throw ( activemq::exceptions::ActiveMQException ) {
+Pointer<Command> ConnectionStateTracker::processBeginTransaction( TransactionInfo*
info ) {
 
     try{
 
@@ -663,8 +643,7 @@ Pointer<Command> ConnectionStateTracker:
 }
 
 ////////////////////////////////////////////////////////////////////////////////
-Pointer<Command> ConnectionStateTracker::processPrepareTransaction( TransactionInfo*
info )
-    throw ( activemq::exceptions::ActiveMQException ) {
+Pointer<Command> ConnectionStateTracker::processPrepareTransaction( TransactionInfo*
info ) {
 
     try{
 
@@ -693,8 +672,7 @@ Pointer<Command> ConnectionStateTracker:
 }
 
 ////////////////////////////////////////////////////////////////////////////////
-Pointer<Command> ConnectionStateTracker::processCommitTransactionOnePhase( TransactionInfo*
info )
-    throw ( activemq::exceptions::ActiveMQException ) {
+Pointer<Command> ConnectionStateTracker::processCommitTransactionOnePhase( TransactionInfo*
info ) {
 
     try{
 
@@ -724,8 +702,7 @@ Pointer<Command> ConnectionStateTracker:
 }
 
 ////////////////////////////////////////////////////////////////////////////////
-Pointer<Command> ConnectionStateTracker::processCommitTransactionTwoPhase( TransactionInfo*
info )
-    throw ( activemq::exceptions::ActiveMQException ) {
+Pointer<Command> ConnectionStateTracker::processCommitTransactionTwoPhase( TransactionInfo*
info ) {
 
     try{
 
@@ -755,8 +732,7 @@ Pointer<Command> ConnectionStateTracker:
 }
 
 ////////////////////////////////////////////////////////////////////////////////
-Pointer<Command> ConnectionStateTracker::processRollbackTransaction( TransactionInfo*
info )
-    throw ( activemq::exceptions::ActiveMQException ) {
+Pointer<Command> ConnectionStateTracker::processRollbackTransaction( TransactionInfo*
info ) {
 
     try{
 
@@ -786,8 +762,7 @@ Pointer<Command> ConnectionStateTracker:
 }
 
 ////////////////////////////////////////////////////////////////////////////////
-Pointer<Command> ConnectionStateTracker::processEndTransaction( TransactionInfo* info
)
-    throw ( activemq::exceptions::ActiveMQException ) {
+Pointer<Command> ConnectionStateTracker::processEndTransaction( TransactionInfo* info
) {
 
     try{
 

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/state/ConnectionStateTracker.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/state/ConnectionStateTracker.h?rev=957012&r1=957011&r2=957012&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/state/ConnectionStateTracker.h
(original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/state/ConnectionStateTracker.h
Tue Jun 22 20:17:47 2010
@@ -75,71 +75,52 @@ namespace state {
 
         virtual ~ConnectionStateTracker();
 
-        Pointer<Tracked> track( const Pointer<Command>& command ) throw(
decaf::io::IOException );
+        Pointer<Tracked> track( const Pointer<Command>& command );
 
         void trackBack( const Pointer<Command>& command );
 
-        void restore( const Pointer<transport::Transport>& transport )
-            throw( decaf::io::IOException );
+        void restore( const Pointer<transport::Transport>& transport );
 
         void connectionInterruptProcessingComplete(
             transport::Transport* transport, const Pointer<ConnectionId>& connectionId
);
 
         void transportInterrupted();
 
-        virtual Pointer<Command> processDestinationInfo( DestinationInfo* info )
-            throw ( exceptions::ActiveMQException );
+        virtual Pointer<Command> processDestinationInfo( DestinationInfo* info );
 
-        virtual Pointer<Command> processRemoveDestination( DestinationInfo* info )
-            throw ( exceptions::ActiveMQException );
+        virtual Pointer<Command> processRemoveDestination( DestinationInfo* info );
 
-        virtual Pointer<Command> processProducerInfo( ProducerInfo* info )
-            throw ( exceptions::ActiveMQException );
+        virtual Pointer<Command> processProducerInfo( ProducerInfo* info );
 
-        virtual Pointer<Command> processRemoveProducer( ProducerId* id )
-            throw ( exceptions::ActiveMQException );
+        virtual Pointer<Command> processRemoveProducer( ProducerId* id );
 
-        virtual Pointer<Command> processConsumerInfo( ConsumerInfo* info )
-            throw ( exceptions::ActiveMQException );
+        virtual Pointer<Command> processConsumerInfo( ConsumerInfo* info );
 
-        virtual Pointer<Command> processRemoveConsumer( ConsumerId* id )
-            throw ( exceptions::ActiveMQException );
+        virtual Pointer<Command> processRemoveConsumer( ConsumerId* id );
 
-        virtual Pointer<Command> processSessionInfo( SessionInfo* info )
-            throw ( exceptions::ActiveMQException );
+        virtual Pointer<Command> processSessionInfo( SessionInfo* info );
 
-        virtual Pointer<Command> processRemoveSession( SessionId* id )
-            throw ( exceptions::ActiveMQException );
+        virtual Pointer<Command> processRemoveSession( SessionId* id );
 
-        virtual Pointer<Command> processConnectionInfo( ConnectionInfo* info)
-            throw ( exceptions::ActiveMQException );
+        virtual Pointer<Command> processConnectionInfo( ConnectionInfo* info );
 
-        virtual Pointer<Command> processRemoveConnection( ConnectionId* id )
-            throw ( exceptions::ActiveMQException );
+        virtual Pointer<Command> processRemoveConnection( ConnectionId* id );
 
-        virtual Pointer<Command> processMessage( Message* message )
-            throw ( exceptions::ActiveMQException );
+        virtual Pointer<Command> processMessage( Message* message );
 
-        virtual Pointer<Command> processMessageAck( MessageAck* ack )
-            throw ( exceptions::ActiveMQException );
+        virtual Pointer<Command> processMessageAck( MessageAck* ack );
 
-        virtual Pointer<Command> processBeginTransaction( TransactionInfo* info )
-            throw ( exceptions::ActiveMQException );
+        virtual Pointer<Command> processBeginTransaction( TransactionInfo* info );
 
-        virtual Pointer<Command> processPrepareTransaction( TransactionInfo* info )
-            throw ( exceptions::ActiveMQException );
+        virtual Pointer<Command> processPrepareTransaction( TransactionInfo* info );
 
-        virtual Pointer<Command> processCommitTransactionOnePhase( TransactionInfo*
info )
-            throw ( exceptions::ActiveMQException );
+        virtual Pointer<Command> processCommitTransactionOnePhase( TransactionInfo*
info );
 
-        virtual Pointer<Command> processCommitTransactionTwoPhase( TransactionInfo*
info )
-            throw ( exceptions::ActiveMQException );
+        virtual Pointer<Command> processCommitTransactionTwoPhase( TransactionInfo*
info );
 
-        virtual Pointer<Command> processRollbackTransaction( TransactionInfo* info
)
-            throw ( exceptions::ActiveMQException );
+        virtual Pointer<Command> processRollbackTransaction( TransactionInfo* info
);
 
-        virtual Pointer<Command> processEndTransaction( TransactionInfo* info )
-            throw ( exceptions::ActiveMQException );
+        virtual Pointer<Command> processEndTransaction( TransactionInfo* info );
 
         bool isRestoreConsumers() const {
             return this->restoreConsumers;
@@ -208,24 +189,19 @@ namespace state {
     private:
 
         void doRestoreTransactions( const Pointer<transport::Transport>& transport,
-                                    const Pointer<ConnectionState>& connectionState
)
-            throw( decaf::io::IOException );
+                                    const Pointer<ConnectionState>& connectionState
);
 
         void doRestoreSessions( const Pointer<transport::Transport>& transport,
-                                const Pointer<ConnectionState>& connectionState
)
-            throw( decaf::io::IOException );
+                                const Pointer<ConnectionState>& connectionState
);
 
         void doRestoreConsumers( const Pointer<transport::Transport>& transport,
-                                 const Pointer<SessionState>& sessionState )
-            throw( decaf::io::IOException );
+                                 const Pointer<SessionState>& sessionState );
 
         void doRestoreProducers( const Pointer<transport::Transport>& transport,
-                                 const Pointer<SessionState>& sessionState )
-            throw( decaf::io::IOException );
+                                 const Pointer<SessionState>& sessionState );
 
         void doRestoreTempDestinations( const Pointer<transport::Transport>& transport,
-                                        const Pointer<ConnectionState>& connectionState
)
-            throw( decaf::io::IOException );
+                                        const Pointer<ConnectionState>& connectionState
);
 
     };
 



Mime
View raw message