Return-Path: X-Original-To: apmail-activemq-commits-archive@www.apache.org Delivered-To: apmail-activemq-commits-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 8CC4BD441 for ; Mon, 18 Feb 2013 19:02:57 +0000 (UTC) Received: (qmail 18493 invoked by uid 500); 18 Feb 2013 19:02:57 -0000 Delivered-To: apmail-activemq-commits-archive@activemq.apache.org Received: (qmail 18467 invoked by uid 500); 18 Feb 2013 19:02:57 -0000 Mailing-List: contact commits-help@activemq.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@activemq.apache.org Delivered-To: mailing list commits@activemq.apache.org Received: (qmail 18458 invoked by uid 99); 18 Feb 2013 19:02:57 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 18 Feb 2013 19:02:57 +0000 X-ASF-Spam-Status: No, hits=-2000.0 required=5.0 tests=ALL_TRUSTED X-Spam-Check-By: apache.org Received: from [140.211.11.4] (HELO eris.apache.org) (140.211.11.4) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 18 Feb 2013 19:02:46 +0000 Received: from eris.apache.org (localhost [127.0.0.1]) by eris.apache.org (Postfix) with ESMTP id 278E72388978; Mon, 18 Feb 2013 19:02:25 +0000 (UTC) Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit Subject: svn commit: r1447432 - in /activemq/activemq-cpp/trunk/activemq-cpp/src: main/activemq/transport/failover/ test/ test/activemq/transport/failover/ Date: Mon, 18 Feb 2013 19:02:24 -0000 To: commits@activemq.apache.org From: tabish@apache.org X-Mailer: svnmailer-1.0.8-patched Message-Id: <20130218190225.278E72388978@eris.apache.org> X-Virus-Checked: Checked by ClamAV on apache.org Author: tabish Date: Mon Feb 18 19:02:24 2013 New Revision: 1447432 URL: http://svn.apache.org/r1447432 Log: https://issues.apache.org/jira/browse/AMQCPP-463 Add some tests and supporting code in the transport and fix a rebalance issue. Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/failover/FailoverTransport.cpp activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/failover/FailoverTransport.h activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/failover/URIPool.h activemq/activemq-cpp/trunk/activemq-cpp/src/test/activemq/transport/failover/FailoverTransportTest.cpp activemq/activemq-cpp/trunk/activemq-cpp/src/test/activemq/transport/failover/FailoverTransportTest.h activemq/activemq-cpp/trunk/activemq-cpp/src/test/testRegistry.cpp Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/failover/FailoverTransport.cpp URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/failover/FailoverTransport.cpp?rev=1447432&r1=1447431&r2=1447432&view=diff ============================================================================== --- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/failover/FailoverTransport.cpp (original) +++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/failover/FailoverTransport.cpp Mon Feb 18 19:02:24 2013 @@ -868,7 +868,7 @@ bool FailoverTransport::iterate() { } else { if (this->impl->doRebalance) { - if (connectList->getPriorityURI().equals(*this->impl->connectedTransportURI)) { + if (isPriorityBackup() && connectList->getPriorityURI().equals(*this->impl->connectedTransportURI)) { // already connected to first in the list, no need to rebalance this->impl->doRebalance = false; return false; @@ -939,7 +939,7 @@ bool FailoverTransport::iterate() { this->impl->connectFailures = 0; this->impl->connectedToPrioirty = - connectList->getPriorityURI().equals(uri) || this->impl->connectedToPrioirty; + connectList->getPriorityURI().equals(uri) || this->impl->priorityUris->contains(uri); // Make sure on initial startup, that the transportListener // has been initialized for this instance. @@ -1311,3 +1311,8 @@ void FailoverTransport::setPriorityURIs( } } } + +//////////////////////////////////////////////////////////////////////////////// +const List& FailoverTransport::getPriorityURIs() const { + return this->impl->priorityUris->getURIList(); +} Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/failover/FailoverTransport.h URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/failover/FailoverTransport.h?rev=1447432&r1=1447431&r2=1447432&view=diff ============================================================================== --- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/failover/FailoverTransport.h (original) +++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/failover/FailoverTransport.h Mon Feb 18 19:02:24 2013 @@ -28,6 +28,7 @@ #include #include +#include #include #include #include @@ -229,6 +230,8 @@ namespace failover { void setPriorityURIs(const std::string& priorityURIs); + const decaf::util::List& getPriorityURIs() const; + void setConnectionInterruptProcessingComplete(const Pointer connectionId); bool isConnectedToPriority() const; Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/failover/URIPool.h URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/failover/URIPool.h?rev=1447432&r1=1447431&r2=1447432&view=diff ============================================================================== --- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/failover/URIPool.h (original) +++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/failover/URIPool.h Mon Feb 18 19:02:24 2013 @@ -68,6 +68,15 @@ namespace failover { ~URIPool(); /** + * Gets a static view of the URI List contained in this URI Pool + * + * @returns a static reference to this Pools list of URIs. + */ + const decaf::util::List& getURIList() const { + return this->uriPool; + } + + /** * @returns true if this URI Pool is empty. */ bool isEmpty() const; Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/test/activemq/transport/failover/FailoverTransportTest.cpp URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/test/activemq/transport/failover/FailoverTransportTest.cpp?rev=1447432&r1=1447431&r2=1447432&view=diff ============================================================================== --- activemq/activemq-cpp/trunk/activemq-cpp/src/test/activemq/transport/failover/FailoverTransportTest.cpp (original) +++ activemq/activemq-cpp/trunk/activemq-cpp/src/test/activemq/transport/failover/FailoverTransportTest.cpp Mon Feb 18 19:02:24 2013 @@ -582,7 +582,7 @@ void FailoverTransportTest::testTranspor Thread::sleep( 2000 ); failover->removeURI( true, removals ); - Thread::sleep( 2000 ); + Thread::sleep( 20000 ); mock = NULL; while( mock == NULL ) { @@ -592,3 +592,79 @@ void FailoverTransportTest::testTranspor CPPUNIT_ASSERT_EQUAL(std::string("Reconnect"), mock->getName()); } + +//////////////////////////////////////////////////////////////////////////////// +void FailoverTransportTest::testPriorityBackupConfig() { + + std::string uri = "failover://(mock://localhost:61616," + "mock://localhost:61618)?randomize=false&priorityBackup=true"; + + DefaultTransportListener listener; + FailoverTransportFactory factory; + + Pointer transport( factory.create( uri ) ); + CPPUNIT_ASSERT( transport != NULL ); + transport->setTransportListener( &listener ); + + FailoverTransport* failover = dynamic_cast( + transport->narrow( typeid( FailoverTransport ) ) ); + + CPPUNIT_ASSERT( failover != NULL ); + CPPUNIT_ASSERT( failover->isRandomize() == false ); + CPPUNIT_ASSERT( failover->isPriorityBackup() == true ); + + transport->start(); + + Thread::sleep( 1000 ); + CPPUNIT_ASSERT( failover->isConnected() == true ); + CPPUNIT_ASSERT( failover->isConnectedToPriority() == true ); + + transport->close(); +} + +//////////////////////////////////////////////////////////////////////////////// +void FailoverTransportTest::testUriOptionsApplied() { + + std::string uri = "failover://(mock://localhost:61616,mock://localhost:61618)?" + "randomize=true&" + "priorityBackup=true&" + "initialReconnectDelay=222&" + "useExponentialBackOff=false&" + "maxReconnectAttempts=27&" + "startupMaxReconnectAttempts=44&" + "backup=true&" + "trackMessages=false&" + "maxCacheSize=16543217&" + "timeout=500&" + "updateURIsSupported=false&" + "maxReconnectDelay=55555&" + "priorityURIs=mock://localhost:61617,mock://localhost:61619"; + + DefaultTransportListener listener; + FailoverTransportFactory factory; + + Pointer transport( factory.create( uri ) ); + CPPUNIT_ASSERT( transport != NULL ); + transport->setTransportListener( &listener ); + + FailoverTransport* failover = dynamic_cast( + transport->narrow( typeid( FailoverTransport ) ) ); + + CPPUNIT_ASSERT( failover != NULL ); + CPPUNIT_ASSERT( failover->isRandomize() == true ); + CPPUNIT_ASSERT( failover->isPriorityBackup() == true ); + CPPUNIT_ASSERT( failover->isUseExponentialBackOff() == false ); + CPPUNIT_ASSERT( failover->getInitialReconnectDelay() == 222 ); + CPPUNIT_ASSERT( failover->getMaxReconnectAttempts() == 27 ); + CPPUNIT_ASSERT( failover->getStartupMaxReconnectAttempts() == 44 ); + CPPUNIT_ASSERT( failover->isBackup() == true ); + CPPUNIT_ASSERT( failover->isTrackMessages() == false ); + CPPUNIT_ASSERT( failover->getMaxCacheSize() == 16543217 ); + CPPUNIT_ASSERT( failover->isUpdateURIsSupported() == false ); + CPPUNIT_ASSERT( failover->getMaxReconnectDelay() == 55555 ); + + const List& priorityUris = failover->getPriorityURIs(); + CPPUNIT_ASSERT( priorityUris.size() == 2 ); + + transport->close(); +} Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/test/activemq/transport/failover/FailoverTransportTest.h URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/test/activemq/transport/failover/FailoverTransportTest.h?rev=1447432&r1=1447431&r2=1447432&view=diff ============================================================================== --- activemq/activemq-cpp/trunk/activemq-cpp/src/test/activemq/transport/failover/FailoverTransportTest.h (original) +++ activemq/activemq-cpp/trunk/activemq-cpp/src/test/activemq/transport/failover/FailoverTransportTest.h Mon Feb 18 19:02:24 2013 @@ -51,6 +51,8 @@ namespace failover { CPPUNIT_TEST( testSendRequestMessageFail ); CPPUNIT_TEST( testWithOpewireCommands ); CPPUNIT_TEST( testTransportHandlesConnectionControl ); + CPPUNIT_TEST( testPriorityBackupConfig ); + CPPUNIT_TEST( testUriOptionsApplied ); CPPUNIT_TEST_SUITE_END(); public: @@ -58,43 +60,19 @@ namespace failover { FailoverTransportTest(); virtual ~FailoverTransportTest(); - // Tests that a Failover Transport can be created, started and stopped. void testTransportCreate(); - - // Tests that a Failover Transport can be created with backups enabled and - // be created, started and stopped. void testTransportCreateWithBackups(); - - // Tests that a Transport will try and reconnect to a Transport that fails - // at its creation time and will retry until the max reconnect amount has been - // reached at which point it calls its listeners onException method. void testTransportCreateFailOnCreate(); - - // Same as above but attempt to send a Message which should result in an Exception - // being thrown from the oneway method when the max connection attempts have been - // made. void testTransportCreateFailOnCreateSendMessage(); - - // Tests that a Transport with a Connected Primary Transport but failing backup - // transports won't segfault and can be started, and stopped without error. void testFailingBackupCreation(); - - // Test that messages sent via the Oneway or Request methods are received. void testSendOnewayMessage(); void testSendRequestMessage(); - - // Test that messages sent via the Oneway or Request methods are received after - // the first transport faults on the send and transport 2 is created. void testSendOnewayMessageFail(); void testSendRequestMessageFail(); - - // Test the transport using a realistic set of commands being sen through which - // simulates creation of a Connection, Session, Topics, Producers and Consumers - // and then removing them all as a normal shutdown would. void testWithOpewireCommands(); - - // Tests that the Transport correctly handles the ConnectionControl command. void testTransportHandlesConnectionControl(); + void testPriorityBackupConfig(); + void testUriOptionsApplied(); private: Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/test/testRegistry.cpp URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/test/testRegistry.cpp?rev=1447432&r1=1447431&r2=1447432&view=diff ============================================================================== --- activemq/activemq-cpp/trunk/activemq-cpp/src/test/testRegistry.cpp (original) +++ activemq/activemq-cpp/trunk/activemq-cpp/src/test/testRegistry.cpp Mon Feb 18 19:02:24 2013 @@ -18,483 +18,483 @@ // All CPP Unit tests are registered in here so we can disable them and // enable them easily in one place. -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::commands::BrokerInfoTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::commands::BrokerIdTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::commands::ActiveMQTopicTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::commands::ActiveMQTextMessageTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::commands::ActiveMQTempTopicTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::commands::ActiveMQTempQueueTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::commands::ActiveMQQueueTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::commands::ActiveMQMessageTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::commands::ActiveMQMapMessageTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::commands::ActiveMQDestinationTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::commands::ActiveMQBytesMessageTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::commands::ActiveMQStreamMessageTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::commands::XATransactionIdTest ); - -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::BaseDataStreamMarshallerTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::PrimitiveTypesMarshallerTest ); - -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::utils::BooleanStreamTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::utils::HexTableTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::utils::MessagePropertyInterceptorTest ); - -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::OpenWireFormatTest ); - -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::stomp::StompHelperTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::stomp::StompWireFormatTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::stomp::StompWireFormatFactoryTest ); - -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::cmsutil::CmsAccessorTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::cmsutil::CmsDestinationAccessorTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::cmsutil::CmsTemplateTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::cmsutil::DynamicDestinationResolverTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::cmsutil::SessionPoolTest ); - -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::core::ActiveMQConnectionFactoryTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::core::ActiveMQConnectionTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::core::ActiveMQSessionTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::core::FifoMessageDispatchChannelTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::core::SimplePriorityMessageDispatchChannelTest ); - -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::state::ConnectionStateTrackerTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::state::ConnectionStateTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::state::ConsumerStateTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::state::ProducerStateTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::state::SessionStateTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::state::TransactionStateTest ); - +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::commands::BrokerInfoTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::commands::BrokerIdTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::commands::ActiveMQTopicTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::commands::ActiveMQTextMessageTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::commands::ActiveMQTempTopicTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::commands::ActiveMQTempQueueTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::commands::ActiveMQQueueTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::commands::ActiveMQMessageTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::commands::ActiveMQMapMessageTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::commands::ActiveMQDestinationTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::commands::ActiveMQBytesMessageTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::commands::ActiveMQStreamMessageTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::commands::XATransactionIdTest ); +// +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::BaseDataStreamMarshallerTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::PrimitiveTypesMarshallerTest ); +// +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::utils::BooleanStreamTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::utils::HexTableTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::utils::MessagePropertyInterceptorTest ); +// +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::OpenWireFormatTest ); +// +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::stomp::StompHelperTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::stomp::StompWireFormatTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::stomp::StompWireFormatFactoryTest ); +// +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::cmsutil::CmsAccessorTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::cmsutil::CmsDestinationAccessorTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::cmsutil::CmsTemplateTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::cmsutil::DynamicDestinationResolverTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::cmsutil::SessionPoolTest ); +// +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::core::ActiveMQConnectionFactoryTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::core::ActiveMQConnectionTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::core::ActiveMQSessionTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::core::FifoMessageDispatchChannelTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::core::SimplePriorityMessageDispatchChannelTest ); +// +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::state::ConnectionStateTrackerTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::state::ConnectionStateTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::state::ConsumerStateTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::state::ProducerStateTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::state::SessionStateTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::state::TransactionStateTest ); +// #include CPPUNIT_TEST_SUITE_REGISTRATION( activemq::transport::failover::FailoverTransportTest ); - -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::transport::tcp::TcpTransportTest ); - -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::transport::correlator::ResponseCorrelatorTest ); - -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::transport::mock::MockTransportFactoryTest ); - -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::transport::inactivity::InactivityMonitorTest ); - -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::transport::TransportRegistryTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::transport::IOTransportTest ); - -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::exceptions::ActiveMQExceptionTest ); - -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::util::AdvisorySupportTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::util::ActiveMQMessageTransformationTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::util::IdGeneratorTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::util::LongSequenceGeneratorTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::util::PrimitiveValueNodeTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::util::PrimitiveListTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::util::PrimitiveMapTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::util::PrimitiveValueConverterTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::util::URISupportTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::util::MemoryUsageTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::util::MarshallingSupportTest ); - -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::threads::SchedulerTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::threads::DedicatedTaskRunnerTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::threads::CompositeTaskRunnerTest ); - -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::WireFormatRegistryTest ); - -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::internal::util::ByteArrayAdapterTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::internal::util::TimerTaskHeapTest ); - -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::internal::net::ssl::DefaultSSLSocketFactoryTest ); - -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::internal::nio::ByteArrayBufferTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::internal::nio::BufferFactoryTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::internal::nio::CharArrayBufferTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::internal::nio::DoubleArrayBufferTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::internal::nio::FloatArrayBufferTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::internal::nio::LongArrayBufferTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::internal::nio::IntArrayBufferTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::internal::nio::ShortArrayBufferTest ); - -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::internal::net::URIEncoderDecoderTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::internal::net::URIHelperTest ); - -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::nio::BufferTest ); - -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::io::InputStreamTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::io::OutputStreamTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::io::FilterInputStreamTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::io::FilterOutputStreamTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::io::BufferedInputStreamTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::io::BufferedOutputStreamTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::io::ByteArrayInputStreamTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::io::ByteArrayOutputStreamTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::io::PushbackInputStreamTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::io::DataInputStreamTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::io::DataOutputStreamTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::io::WriterTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::io::ReaderTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::io::OutputStreamWriterTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::io::InputStreamReaderTest ); - -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::lang::MathTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::lang::ByteTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::lang::CharacterTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::lang::BooleanTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::lang::ShortTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::lang::IntegerTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::lang::LongTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::lang::FloatTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::lang::DoubleTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::lang::ExceptionTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::lang::ThreadTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::lang::ThreadLocalTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::lang::SystemTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::lang::PointerTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::lang::ArrayPointerTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::lang::StringTest ); - -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::net::InetAddressTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::net::InetAddressTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::net::InetAddressTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::net::SocketFactoryTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::net::ServerSocketTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::net::SocketTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::net::URITest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::net::URISyntaxExceptionTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::net::URLEncoderTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::net::URLDecoderTest ); - -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::net::ssl::SSLSocketFactoryTest ); - -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::concurrent::CopyOnWriteArrayListTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::concurrent::CopyOnWriteArraySetTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::concurrent::ConcurrentStlMapTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::concurrent::CountDownLatchTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::concurrent::MutexTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::concurrent::ThreadPoolExecutorTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::concurrent::ExecutorsTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::concurrent::TimeUnitTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::concurrent::LinkedBlockingQueueTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::concurrent::SemaphoreTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::concurrent::FutureTaskTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::concurrent::AbstractExecutorServiceTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::concurrent::ConcurrentHashMapTest ); - -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::concurrent::atomic::AtomicBooleanTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::concurrent::atomic::AtomicIntegerTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::concurrent::atomic::AtomicReferenceTest ); - -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::concurrent::locks::LockSupportTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::concurrent::locks::AbstractQueuedSynchronizerTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::concurrent::locks::ReentrantLockTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::concurrent::locks::ReentrantReadWriteLockTest ); - -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::HashCodeTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::HashMapTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::AbstractCollectionTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::AbstractListTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::AbstractSequentialListTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::BitSetTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::DateTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::UUIDTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::ListTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::LinkedListTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::ArrayListTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::ArraysTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::StlMapTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::PropertiesTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::QueueTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::RandomTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::SetTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::StringTokenizerTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::TimerTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::PriorityQueueTest ); - -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::zip::DeflaterTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::zip::InflaterTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::zip::Adler32Test ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::zip::CRC32Test ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::zip::CheckedInputStreamTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::zip::CheckedOutputStreamTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::zip::DeflaterOutputStreamTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::zip::InflaterInputStreamTest ); - -#include -CPPUNIT_TEST_SUITE_REGISTRATION( decaf::security::SecureRandomTest ); - -//////////////////////////////////////////////////////////////////////////////////////////////////////////////// -////// Marshaler Tests -////// -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::ActiveMQBlobMessageMarshallerTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::ActiveMQBytesMessageMarshallerTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::ActiveMQMapMessageMarshallerTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::ActiveMQMessageMarshallerTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::ActiveMQObjectMessageMarshallerTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::ActiveMQQueueMarshallerTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::ActiveMQStreamMessageMarshallerTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::ActiveMQTempQueueMarshallerTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::ActiveMQTempTopicMarshallerTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::ActiveMQTextMessageMarshallerTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::ActiveMQTopicMarshallerTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::BrokerIdMarshallerTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::BrokerInfoMarshallerTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::ConnectionControlMarshallerTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::ConnectionErrorMarshallerTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::ConnectionIdMarshallerTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::ConnectionInfoMarshallerTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::ConsumerControlMarshallerTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::ConsumerIdMarshallerTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::ConsumerInfoMarshallerTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::ControlCommandMarshallerTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::DataArrayResponseMarshallerTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::DataResponseMarshallerTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::DestinationInfoMarshallerTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::DiscoveryEventMarshallerTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::ExceptionResponseMarshallerTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::FlushCommandMarshallerTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::IntegerResponseMarshallerTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::JournalQueueAckMarshallerTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::JournalTopicAckMarshallerTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::JournalTraceMarshallerTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::JournalTransactionMarshallerTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::KeepAliveInfoMarshallerTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::LastPartialCommandMarshallerTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::LocalTransactionIdMarshallerTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::MessageAckMarshallerTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::MessageDispatchMarshallerTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::MessageDispatchNotificationMarshallerTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::MessageIdMarshallerTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::MessagePullMarshallerTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::NetworkBridgeFilterMarshallerTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::PartialCommandMarshallerTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::ProducerAckMarshallerTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::ProducerIdMarshallerTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::ProducerInfoMarshallerTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::RemoveInfoMarshallerTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::RemoveSubscriptionInfoMarshallerTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::ReplayCommandMarshallerTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::ResponseMarshallerTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::SessionIdMarshallerTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::SessionInfoMarshallerTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::ShutdownInfoMarshallerTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::SubscriptionInfoMarshallerTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::TransactionInfoMarshallerTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::WireFormatInfoMarshallerTest ); -#include -CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::XATransactionIdMarshallerTest ); +// +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::transport::tcp::TcpTransportTest ); +// +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::transport::correlator::ResponseCorrelatorTest ); +// +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::transport::mock::MockTransportFactoryTest ); +// +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::transport::inactivity::InactivityMonitorTest ); +// +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::transport::TransportRegistryTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::transport::IOTransportTest ); +// +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::exceptions::ActiveMQExceptionTest ); +// +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::util::AdvisorySupportTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::util::ActiveMQMessageTransformationTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::util::IdGeneratorTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::util::LongSequenceGeneratorTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::util::PrimitiveValueNodeTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::util::PrimitiveListTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::util::PrimitiveMapTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::util::PrimitiveValueConverterTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::util::URISupportTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::util::MemoryUsageTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::util::MarshallingSupportTest ); +// +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::threads::SchedulerTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::threads::DedicatedTaskRunnerTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::threads::CompositeTaskRunnerTest ); +// +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::WireFormatRegistryTest ); +// +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::internal::util::ByteArrayAdapterTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::internal::util::TimerTaskHeapTest ); +// +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::internal::net::ssl::DefaultSSLSocketFactoryTest ); +// +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::internal::nio::ByteArrayBufferTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::internal::nio::BufferFactoryTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::internal::nio::CharArrayBufferTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::internal::nio::DoubleArrayBufferTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::internal::nio::FloatArrayBufferTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::internal::nio::LongArrayBufferTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::internal::nio::IntArrayBufferTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::internal::nio::ShortArrayBufferTest ); +// +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::internal::net::URIEncoderDecoderTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::internal::net::URIHelperTest ); +// +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::nio::BufferTest ); +// +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::io::InputStreamTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::io::OutputStreamTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::io::FilterInputStreamTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::io::FilterOutputStreamTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::io::BufferedInputStreamTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::io::BufferedOutputStreamTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::io::ByteArrayInputStreamTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::io::ByteArrayOutputStreamTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::io::PushbackInputStreamTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::io::DataInputStreamTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::io::DataOutputStreamTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::io::WriterTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::io::ReaderTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::io::OutputStreamWriterTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::io::InputStreamReaderTest ); +// +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::lang::MathTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::lang::ByteTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::lang::CharacterTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::lang::BooleanTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::lang::ShortTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::lang::IntegerTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::lang::LongTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::lang::FloatTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::lang::DoubleTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::lang::ExceptionTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::lang::ThreadTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::lang::ThreadLocalTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::lang::SystemTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::lang::PointerTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::lang::ArrayPointerTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::lang::StringTest ); +// +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::net::InetAddressTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::net::InetAddressTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::net::InetAddressTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::net::SocketFactoryTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::net::ServerSocketTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::net::SocketTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::net::URITest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::net::URISyntaxExceptionTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::net::URLEncoderTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::net::URLDecoderTest ); +// +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::net::ssl::SSLSocketFactoryTest ); +// +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::concurrent::CopyOnWriteArrayListTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::concurrent::CopyOnWriteArraySetTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::concurrent::ConcurrentStlMapTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::concurrent::CountDownLatchTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::concurrent::MutexTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::concurrent::ThreadPoolExecutorTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::concurrent::ExecutorsTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::concurrent::TimeUnitTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::concurrent::LinkedBlockingQueueTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::concurrent::SemaphoreTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::concurrent::FutureTaskTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::concurrent::AbstractExecutorServiceTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::concurrent::ConcurrentHashMapTest ); +// +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::concurrent::atomic::AtomicBooleanTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::concurrent::atomic::AtomicIntegerTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::concurrent::atomic::AtomicReferenceTest ); +// +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::concurrent::locks::LockSupportTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::concurrent::locks::AbstractQueuedSynchronizerTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::concurrent::locks::ReentrantLockTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::concurrent::locks::ReentrantReadWriteLockTest ); +// +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::HashCodeTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::HashMapTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::AbstractCollectionTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::AbstractListTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::AbstractSequentialListTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::BitSetTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::DateTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::UUIDTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::ListTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::LinkedListTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::ArrayListTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::ArraysTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::StlMapTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::PropertiesTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::QueueTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::RandomTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::SetTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::StringTokenizerTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::TimerTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::PriorityQueueTest ); +// +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::zip::DeflaterTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::zip::InflaterTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::zip::Adler32Test ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::zip::CRC32Test ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::zip::CheckedInputStreamTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::zip::CheckedOutputStreamTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::zip::DeflaterOutputStreamTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::zip::InflaterInputStreamTest ); +// +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::security::SecureRandomTest ); +// +////////////////////////////////////////////////////////////////////////////////////////////////////////////////// +//////// Marshaler Tests +//////// +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::ActiveMQBlobMessageMarshallerTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::ActiveMQBytesMessageMarshallerTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::ActiveMQMapMessageMarshallerTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::ActiveMQMessageMarshallerTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::ActiveMQObjectMessageMarshallerTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::ActiveMQQueueMarshallerTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::ActiveMQStreamMessageMarshallerTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::ActiveMQTempQueueMarshallerTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::ActiveMQTempTopicMarshallerTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::ActiveMQTextMessageMarshallerTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::ActiveMQTopicMarshallerTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::BrokerIdMarshallerTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::BrokerInfoMarshallerTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::ConnectionControlMarshallerTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::ConnectionErrorMarshallerTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::ConnectionIdMarshallerTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::ConnectionInfoMarshallerTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::ConsumerControlMarshallerTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::ConsumerIdMarshallerTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::ConsumerInfoMarshallerTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::ControlCommandMarshallerTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::DataArrayResponseMarshallerTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::DataResponseMarshallerTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::DestinationInfoMarshallerTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::DiscoveryEventMarshallerTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::ExceptionResponseMarshallerTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::FlushCommandMarshallerTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::IntegerResponseMarshallerTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::JournalQueueAckMarshallerTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::JournalTopicAckMarshallerTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::JournalTraceMarshallerTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::JournalTransactionMarshallerTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::KeepAliveInfoMarshallerTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::LastPartialCommandMarshallerTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::LocalTransactionIdMarshallerTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::MessageAckMarshallerTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::MessageDispatchMarshallerTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::MessageDispatchNotificationMarshallerTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::MessageIdMarshallerTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::MessagePullMarshallerTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::NetworkBridgeFilterMarshallerTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::PartialCommandMarshallerTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::ProducerAckMarshallerTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::ProducerIdMarshallerTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::ProducerInfoMarshallerTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::RemoveInfoMarshallerTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::RemoveSubscriptionInfoMarshallerTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::ReplayCommandMarshallerTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::ResponseMarshallerTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::SessionIdMarshallerTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::SessionInfoMarshallerTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::ShutdownInfoMarshallerTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::SubscriptionInfoMarshallerTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::TransactionInfoMarshallerTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::WireFormatInfoMarshallerTest ); +//#include +//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::generated::XATransactionIdMarshallerTest );