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 2013/01/15 22:18:53 UTC
svn commit: r1433654 - in
/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport:
TransportFilter.cpp inactivity/InactivityMonitor.cpp tcp/TcpTransport.cpp
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) {