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 2010/06/22 22:17:47 UTC
svn commit: r957012 - in
/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/state:
CommandVisitor.h CommandVisitorAdapter.h ConnectionState.h
ConnectionStateTracker.cpp ConnectionStateTracker.h
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 );
};