Author: tabish
Date: Wed Mar 4 16:24:46 2009
New Revision: 750064
URL: http://svn.apache.org/viewvc?rev=750064&view=rev
Log:
http://issues.apache.org/activemq/browse/AMQCPP-100
Fix some breakage in the tests
Modified:
activemq/activemq-cpp/trunk/src/test/activemq/transport/correlator/ResponseCorrelatorTest.cpp
Modified:
activemq/activemq-cpp/trunk/src/test/activemq/transport/correlator/ResponseCorrelatorTest.cpp
URL:
http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/test/activemq/transport/correlator/ResponseCorrelatorTest.cpp?rev=750064&r1=750063&r2=750064&view=diff
==============================================================================
---
activemq/activemq-cpp/trunk/src/test/activemq/transport/correlator/ResponseCorrelatorTest.cpp
(original)
+++
activemq/activemq-cpp/trunk/src/test/activemq/transport/correlator/ResponseCorrelatorTest.cpp
Wed Mar 4 16:24:46 2009
@@ -230,7 +230,7 @@
MyBrokenTransport(){}
virtual ~MyBrokenTransport(){}
- virtual commands::Response* createResponse(commands:: Command* command
AMQCPP_UNUSED){
+ virtual Pointer<Response> createResponse( const Pointer<Command>&
command ){
throw exceptions::ActiveMQException( __FILE__, __LINE__,
"bad stuff" );
}
@@ -249,7 +249,7 @@
exCount = 0;
}
virtual ~MyListener(){}
- virtual void onCommand( commands::Command* command ){
+ virtual void onCommand( const Pointer<Command>& command ){
synchronized( &mutex ){
commands.insert( command->getCommandId() );
@@ -498,7 +498,7 @@
Pointer<MyTransport> transport( new MyTransport() );
ResponseCorrelator correlator( transport );
- Transport* narrowed = correlator.narrow( typeid( transport ) );
+ Transport* narrowed = correlator.narrow( typeid( *transport ) );
CPPUNIT_ASSERT( narrowed == transport );
narrowed = correlator.narrow( typeid( std::string() ) );