activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject svn commit: r809703 [2/2] - in /activemq/activemq-cpp/trunk/activemq-cpp/src: main/ main/activemq/transport/ main/activemq/transport/correlator/ main/activemq/transport/failover/ main/activemq/transport/inactivity/ main/activemq/transport/mock/ main/ac...
Date Mon, 31 Aug 2009 19:24:11 GMT
Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/test/decaf/io/BufferedInputStreamTest.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/test/decaf/io/BufferedInputStreamTest.cpp?rev=809703&r1=809702&r2=809703&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/test/decaf/io/BufferedInputStreamTest.cpp
(original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/test/decaf/io/BufferedInputStreamTest.cpp
Mon Aug 31 19:24:08 2009
@@ -26,6 +26,129 @@
 using namespace decaf::io;
 using namespace decaf::util;
 
+namespace decaf{
+namespace io{
+
+    class MyInputStream : public InputStream{
+    private:
+        std::string data;
+        std::size_t pos;
+        bool throwOnRead;
+        bool closed;
+
+    public:
+
+        MyInputStream( const std::string& data ){
+            this->data = data;
+            this->pos = 0;
+            this->throwOnRead = false;
+            this->closed = false;
+        }
+        virtual ~MyInputStream(){}
+
+        void setThrowOnRead( bool value ) {
+            this->throwOnRead = value;
+        }
+
+        bool isThrowOnRead() const {
+            return this->throwOnRead;
+        }
+
+        bool isClosed() const {
+            return this->closed;
+        }
+
+        virtual std::size_t available() const throw (IOException){
+            if( isClosed() ) {
+                throw IOException(
+                    __FILE__, __LINE__,
+                    "MyInputStream::read - Stream already closed." );
+            }
+            std::size_t len = data.length();
+            return len - pos;
+        }
+
+        virtual unsigned char read() throw (IOException){
+            if( this->isThrowOnRead() ) {
+                throw IOException(
+                    __FILE__, __LINE__,
+                    "MyInputStream::read - Throw on Read on." );
+            }
+
+            if( pos >= data.length() ){
+                throw IOException();
+            }
+
+            return data.c_str()[pos++];
+        }
+
+        virtual int read( unsigned char* buffer,
+                          std::size_t offset,
+                          std::size_t bufferSize )
+            throw (IOException){
+
+            std::size_t numToRead = std::min( bufferSize, available() );
+
+            if( this->isThrowOnRead() ) {
+                throw IOException(
+                    __FILE__, __LINE__,
+                    "MyInputStream::read - Throw on Read on." );
+            }
+
+            // Simulate EOF
+            if( numToRead == 0 ) {
+                return -1;
+            }
+
+            const char* str = data.c_str();
+            for( std::size_t ix=0; ix<numToRead; ++ix ){
+                buffer[ix+offset] = str[pos+ix];
+            }
+
+            pos += numToRead;
+
+            return (int)numToRead;
+        }
+
+        virtual void close() throw( decaf::io::IOException){
+            this->closed = true;
+        }
+
+        virtual std::size_t skip( std::size_t num ) throw ( io::IOException, lang::exceptions::UnsupportedOperationException
) {
+            return ( pos += std::min( num, available() ) );
+        }
+
+        virtual void mark( int readLimit DECAF_UNUSED ) {
+
+        }
+
+        virtual void reset() throw ( IOException ) {
+            throw IOException(
+                __FILE__, __LINE__,
+                "BufferedInputStream::reset - mark no yet supported." );
+        }
+
+        virtual bool markSupported() const{ return false; }
+
+        virtual void lock() throw( lang::Exception ) {
+        }
+        virtual void unlock() throw( lang::Exception ) {
+        }
+        virtual void wait() throw( lang::Exception ) {
+        }
+        virtual void wait( long long millisecs DECAF_UNUSED ) throw( lang::Exception ) {
+        }
+        virtual void wait( long long millisecs DECAF_UNUSED, int nanos DECAF_UNUSED ) throw(
lang::Exception ) {
+        }
+        virtual void notify() throw( lang::Exception ) {
+        }
+        virtual void notifyAll() throw( lang::Exception ) {
+        }
+
+    };
+
+}}
+
 ////////////////////////////////////////////////////////////////////////////////
 void BufferedInputStreamTest::testConstructor() {
 

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/test/decaf/io/BufferedInputStreamTest.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/test/decaf/io/BufferedInputStreamTest.h?rev=809703&r1=809702&r2=809703&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/test/decaf/io/BufferedInputStreamTest.h (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/test/decaf/io/BufferedInputStreamTest.h Mon
Aug 31 19:24:08 2009
@@ -55,125 +55,6 @@
         void testReadException();
         void testRead2();
 
-    public:
-
-        class MyInputStream : public InputStream{
-        private:
-            std::string data;
-            std::size_t pos;
-            bool throwOnRead;
-            bool closed;
-
-        public:
-
-            MyInputStream( const std::string& data ){
-                this->data = data;
-                this->pos = 0;
-                this->throwOnRead = false;
-                this->closed = false;
-            }
-            virtual ~MyInputStream(){}
-
-            void setThrowOnRead( bool value ) {
-                this->throwOnRead = value;
-            }
-
-            bool isThrowOnRead() const {
-                return this->throwOnRead;
-            }
-
-            bool isClosed() const {
-                return this->closed;
-            }
-
-            virtual std::size_t available() const throw (IOException){
-                if( isClosed() ) {
-                    throw IOException(
-                        __FILE__, __LINE__,
-                        "MyInputStream::read - Stream already closed." );
-                }
-                std::size_t len = data.length();
-                return len - pos;
-            }
-
-            virtual unsigned char read() throw (IOException){
-                if( this->isThrowOnRead() ) {
-                    throw IOException(
-                        __FILE__, __LINE__,
-                        "MyInputStream::read - Throw on Read on." );
-                }
-
-                if( pos >= data.length() ){
-                    throw IOException();
-                }
-
-                return data.c_str()[pos++];
-            }
-
-            virtual int read( unsigned char* buffer,
-                              std::size_t offset,
-                              std::size_t bufferSize )
-                throw (IOException){
-
-                std::size_t numToRead = std::min( bufferSize, available() );
-
-                if( this->isThrowOnRead() ) {
-                    throw IOException(
-                        __FILE__, __LINE__,
-                        "MyInputStream::read - Throw on Read on." );
-                }
-
-                // Simulate EOF
-                if( numToRead == 0 ) {
-                    return -1;
-                }
-
-                const char* str = data.c_str();
-                for( std::size_t ix=0; ix<numToRead; ++ix ){
-                    buffer[ix+offset] = str[pos+ix];
-                }
-
-                pos += numToRead;
-
-                return (int)numToRead;
-            }
-
-            virtual void close() throw(lang::Exception){
-                this->closed = true;
-            }
-            virtual std::size_t skip( std::size_t num ) throw ( io::IOException, lang::exceptions::UnsupportedOperationException
) {
-                return ( pos += std::min( num, available() ) );
-            }
-
-            virtual void mark( int readLimit DECAF_UNUSED ) {
-
-            }
-
-            virtual void reset() throw ( IOException ) {
-                throw IOException(
-                    __FILE__, __LINE__,
-                    "BufferedInputStream::reset - mark no yet supported." );
-            }
-
-            virtual bool markSupported() const{ return false; }
-
-            virtual void lock() throw( lang::Exception ) {
-            }
-            virtual void unlock() throw( lang::Exception ) {
-            }
-            virtual void wait() throw( lang::Exception ) {
-            }
-            virtual void wait( long long millisecs DECAF_UNUSED ) throw( lang::Exception
) {
-            }
-            virtual void wait( long long millisecs DECAF_UNUSED, int nanos DECAF_UNUSED )
throw( lang::Exception ) {
-            }
-            virtual void notify() throw( lang::Exception ) {
-            }
-            virtual void notifyAll() throw( lang::Exception ) {
-            }
-
-        };
-
     };
 
 }}

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/test/decaf/io/BufferedOutputStreamTest.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/test/decaf/io/BufferedOutputStreamTest.cpp?rev=809703&r1=809702&r2=809703&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/test/decaf/io/BufferedOutputStreamTest.cpp
(original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/test/decaf/io/BufferedOutputStreamTest.cpp
Mon Aug 31 19:24:08 2009
@@ -26,6 +26,79 @@
 using namespace decaf::io;
 using namespace decaf::util;
 
+namespace decaf{
+namespace io{
+
+    class MyOutputStream : public OutputStream{
+    private:
+        char buffer[100];
+        std::size_t pos;
+    public:
+
+        MyOutputStream(){
+            pos = 0;
+            memset( buffer, 0, 100 );
+        }
+        virtual ~MyOutputStream(){}
+
+        const char* getBuffer() const{ return buffer; }
+
+        virtual void write( unsigned char c ) throw (IOException){
+            if( pos >= 100 ){
+                throw IOException();
+            }
+
+            buffer[pos++] = c;
+        }
+
+        virtual void write( const std::vector<unsigned char>& buffer )
+            throw ( IOException ) {
+
+            if( buffer.empty() ){
+                return;
+            }
+
+            this->write( &buffer[0], 0, buffer.size() );
+        }
+
+        virtual void write( const unsigned char* buffer,
+                            std::size_t offset,
+                            std::size_t len ) throw (IOException){
+
+            if( (pos + len) > 100 ){
+                throw IOException();
+            }
+
+            memcpy( this->buffer + pos, buffer+offset, len );
+
+            pos += len;
+        }
+
+        virtual void flush() throw (IOException){
+        }
+
+        virtual void close() throw(IOException){
+            // do nothing.
+        }
+
+        virtual void lock() throw( lang::Exception ) {
+        }
+        virtual void unlock() throw( lang::Exception ) {
+        }
+        virtual void wait() throw( lang::Exception ) {
+        }
+        virtual void wait( long long millisecs DECAF_UNUSED ) throw( lang::Exception ) {
+        }
+        virtual void wait( long long millisecs DECAF_UNUSED, int nanos DECAF_UNUSED ) throw(
lang::Exception ) {
+        }
+        virtual void notify() throw( lang::Exception ) {
+        }
+        virtual void notifyAll() throw( lang::Exception ) {
+        }
+    };
+
+}}
+
 ////////////////////////////////////////////////////////////////////////////////
 void BufferedOutputStreamTest::testConstructor1() {
 

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/test/decaf/io/BufferedOutputStreamTest.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/test/decaf/io/BufferedOutputStreamTest.h?rev=809703&r1=809702&r2=809703&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/test/decaf/io/BufferedOutputStreamTest.h
(original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/test/decaf/io/BufferedOutputStreamTest.h
Mon Aug 31 19:24:08 2009
@@ -68,76 +68,6 @@
         void testWriteNullStreamSize();
         void testWriteI();
 
-    public:
-
-        class MyOutputStream : public OutputStream{
-        private:
-            char buffer[100];
-            std::size_t pos;
-        public:
-
-            MyOutputStream(){
-                pos = 0;
-                memset( buffer, 0, 100 );
-            }
-            virtual ~MyOutputStream(){}
-
-            const char* getBuffer() const{ return buffer; }
-
-            virtual void write( unsigned char c ) throw (IOException){
-                if( pos >= 100 ){
-                    throw IOException();
-                }
-
-                buffer[pos++] = c;
-            }
-
-            virtual void write( const std::vector<unsigned char>& buffer )
-                throw ( IOException ) {
-
-                if( buffer.empty() ){
-                    return;
-                }
-
-                this->write( &buffer[0], 0, buffer.size() );
-            }
-
-            virtual void write( const unsigned char* buffer,
-                                std::size_t offset,
-                                std::size_t len ) throw (IOException){
-
-                if( (pos + len) > 100 ){
-                    throw IOException();
-                }
-
-                memcpy( this->buffer + pos, buffer+offset, len );
-
-                pos += len;
-            }
-
-            virtual void flush() throw (IOException){
-            }
-
-            virtual void close() throw(lang::Exception){
-                // do nothing.
-            }
-
-            virtual void lock() throw( lang::Exception ) {
-            }
-            virtual void unlock() throw( lang::Exception ) {
-            }
-            virtual void wait() throw( lang::Exception ) {
-            }
-            virtual void wait( long long millisecs DECAF_UNUSED ) throw( lang::Exception
) {
-            }
-            virtual void wait( long long millisecs DECAF_UNUSED, int nanos DECAF_UNUSED )
throw( lang::Exception ) {
-            }
-            virtual void notify() throw( lang::Exception ) {
-            }
-            virtual void notifyAll() throw( lang::Exception ) {
-            }
-        };
-
     };
 
 }}

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/test/decaf/io/FilterInputStreamTest.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/test/decaf/io/FilterInputStreamTest.cpp?rev=809703&r1=809702&r2=809703&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/test/decaf/io/FilterInputStreamTest.cpp (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/test/decaf/io/FilterInputStreamTest.cpp Mon
Aug 31 19:24:08 2009
@@ -24,6 +24,127 @@
 using namespace decaf::io;
 using namespace decaf::util;
 
+namespace decaf{
+namespace io{
+
+    class MyInputStream : public InputStream{
+    private:
+        std::string data;
+        std::size_t pos;
+        bool throwOnRead;
+        bool closed;
+
+    public:
+
+        MyInputStream( const std::string& data ){
+            this->data = data;
+            this->pos = 0;
+            this->throwOnRead = false;
+            this->closed = false;
+        }
+        virtual ~MyInputStream(){}
+
+        void setThrowOnRead( bool value ) {
+            this->throwOnRead = value;
+        }
+
+        bool isThrowOnRead() const {
+            return this->throwOnRead;
+        }
+
+        bool isClosed() const {
+            return this->closed;
+        }
+
+        virtual std::size_t available() const throw (IOException){
+            if( isClosed() ) {
+                throw IOException(
+                    __FILE__, __LINE__,
+                    "MyInputStream::read - Stream already closed." );
+            }
+            std::size_t len = data.length();
+            return len - pos;
+        }
+
+        virtual unsigned char read() throw (IOException){
+            if( this->isThrowOnRead() ) {
+                throw IOException(
+                    __FILE__, __LINE__,
+                    "MyInputStream::read - Throw on Read on." );
+            }
+
+            if( pos >= data.length() ){
+                throw IOException();
+            }
+
+            return data.c_str()[pos++];
+        }
+
+        virtual int read( unsigned char* buffer,
+                          std::size_t offset,
+                          std::size_t bufferSize )
+            throw (IOException){
+
+            std::size_t numToRead = std::min( bufferSize, available() );
+
+            if( this->isThrowOnRead() ) {
+                throw IOException(
+                    __FILE__, __LINE__,
+                    "MyInputStream::read - Throw on Read on." );
+            }
+
+            // Simulate EOF
+            if( numToRead == 0 ) {
+                return -1;
+            }
+
+            const char* str = data.c_str();
+            for( std::size_t ix=0; ix<numToRead; ++ix ){
+                buffer[ix+offset] = str[pos+ix];
+            }
+
+            pos += numToRead;
+
+            return (int)numToRead;
+        }
+
+        virtual void close() throw(IOException){
+            this->closed = true;
+        }
+        virtual std::size_t skip( std::size_t num ) throw ( io::IOException, lang::exceptions::UnsupportedOperationException
) {
+            return ( pos += std::min( num, available() ) );
+        }
+
+        virtual void mark( int readLimit DECAF_UNUSED ) {
+
+        }
+
+        virtual void reset() throw ( IOException ) {
+            throw IOException(
+                __FILE__, __LINE__,
+                "BufferedInputStream::reset - mark no yet supported." );
+        }
+
+        virtual bool markSupported() const{ return false; }
+
+        virtual void lock() throw( lang::Exception ) {
+        }
+        virtual void unlock() throw( lang::Exception ) {
+        }
+        virtual void wait() throw( lang::Exception ) {
+        }
+        virtual void wait( long long millisecs DECAF_UNUSED ) throw( lang::Exception ) {
+        }
+        virtual void wait( long long millisecs DECAF_UNUSED, int nanos DECAF_UNUSED ) throw(
lang::Exception ) {
+        }
+        virtual void notify() throw( lang::Exception ) {
+        }
+        virtual void notifyAll() throw( lang::Exception ) {
+        }
+    };
+
+}}
+
 ////////////////////////////////////////////////////////////////////////////////
 void FilterInputStreamTest::testAvailable() {
 

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/test/decaf/io/FilterInputStreamTest.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/test/decaf/io/FilterInputStreamTest.h?rev=809703&r1=809702&r2=809703&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/test/decaf/io/FilterInputStreamTest.h (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/test/decaf/io/FilterInputStreamTest.h Mon
Aug 31 19:24:08 2009
@@ -50,124 +50,6 @@
         void testRead3();
         void testSkip();
 
-    public:
-
-        class MyInputStream : public InputStream{
-        private:
-            std::string data;
-            std::size_t pos;
-            bool throwOnRead;
-            bool closed;
-
-        public:
-
-            MyInputStream( const std::string& data ){
-                this->data = data;
-                this->pos = 0;
-                this->throwOnRead = false;
-                this->closed = false;
-            }
-            virtual ~MyInputStream(){}
-
-            void setThrowOnRead( bool value ) {
-                this->throwOnRead = value;
-            }
-
-            bool isThrowOnRead() const {
-                return this->throwOnRead;
-            }
-
-            bool isClosed() const {
-                return this->closed;
-            }
-
-            virtual std::size_t available() const throw (IOException){
-                if( isClosed() ) {
-                    throw IOException(
-                        __FILE__, __LINE__,
-                        "MyInputStream::read - Stream already closed." );
-                }
-                std::size_t len = data.length();
-                return len - pos;
-            }
-
-            virtual unsigned char read() throw (IOException){
-                if( this->isThrowOnRead() ) {
-                    throw IOException(
-                        __FILE__, __LINE__,
-                        "MyInputStream::read - Throw on Read on." );
-                }
-
-                if( pos >= data.length() ){
-                    throw IOException();
-                }
-
-                return data.c_str()[pos++];
-            }
-
-            virtual int read( unsigned char* buffer,
-                              std::size_t offset,
-                              std::size_t bufferSize )
-                throw (IOException){
-
-                std::size_t numToRead = std::min( bufferSize, available() );
-
-                if( this->isThrowOnRead() ) {
-                    throw IOException(
-                        __FILE__, __LINE__,
-                        "MyInputStream::read - Throw on Read on." );
-                }
-
-                // Simulate EOF
-                if( numToRead == 0 ) {
-                    return -1;
-                }
-
-                const char* str = data.c_str();
-                for( std::size_t ix=0; ix<numToRead; ++ix ){
-                    buffer[ix+offset] = str[pos+ix];
-                }
-
-                pos += numToRead;
-
-                return (int)numToRead;
-            }
-
-            virtual void close() throw(lang::Exception){
-                this->closed = true;
-            }
-            virtual std::size_t skip( std::size_t num ) throw ( io::IOException, lang::exceptions::UnsupportedOperationException
) {
-                return ( pos += std::min( num, available() ) );
-            }
-
-            virtual void mark( int readLimit DECAF_UNUSED ) {
-
-            }
-
-            virtual void reset() throw ( IOException ) {
-                throw IOException(
-                    __FILE__, __LINE__,
-                    "BufferedInputStream::reset - mark no yet supported." );
-            }
-
-            virtual bool markSupported() const{ return false; }
-
-            virtual void lock() throw( lang::Exception ) {
-            }
-            virtual void unlock() throw( lang::Exception ) {
-            }
-            virtual void wait() throw( lang::Exception ) {
-            }
-            virtual void wait( long long millisecs DECAF_UNUSED ) throw( lang::Exception
) {
-            }
-            virtual void wait( long long millisecs DECAF_UNUSED, int nanos DECAF_UNUSED )
throw( lang::Exception ) {
-            }
-            virtual void notify() throw( lang::Exception ) {
-            }
-            virtual void notifyAll() throw( lang::Exception ) {
-            }
-        };
-
     };
 
 }}

Added: activemq/activemq-cpp/trunk/activemq-cpp/src/test/decaf/util/concurrent/SynchronousQueueTest.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/test/decaf/util/concurrent/SynchronousQueueTest.cpp?rev=809703&view=auto
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/test/decaf/util/concurrent/SynchronousQueueTest.cpp
(added)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/test/decaf/util/concurrent/SynchronousQueueTest.cpp
Mon Aug 31 19:24:08 2009
@@ -0,0 +1,29 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+#include "SynchronousQueueTest.h"
+
+using namespace std;
+using namespace decaf;
+using namespace decaf::lang;
+using namespace decaf::util;
+using namespace decaf::util::concurrent;
+
+///////////////////////////////////////////////////////////////////////////////
+void SynchronousQueueTest::testConstructor_1() {
+
+}

Propchange: activemq/activemq-cpp/trunk/activemq-cpp/src/test/decaf/util/concurrent/SynchronousQueueTest.cpp
------------------------------------------------------------------------------
    svn:eol-style = native

Added: activemq/activemq-cpp/trunk/activemq-cpp/src/test/decaf/util/concurrent/SynchronousQueueTest.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/test/decaf/util/concurrent/SynchronousQueueTest.h?rev=809703&view=auto
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/test/decaf/util/concurrent/SynchronousQueueTest.h
(added)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/test/decaf/util/concurrent/SynchronousQueueTest.h
Mon Aug 31 19:24:08 2009
@@ -0,0 +1,52 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+#ifndef _DECAF_UTIL_CONCURRENT_SYNCHRONOUSQUEUETEST_H_
+#define _DECAF_UTIL_CONCURRENT_SYNCHRONOUSQUEUETEST_H_
+
+#include <cppunit/TestFixture.h>
+#include <cppunit/extensions/HelperMacros.h>
+
+#include <decaf/lang/Thread.h>
+#include <decaf/lang/Runnable.h>
+#include <decaf/util/concurrent/Concurrent.h>
+#include <decaf/util/concurrent/Mutex.h>
+#include <decaf/util/Random.h>
+#include <time.h>
+
+namespace decaf {
+namespace util {
+namespace concurrent {
+
+    class SynchronousQueueTest : public CppUnit::TestFixture {
+
+        CPPUNIT_TEST_SUITE( SynchronousQueueTest );
+        CPPUNIT_TEST( testConstructor_1 );
+        CPPUNIT_TEST_SUITE_END();
+
+    public:
+
+        SynchronousQueueTest() {}
+        virtual ~SynchronousQueueTest() {}
+
+        void testConstructor_1();
+
+    };
+
+}}}
+
+#endif /* _DECAF_UTIL_CONCURRENT_SYNCHRONOUSQUEUETEST_H_ */

Propchange: activemq/activemq-cpp/trunk/activemq-cpp/src/test/decaf/util/concurrent/SynchronousQueueTest.h
------------------------------------------------------------------------------
    svn:eol-style = native



Mime
View raw message