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 2009/08/31 21:24:11 UTC
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...
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