activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject svn commit: r1433654 - in /activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport: TransportFilter.cpp inactivity/InactivityMonitor.cpp tcp/TcpTransport.cpp
Date Tue, 15 Jan 2013 21:18:53 GMT
Author: tabish
Date: Tue Jan 15 21:18:52 2013
New Revision: 1433654

URL: http://svn.apache.org/viewvc?rev=1433654&view=rev
Log:
https://issues.apache.org/jira/browse/AMQCPP-422

Modified:
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/TransportFilter.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/inactivity/InactivityMonitor.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/tcp/TcpTransport.cpp

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/TransportFilter.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/TransportFilter.cpp?rev=1433654&r1=1433653&r2=1433654&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/TransportFilter.cpp
(original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/TransportFilter.cpp
Tue Jan 15 21:18:52 2013
@@ -106,6 +106,7 @@ void TransportFilter::stop() {
 void TransportFilter::close() {
 
     if (next != NULL) {
+        next->setTransportListener(NULL);
         next->close();
         next.reset(NULL);
     }

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/inactivity/InactivityMonitor.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/inactivity/InactivityMonitor.cpp?rev=1433654&r1=1433653&r2=1433654&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/inactivity/InactivityMonitor.cpp
(original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/inactivity/InactivityMonitor.cpp
Tue Jan 15 21:18:52 2013
@@ -294,6 +294,7 @@ void InactivityMonitor::setKeepAliveResp
 ////////////////////////////////////////////////////////////////////////////////
 void InactivityMonitor::close() {
     try {
+        setTransportListener(NULL);
         stopMonitorThreads();
         TransportFilter::close();
     }

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/tcp/TcpTransport.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/tcp/TcpTransport.cpp?rev=1433654&r1=1433653&r2=1433654&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/tcp/TcpTransport.cpp
(original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/tcp/TcpTransport.cpp
Tue Jan 15 21:18:52 2013
@@ -60,6 +60,7 @@ void TcpTransport::close() {
     try {
 
         this->closed = true;
+        this->setTransportListener(NULL);
 
         // Close the socket.
         if (socket.get() != NULL) {



Mime
View raw message