activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject svn commit: r1446240 - /activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/core/ActiveMQConnection.cpp
Date Thu, 14 Feb 2013 15:35:08 GMT
Author: tabish
Date: Thu Feb 14 15:35:08 2013
New Revision: 1446240

URL: http://svn.apache.org/r1446240
Log:
additional fixes for: https://issues.apache.org/jira/browse/AMQCPP-460

Modified:
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/core/ActiveMQConnection.cpp

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/core/ActiveMQConnection.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/core/ActiveMQConnection.cpp?rev=1446240&r1=1446239&r2=1446240&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/core/ActiveMQConnection.cpp
(original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/core/ActiveMQConnection.cpp
Thu Feb 14 15:35:08 2013
@@ -320,7 +320,7 @@ namespace core{
 
     public:
 
-        OnAsyncExceptionRunnable(ActiveMQConnection* connection, Exception ex) :
+        OnAsyncExceptionRunnable(ActiveMQConnection* connection, const Exception& ex)
:
             Runnable(), connection(connection), ex(ex) {}
         virtual ~OnAsyncExceptionRunnable() {}
 
@@ -386,8 +386,8 @@ namespace core{
                     Pointer< Iterator<TransportListener*> > iter( this->config->transportListeners.iterator()
);
 
                     while (iter->hasNext()) {
-                        try{
-                            iter->next()->onException(error);
+                        try {
+                            iter->next()->onException(*error);
                         } catch(...) {}
                     }
                 }
@@ -648,7 +648,8 @@ void ActiveMQConnection::close() {
                 this->stop();
             } catch (cms::CMSException& error) {
                 if (!hasException) {
-                    ex = Exception(new CMSException(error));
+//                    ex = Exception(new CMSException(error)); // TODO
+                    ex = Exception();
                     ex.setMark(__FILE__, __LINE__);
                     hasException = true;
                 }
@@ -713,7 +714,8 @@ void ActiveMQConnection::close() {
             }
         } catch (cms::CMSException& error) {
             if (!hasException) {
-                ex = Exception(new CMSException(error));
+//                ex = Exception(new CMSException(error));  TODO
+                ex = Exception();
                 ex.setMark(__FILE__, __LINE__);
                 hasException = true;
             }



Mime
View raw message