You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by nm...@apache.org on 2007/02/12 22:57:59 UTC
svn commit: r506685 - in
/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire:
OpenWireFormat.cpp OpenWireFormatNegotiator.cpp
Author: nmittler
Date: Mon Feb 12 13:57:59 2007
New Revision: 506685
URL: http://svn.apache.org/viewvc?view=rev&rev=506685
Log:
[AMQCPP-30] Fixed memory leak in OpenWireCommandReader/Writer
Modified:
activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenWireFormat.cpp
activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenWireFormatNegotiator.cpp
Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenWireFormat.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenWireFormat.cpp?view=diff&rev=506685&r1=506684&r2=506685
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenWireFormat.cpp (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenWireFormat.cpp Mon Feb 12 13:57:59 2007
@@ -29,7 +29,6 @@
#include <activemq/connector/openwire/marshal/MarshalAware.h>
#include <activemq/connector/openwire/marshal/DataStreamMarshaller.h>
#include <activemq/connector/openwire/marshal/v2/MarshallerFactory.h>
-#include <iostream>
using namespace std;
using namespace activemq;
@@ -200,9 +199,6 @@
throw ( io::IOException ) {
try{
-
- cout << "OpenWireFormat::unmarshal()" << endl;
- cout.flush();
if( !sizePrefixDisabled ) {
dis->readInt();
Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenWireFormatNegotiator.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenWireFormatNegotiator.cpp?view=diff&rev=506685&r1=506684&r2=506685
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenWireFormatNegotiator.cpp (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenWireFormatNegotiator.cpp Mon Feb 12 13:57:59 2007
@@ -19,7 +19,6 @@
#include <activemq/connector/openwire/commands/DataStructure.h>
#include <activemq/connector/openwire/commands/WireFormatInfo.h>
-#include <iostream>
using namespace std;
using namespace activemq;
@@ -82,9 +81,6 @@
////////////////////////////////////////////////////////////////////////////////
void OpenWireFormatNegotiator::onCommand( Command* command ) {
-
- cout << "OpenWireFormatNegotiator::onCommand" << endl;
- cout.flush();
DataStructure* dataStructure =
dynamic_cast<DataStructure*>( command );
@@ -182,9 +178,6 @@
// Mark the latch
wireInfoSentDownLatch.countDown();
-
- cout << "leaving OpenWireFormatNegotiator::start first time logic" << endl;
- cout.flush();
} catch( ActiveMQException& ex ) {