activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject svn commit: r593309 [8/8] - in /activemq/activemq-cpp/trunk/src: examples/ examples/consumers/ examples/producers/ main/ main/activemq/concurrent/ main/activemq/connector/ main/activemq/connector/openwire/ main/activemq/connector/openwire/marshal/ main...
Date Thu, 08 Nov 2007 21:02:22 GMT
Modified: activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/utils/BooleanStreamTest.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/utils/BooleanStreamTest.cpp?rev=593309&r1=593308&r2=593309&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/utils/BooleanStreamTest.cpp
(original)
+++ activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/utils/BooleanStreamTest.cpp
Thu Nov  8 13:02:02 2007
@@ -20,10 +20,10 @@
 CPPUNIT_TEST_SUITE_REGISTRATION( activemq::connector::openwire::utils::BooleanStreamTest
);
 
 #include <activemq/connector/openwire/utils/BooleanStream.h>
-#include <activemq/io/ByteArrayOutputStream.h>
-#include <activemq/io/ByteArrayInputStream.h>
-#include <activemq/io/DataOutputStream.h>
-#include <activemq/io/DataInputStream.h>
+#include <decaf/io/ByteArrayOutputStream.h>
+#include <decaf/io/ByteArrayInputStream.h>
+#include <decaf/io/DataOutputStream.h>
+#include <decaf/io/DataInputStream.h>
 
 using namespace activemq;
 using namespace activemq::io;

Modified: activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/utils/OpenwireStringSupportTest.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/utils/OpenwireStringSupportTest.cpp?rev=593309&r1=593308&r2=593309&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/utils/OpenwireStringSupportTest.cpp
(original)
+++ activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/utils/OpenwireStringSupportTest.cpp
Thu Nov  8 13:02:02 2007
@@ -21,10 +21,10 @@
 
 #include <activemq/connector/openwire/utils/OpenwireStringSupport.h>
 
-#include <activemq/io/ByteArrayInputStream.h>
-#include <activemq/io/ByteArrayOutputStream.h>
-#include <activemq/io/DataInputStream.h>
-#include <activemq/io/DataOutputStream.h>
+#include <decaf/io/ByteArrayInputStream.h>
+#include <decaf/io/ByteArrayOutputStream.h>
+#include <decaf/io/DataInputStream.h>
+#include <decaf/io/DataOutputStream.h>
 
 using namespace std;
 using namespace activemq;

Modified: activemq/activemq-cpp/trunk/src/test/activemq/connector/stomp/StompCommandReaderTest.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/test/activemq/connector/stomp/StompCommandReaderTest.h?rev=593309&r1=593308&r2=593309&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/src/test/activemq/connector/stomp/StompCommandReaderTest.h
(original)
+++ activemq/activemq-cpp/trunk/src/test/activemq/connector/stomp/StompCommandReaderTest.h
Thu Nov  8 13:02:02 2007
@@ -27,7 +27,7 @@
 #include <activemq/connector/stomp/commands/TextMessageCommand.h>
 #include <activemq/connector/stomp/commands/BytesMessageCommand.h>
 
-#include <activemq/io/ByteArrayInputStream.h>
+#include <decaf/io/ByteArrayInputStream.h>
 
 namespace activemq{
 namespace connector{

Modified: activemq/activemq-cpp/trunk/src/test/activemq/connector/stomp/StompCommandWriterTest.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/test/activemq/connector/stomp/StompCommandWriterTest.h?rev=593309&r1=593308&r2=593309&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/src/test/activemq/connector/stomp/StompCommandWriterTest.h
(original)
+++ activemq/activemq-cpp/trunk/src/test/activemq/connector/stomp/StompCommandWriterTest.h
Thu Nov  8 13:02:02 2007
@@ -30,8 +30,8 @@
 #include <activemq/connector/stomp/StompTopic.h>
 #include <activemq/connector/stomp/commands/CommandConstants.h>
 
-#include <activemq/io/ByteArrayOutputStream.h>
-#include <activemq/io/ByteArrayInputStream.h>
+#include <decaf/io/ByteArrayOutputStream.h>
+#include <decaf/io/ByteArrayInputStream.h>
 #include <algorithm>
 #include <string.h>
 

Modified: activemq/activemq-cpp/trunk/src/test/activemq/connector/stomp/StompConnectorTest.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/test/activemq/connector/stomp/StompConnectorTest.h?rev=593309&r1=593308&r2=593309&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/src/test/activemq/connector/stomp/StompConnectorTest.h (original)
+++ activemq/activemq-cpp/trunk/src/test/activemq/connector/stomp/StompConnectorTest.h Thu
Nov  8 13:02:02 2007
@@ -32,7 +32,7 @@
 #include <activemq/transport/MockTransport.h>
 #include <activemq/util/Config.h>
 
-#include <activemq/io/ByteArrayOutputStream.h>
+#include <decaf/io/ByteArrayOutputStream.h>
 #include <algorithm>
 
 namespace activemq{

Modified: activemq/activemq-cpp/trunk/src/test/activemq/core/ActiveMQConnectionFactoryTest.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/test/activemq/core/ActiveMQConnectionFactoryTest.cpp?rev=593309&r1=593308&r2=593309&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/src/test/activemq/core/ActiveMQConnectionFactoryTest.cpp (original)
+++ activemq/activemq-cpp/trunk/src/test/activemq/core/ActiveMQConnectionFactoryTest.cpp Thu
Nov  8 13:02:02 2007
@@ -19,9 +19,9 @@
 
 CPPUNIT_TEST_SUITE_REGISTRATION( activemq::core::ActiveMQConnectionFactoryTest );
 
-#include <activemq/concurrent/Concurrent.h>
-#include <activemq/concurrent/Mutex.h>
-#include <activemq/concurrent/Thread.h>
+#include <decaf/util/concurrent/Concurrent.h>
+#include <decaf/util/concurrent/Mutex.h>
+#include <decaf/lang/Thread.h>
 #include <activemq/core/ActiveMQConnectionFactory.h>
 #include <activemq/core/ActiveMQConnection.h>
 #include <cms/Connection.h>

Modified: activemq/activemq-cpp/trunk/src/test/activemq/core/ActiveMQConnectionTest.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/test/activemq/core/ActiveMQConnectionTest.cpp?rev=593309&r1=593308&r2=593309&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/src/test/activemq/core/ActiveMQConnectionTest.cpp (original)
+++ activemq/activemq-cpp/trunk/src/test/activemq/core/ActiveMQConnectionTest.cpp Thu Nov
 8 13:02:02 2007
@@ -19,16 +19,16 @@
 
 CPPUNIT_TEST_SUITE_REGISTRATION( activemq::core::ActiveMQConnectionTest );
 
-#include <activemq/concurrent/Concurrent.h>
-#include <activemq/concurrent/Mutex.h>
-#include <activemq/concurrent/Thread.h>
+#include <decaf/util/concurrent/Concurrent.h>
+#include <decaf/util/concurrent/Mutex.h>
+#include <decaf/lang/Thread.h>
 #include <activemq/core/ActiveMQConnectionFactory.h>
 #include <activemq/transport/MockTransport.h>
 #include <activemq/core/ActiveMQConnection.h>
 #include <activemq/core/ActiveMQConnectionData.h>
 #include <activemq/connector/stomp/StompConnector.h>
 #include <activemq/connector/openwire/OpenWireConnector.h>
-#include <activemq/util/Properties.h>
+#include <decaf/util/Properties.h>
 #include <activemq/transport/MockTransportFactory.h>
 #include <activemq/transport/TransportFactoryMap.h>
 #include <activemq/connector/stomp/StompConsumerInfo.h>

Modified: activemq/activemq-cpp/trunk/src/test/activemq/core/ActiveMQSessionTest.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/test/activemq/core/ActiveMQSessionTest.cpp?rev=593309&r1=593308&r2=593309&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/src/test/activemq/core/ActiveMQSessionTest.cpp (original)
+++ activemq/activemq-cpp/trunk/src/test/activemq/core/ActiveMQSessionTest.cpp Thu Nov  8
13:02:02 2007
@@ -19,7 +19,7 @@
 
 CPPUNIT_TEST_SUITE_REGISTRATION( activemq::core::ActiveMQSessionTest );
 
-#include <activemq/concurrent/Thread.h>
+#include <decaf/lang/Thread.h>
 #include <activemq/transport/MockTransportFactory.h>
 #include <activemq/transport/TransportFactoryMap.h>
 #include <activemq/transport/TransportFactoryMapRegistrar.h>
@@ -31,15 +31,15 @@
 #include <activemq/connector/stomp/StompSessionInfo.h>
 #include <activemq/connector/stomp/StompTopic.h>
 #include <activemq/connector/stomp/commands/TextMessageCommand.h>
-#include <activemq/network/Socket.h>
+#include <decaf/net/Socket.h>
 #include <activemq/network/ServerSocket.h>
 #include <activemq/core/ActiveMQConnectionFactory.h>
 #include <activemq/core/ActiveMQConnectionData.h>
 #include <activemq/core/ActiveMQSession.h>
 #include <activemq/core/ActiveMQConsumer.h>
 #include <activemq/core/ActiveMQProducer.h>
-#include <activemq/util/Properties.h>
-#include <activemq/util/Date.h>
+#include <decaf/util/Properties.h>
+#include <decaf/util/Date.h>
 #include <activemq/connector/ConsumerMessageListener.h>
 
 using namespace std;

Modified: activemq/activemq-cpp/trunk/src/test/activemq/core/ActiveMQSessionTest.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/test/activemq/core/ActiveMQSessionTest.h?rev=593309&r1=593308&r2=593309&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/src/test/activemq/core/ActiveMQSessionTest.h (original)
+++ activemq/activemq-cpp/trunk/src/test/activemq/core/ActiveMQSessionTest.h Thu Nov  8 13:02:02
2007
@@ -24,8 +24,8 @@
 #include <cms/Connection.h>
 #include <cms/MessageListener.h>
 
-#include <activemq/concurrent/Concurrent.h>
-#include <activemq/concurrent/Mutex.h>
+#include <decaf/util/concurrent/Concurrent.h>
+#include <decaf/util/concurrent/Mutex.h>
 #include <activemq/core/ActiveMQConnection.h>
 #include <activemq/transport/MockTransport.h>
 #include <activemq/util/Config.h>

Modified: activemq/activemq-cpp/trunk/src/test/activemq/transport/IOTransportTest.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/test/activemq/transport/IOTransportTest.h?rev=593309&r1=593308&r2=593309&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/src/test/activemq/transport/IOTransportTest.h (original)
+++ activemq/activemq-cpp/trunk/src/test/activemq/transport/IOTransportTest.h Thu Nov  8 13:02:02
2007
@@ -27,11 +27,11 @@
 #include <activemq/transport/CommandWriter.h>
 #include <activemq/transport/Command.h>
 #include <activemq/transport/TransportExceptionListener.h>
-#include <activemq/concurrent/Concurrent.h>
+#include <decaf/util/concurrent/Concurrent.h>
 #include <activemq/io/BlockingByteArrayInputStream.h>
-#include <activemq/io/ByteArrayOutputStream.h>
-#include <activemq/concurrent/Thread.h>
-#include <activemq/concurrent/Mutex.h>
+#include <decaf/io/ByteArrayOutputStream.h>
+#include <decaf/lang/Thread.h>
+#include <decaf/util/concurrent/Mutex.h>
 #include <activemq/util/Config.h>
 
 namespace activemq{
@@ -235,7 +235,7 @@
 
             transport.start();
 
-            concurrent::Thread::sleep( 50 );
+            decaf::lang::Thread::sleep( 50 );
 
             transport.close();
         }
@@ -258,7 +258,7 @@
 
             transport.start();
 
-            concurrent::Thread::sleep( 10 );
+            decaf::lang::Thread::sleep( 10 );
 
             unsigned char buffer[10] = { '1', '2', '3', '4', '5', '6', '7', '8', '9', '0'
};
             try{
@@ -269,7 +269,7 @@
                 ex.setMark( __FILE__, __LINE__ );
             }
 
-            concurrent::Thread::sleep( 100 );
+            decaf::lang::Thread::sleep( 100 );
 
             CPPUNIT_ASSERT( listener.str == "1234567890" );
 

Modified: activemq/activemq-cpp/trunk/src/test/activemq/transport/filters/ResponseCorrelatorTest.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/test/activemq/transport/filters/ResponseCorrelatorTest.h?rev=593309&r1=593308&r2=593309&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/src/test/activemq/transport/filters/ResponseCorrelatorTest.h
(original)
+++ activemq/activemq-cpp/trunk/src/test/activemq/transport/filters/ResponseCorrelatorTest.h
Thu Nov  8 13:02:02 2007
@@ -22,9 +22,9 @@
 #include <cppunit/extensions/HelperMacros.h>
 
 #include <activemq/transport/filters/ResponseCorrelator.h>
-#include <activemq/concurrent/Thread.h>
-#include <activemq/concurrent/Concurrent.h>
-#include <activemq/exceptions/UnsupportedOperationException.h>
+#include <decaf/lang/Thread.h>
+#include <decaf/util/concurrent/Concurrent.h>
+#include <decaf/lang/exceptions/UnsupportedOperationException.h>
 #include <activemq/util/Config.h>
 #include <queue>
 
@@ -119,13 +119,13 @@
         class MyTransport
         :
             public Transport,
-            public concurrent::Runnable{
+            public decaf::lang::Runnable{
         public:
             CommandReader* reader;
             CommandWriter* writer;
             CommandListener* listener;
             TransportExceptionListener* exListener;
-            concurrent::Thread* thread;
+            decaf::lang::Thread* thread;
             concurrent::Mutex mutex;
             concurrent::Mutex startedMutex;
             bool done;
@@ -188,7 +188,7 @@
 
                 done = false;
 
-                thread = new concurrent::Thread( this );
+                thread = new decaf::lang::Thread( this );
                 thread->start();
             }
 
@@ -317,7 +317,7 @@
             }
         };
 
-        class RequestThread : public concurrent::Thread{
+        class RequestThread : public decaf::lang::Thread{
         public:
 
             Transport* transport;
@@ -383,7 +383,7 @@
                 CPPUNIT_ASSERT( resp->getCorrelationId() == cmd.getCommandId() );
 
                 // Wait to get the message back asynchronously.
-                concurrent::Thread::sleep( 100 );
+                decaf::lang::Thread::sleep( 100 );
 
                 // Since our transport relays our original command back at us as a
                 // non-response message, check to make sure we received it and that
@@ -429,7 +429,7 @@
                 }
 
                 // Give the thread a little time to get all the messages back.
-                concurrent::Thread::sleep( 500 );
+                decaf::lang::Thread::sleep( 500 );
 
                 // Make sure we got them all back.
                 CPPUNIT_ASSERT( listener.commands.size() == numCommands );
@@ -472,7 +472,7 @@
                 }
 
                 // Wait to make sure we get the asynchronous message back.
-                concurrent::Thread::sleep( 200 );
+                decaf::lang::Thread::sleep( 200 );
 
                 // Since our transport relays our original command back at us as a
                 // non-response message, check to make sure we received it and that
@@ -526,7 +526,7 @@
                     CPPUNIT_ASSERT( requesters[ix].cmd.getCommandId() == requesters[ix].resp->getCorrelationId()
);
                 }
 
-                concurrent::Thread::sleep( 60 );
+                decaf::lang::Thread::sleep( 60 );
                 synchronized( &listener.mutex )
                 {
                     unsigned int count = 0;

Modified: activemq/activemq-cpp/trunk/src/test/activemq/util/URISupportTest.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/test/activemq/util/URISupportTest.cpp?rev=593309&r1=593308&r2=593309&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/src/test/activemq/util/URISupportTest.cpp (original)
+++ activemq/activemq-cpp/trunk/src/test/activemq/util/URISupportTest.cpp Thu Nov  8 13:02:02
2007
@@ -20,7 +20,7 @@
 CPPUNIT_TEST_SUITE_REGISTRATION( activemq::util::URISupportTest );
 
 #include <activemq/util/URISupport.h>
-#include <activemq/util/Properties.h>
+#include <decaf/util/Properties.h>
 
 using namespace std;
 using namespace activemq;



Mime
View raw message