activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject svn commit: r553199 - /activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/OpenWireConnector.cpp
Date Wed, 04 Jul 2007 13:14:45 GMT
Author: tabish
Date: Wed Jul  4 06:14:44 2007
New Revision: 553199

URL: http://svn.apache.org/viewvc?view=rev&rev=553199
Log:
minor code cleanup

Modified:
    activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/OpenWireConnector.cpp

Modified: activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/OpenWireConnector.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/OpenWireConnector.cpp?view=diff&rev=553199&r1=553198&r2=553199
==============================================================================
--- activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/OpenWireConnector.cpp
(original)
+++ activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/OpenWireConnector.cpp
Wed Jul  4 06:14:44 2007
@@ -302,16 +302,13 @@
 
     } catch( ConnectorException& ex ){
         try{ transport->close(); } catch( ... ){}
-
         ex.setMark(__FILE__,__LINE__);
         throw ex;
     } catch( ... ) {
         try{ transport->close(); } catch( ... ){}
-
         throw OpenWireConnectorException(__FILE__, __LINE__,
             "Caught unknown exception" );
     }
-
 }
 
 ////////////////////////////////////////////////////////////////////////////////
@@ -762,7 +759,6 @@
 
         throw OpenWireConnectorException( __FILE__, __LINE__,
             ex.what() );
-
     } catch( ... ) {
         delete producer;
         delete producerInfo;
@@ -1036,7 +1032,6 @@
         ex.setMark(__FILE__,__LINE__);
         throw ex;
     } catch( ... ) {
-
         try{ transport->close(); } catch( ... ){}
 
         throw OpenWireConnectorException( __FILE__, __LINE__,
@@ -1081,7 +1076,6 @@
         ex.setMark(__FILE__,__LINE__);
         throw ex;
     } catch( ... ) {
-
         try{ transport->close(); } catch( ... ){}
 
         throw OpenWireConnectorException( __FILE__, __LINE__,
@@ -1119,7 +1113,6 @@
         ex.setMark(__FILE__,__LINE__);
         throw ex;
     } catch( ... ) {
-
         try{ transport->close(); } catch( ... ){}
 
         throw OpenWireConnectorException( __FILE__, __LINE__,
@@ -1157,7 +1150,6 @@
         ex.setMark(__FILE__,__LINE__);
         throw ex;
     } catch( ... ) {
-
         try{ transport->close(); } catch( ... ){}
 
         throw OpenWireConnectorException( __FILE__, __LINE__,
@@ -1171,8 +1163,7 @@
     TransactionInfo* transaction AMQCPP_UNUSED )
         throw ( ConnectorException )
 {
-    try
-    {
+    try {
         return new commands::ActiveMQMessage();
     }
     AMQ_CATCH_RETHROW( ConnectorException )
@@ -1185,8 +1176,7 @@
     TransactionInfo* transaction AMQCPP_UNUSED )
         throw ( ConnectorException )
 {
-    try
-    {
+    try {
         return new commands::ActiveMQBytesMessage();
     }
     AMQ_CATCH_RETHROW( ConnectorException )
@@ -1199,8 +1189,7 @@
     TransactionInfo* transaction AMQCPP_UNUSED )
         throw ( ConnectorException )
 {
-    try
-    {
+    try {
         return new commands::ActiveMQTextMessage();
     }
     AMQ_CATCH_RETHROW( ConnectorException )
@@ -1213,8 +1202,7 @@
     TransactionInfo* transaction AMQCPP_UNUSED )
         throw ( ConnectorException, UnsupportedOperationException )
 {
-    try
-    {
+    try {
         return new commands::ActiveMQMapMessage();
     }
     AMQ_CATCH_RETHROW( ConnectorException )
@@ -1227,8 +1215,8 @@
 {
     commands::RemoveSubscriptionInfo* rsi = NULL;
 
-    try
-    {
+    try {
+
         enforceConnected();
 
         rsi = new commands::RemoveSubscriptionInfo();
@@ -1261,8 +1249,8 @@
 void OpenWireConnector::closeResource( ConnectorResource* resource )
     throw ( ConnectorException )
 {
-    try
-    {
+    try {
+
         if( resource == NULL ) {
             return;
         }
@@ -1430,8 +1418,7 @@
 void OpenWireConnector::oneway( Command* command )
     throw ( ConnectorException )
 {
-    try
-    {
+    try {
         transport->oneway(command);
     }
     AMQ_CATCH_EXCEPTION_CONVERT( CommandIOException, OpenWireConnectorException )



Mime
View raw message