/*
 * 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 "AdvisorySupportTest.h"

#include <activemq/util/AdvisorySupport.h>
#include <activemq/commands/ActiveMQDestination.h>
#include <activemq/commands/ActiveMQTopic.h>
#include <activemq/commands/ActiveMQQueue.h>
#include <activemq/commands/ActiveMQTempTopic.h>
#include <activemq/commands/ActiveMQTempQueue.h>

#include <decaf/lang/Pointer.h>
#include <decaf/lang/exceptions/NullPointerException.h>

using namespace activemq;
using namespace activemq::util;
using namespace activemq::commands;
using namespace decaf;
using namespace decaf::lang;
using namespace decaf::lang::exceptions;

////////////////////////////////////////////////////////////////////////////////
AdvisorySupportTest::AdvisorySupportTest() {
}

////////////////////////////////////////////////////////////////////////////////
AdvisorySupportTest::~AdvisorySupportTest() {
}

////////////////////////////////////////////////////////////////////////////////
void AdvisorySupportTest::testGetTempDestinationCompositeAdvisoryTopic() {

    Pointer<ActiveMQDestination> topic(AdvisorySupport::getTempDestinationCompositeAdvisoryTopic());
    CPPUNIT_ASSERT(topic != NULL);
    CPPUNIT_ASSERT(topic->isComposite());
    CPPUNIT_ASSERT(topic->isTopic());
    CPPUNIT_ASSERT(topic->isTemporary() == false);
    CPPUNIT_ASSERT(topic->isAdvisory() == true);

    CPPUNIT_ASSERT(topic->getPhysicalName().find(".TempTopic") != std::string::npos);
    CPPUNIT_ASSERT(topic->getPhysicalName().find(".TempQueue") != std::string::npos);
}

////////////////////////////////////////////////////////////////////////////////
void AdvisorySupportTest::testGetAllDestinationsCompositeAdvisoryTopic() {

    Pointer<ActiveMQDestination> topic(AdvisorySupport::getAllDestinationsCompositeAdvisoryTopic());
    CPPUNIT_ASSERT(topic != NULL);
    CPPUNIT_ASSERT(topic->isComposite());
    CPPUNIT_ASSERT(topic->isTopic());
    CPPUNIT_ASSERT(topic->isTemporary() == false);
    CPPUNIT_ASSERT(topic->isAdvisory() == true);

    CPPUNIT_ASSERT(topic->getPhysicalName().find(".TempTopic") != std::string::npos);
    CPPUNIT_ASSERT(topic->getPhysicalName().find(".TempQueue") != std::string::npos);
    CPPUNIT_ASSERT(topic->getPhysicalName().find(".Topic") != std::string::npos);
    CPPUNIT_ASSERT(topic->getPhysicalName().find(".Queue") != std::string::npos);
}

////////////////////////////////////////////////////////////////////////////////
void AdvisorySupportTest::testGetAllDestinationAdvisoryTopics() {

    Pointer<ActiveMQDestination> target(new ActiveMQTopic("Test.Topic"));

    std::vector<ActiveMQDestination*> topics = AdvisorySupport::getAllDestinationAdvisoryTopics(target.get());
    CPPUNIT_ASSERT(topics.size() > 0);

    std::vector<ActiveMQDestination*>::iterator iter = topics.begin();
    for (; iter != topics.end(); ++iter) {
        Pointer<ActiveMQDestination> topic(*iter);
        CPPUNIT_ASSERT(topic->isTopic());
        CPPUNIT_ASSERT(topic->isAdvisory() == true);
        CPPUNIT_ASSERT(topic->isTemporary() == false);
        CPPUNIT_ASSERT(topic->getPhysicalName().find(AdvisorySupport::ADVISORY_TOPIC_PREFIX) == 0);
    }

    Pointer<cms::Destination> cmsDest = target.dynamicCast<cms::Destination>();

    std::vector<ActiveMQDestination*> topics2 = AdvisorySupport::getAllDestinationAdvisoryTopics(cmsDest.get());
    CPPUNIT_ASSERT(topics2.size() > 0);

    std::vector<ActiveMQDestination*>::iterator iter2 = topics2.begin();
    for (; iter2 != topics2.end(); ++iter2) {
        Pointer<ActiveMQDestination> topic(*iter2);
        CPPUNIT_ASSERT(topic->isTopic());
        CPPUNIT_ASSERT(topic->isAdvisory() == true);
        CPPUNIT_ASSERT(topic->isTemporary() == false);
        CPPUNIT_ASSERT(topic->getPhysicalName().find(AdvisorySupport::ADVISORY_TOPIC_PREFIX) == 0);
    }

    CPPUNIT_ASSERT_EQUAL(topics.size(), topics2.size());

    CPPUNIT_ASSERT_THROW_MESSAGE(
        "Should throw a NullPointerException when passed a NULL destination",
        AdvisorySupport::getAllDestinationAdvisoryTopics((ActiveMQDestination*)NULL),
        NullPointerException);
    CPPUNIT_ASSERT_THROW_MESSAGE(
        "Should throw a NullPointerException when passed a NULL destination",
        AdvisorySupport::getAllDestinationAdvisoryTopics((cms::Destination*)NULL),
        NullPointerException);
}

////////////////////////////////////////////////////////////////////////////////
void AdvisorySupportTest::testGetConnectionAdvisoryTopic() {

    Pointer<ActiveMQDestination> topic(AdvisorySupport::getConnectionAdvisoryTopic());
    CPPUNIT_ASSERT(topic != NULL);
    CPPUNIT_ASSERT(topic->isAdvisory() == true);
    CPPUNIT_ASSERT(topic->isComposite() == false);
    CPPUNIT_ASSERT(topic->isTopic());
    CPPUNIT_ASSERT(topic->isTemporary() == false);
    CPPUNIT_ASSERT(topic->getPhysicalName().find(AdvisorySupport::ADVISORY_TOPIC_PREFIX) == 0);
    CPPUNIT_ASSERT(topic->getPhysicalName().find(".Connection") != std::string::npos);
}

////////////////////////////////////////////////////////////////////////////////
void AdvisorySupportTest::testGetQueueAdvisoryTopic() {

    Pointer<ActiveMQDestination> topic(AdvisorySupport::getQueueAdvisoryTopic());
    CPPUNIT_ASSERT(topic != NULL);
    CPPUNIT_ASSERT(topic->isComposite() == false);
    CPPUNIT_ASSERT(topic->isAdvisory() == true);
    CPPUNIT_ASSERT(topic->isTopic());
    CPPUNIT_ASSERT(topic->isTemporary() == false);
    CPPUNIT_ASSERT(topic->getPhysicalName().find(AdvisorySupport::ADVISORY_TOPIC_PREFIX) == 0);
    CPPUNIT_ASSERT(topic->getPhysicalName().find(".Queue") != std::string::npos);
}

////////////////////////////////////////////////////////////////////////////////
void AdvisorySupportTest::testGetTopicAdvisoryTopic() {

    Pointer<ActiveMQDestination> topic(AdvisorySupport::getTopicAdvisoryTopic());
    CPPUNIT_ASSERT(topic != NULL);
    CPPUNIT_ASSERT(topic->isComposite() == false);
    CPPUNIT_ASSERT(topic->isTopic());
    CPPUNIT_ASSERT(topic->isAdvisory() == true);
    CPPUNIT_ASSERT(topic->isTemporary() == false);
    CPPUNIT_ASSERT(topic->getPhysicalName().find(AdvisorySupport::ADVISORY_TOPIC_PREFIX) == 0);
    CPPUNIT_ASSERT(topic->getPhysicalName().find(".Topic") != std::string::npos);
}

////////////////////////////////////////////////////////////////////////////////
void AdvisorySupportTest::testGetTempQueueAdvisoryTopic() {

    Pointer<ActiveMQDestination> topic(AdvisorySupport::getTempQueueAdvisoryTopic());
    CPPUNIT_ASSERT(topic != NULL);
    CPPUNIT_ASSERT(topic->isComposite() == false);
    CPPUNIT_ASSERT(topic->isAdvisory() == true);
    CPPUNIT_ASSERT(topic->isTopic());
    CPPUNIT_ASSERT(topic->isTemporary() == false);
    CPPUNIT_ASSERT(topic->getPhysicalName().find(AdvisorySupport::ADVISORY_TOPIC_PREFIX) == 0);
    CPPUNIT_ASSERT(topic->getPhysicalName().find(".TempQueue") != std::string::npos);
}

////////////////////////////////////////////////////////////////////////////////
void AdvisorySupportTest::testGetTempTopicAdvisoryTopic() {

    Pointer<ActiveMQDestination> topic(AdvisorySupport::getTempTopicAdvisoryTopic());
    CPPUNIT_ASSERT(topic != NULL);
    CPPUNIT_ASSERT(topic->isAdvisory() == true);
    CPPUNIT_ASSERT(topic->isComposite() == false);
    CPPUNIT_ASSERT(topic->isTopic());
    CPPUNIT_ASSERT(topic->isTemporary() == false);
    CPPUNIT_ASSERT(topic->getPhysicalName().find(AdvisorySupport::ADVISORY_TOPIC_PREFIX) == 0);
    CPPUNIT_ASSERT(topic->getPhysicalName().find(".TempTopic") != std::string::npos);
}

////////////////////////////////////////////////////////////////////////////////
void AdvisorySupportTest::testGetConsumerAdvisoryTopic() {

    Pointer<ActiveMQDestination> target(new ActiveMQTopic("Test.Topic"));

    Pointer<ActiveMQDestination> topic(AdvisorySupport::getConsumerAdvisoryTopic(target.get()));
    CPPUNIT_ASSERT(topic != NULL);
    CPPUNIT_ASSERT(topic->isComposite() == false);
    CPPUNIT_ASSERT(topic->isAdvisory() == true);
    CPPUNIT_ASSERT(topic->isTopic());
    CPPUNIT_ASSERT(topic->isTemporary() == false);
    CPPUNIT_ASSERT(topic->getPhysicalName().find(AdvisorySupport::CONSUMER_ADVISORY_TOPIC_PREFIX) == 0);
    CPPUNIT_ASSERT(topic->getPhysicalName().find(".Test.Topic") != std::string::npos);

    Pointer<cms::Destination> cmsDest = target.dynamicCast<cms::Destination>();

    Pointer<ActiveMQDestination> cmstopic(AdvisorySupport::getConsumerAdvisoryTopic(cmsDest.get()));
    CPPUNIT_ASSERT(cmstopic != NULL);
    CPPUNIT_ASSERT(cmstopic->isComposite() == false);
    CPPUNIT_ASSERT(cmstopic->isAdvisory() == true);
    CPPUNIT_ASSERT(cmstopic->isTopic());
    CPPUNIT_ASSERT(cmstopic->isTemporary() == false);
    CPPUNIT_ASSERT(cmstopic->getPhysicalName().find(AdvisorySupport::CONSUMER_ADVISORY_TOPIC_PREFIX) == 0);
    CPPUNIT_ASSERT(cmstopic->getPhysicalName().find(".Test.Topic") != std::string::npos);

    CPPUNIT_ASSERT_THROW_MESSAGE(
        "Should throw a NullPointerException when passed a NULL destination",
        AdvisorySupport::getConsumerAdvisoryTopic((ActiveMQDestination*)NULL),
        NullPointerException);
    CPPUNIT_ASSERT_THROW_MESSAGE(
        "Should throw a NullPointerException when passed a NULL destination",
        AdvisorySupport::getConsumerAdvisoryTopic((cms::Destination*)NULL),
        NullPointerException);
}

////////////////////////////////////////////////////////////////////////////////
void AdvisorySupportTest::testGetProducerAdvisoryTopic() {

    Pointer<ActiveMQDestination> target(new ActiveMQTopic("Test.Topic"));

    Pointer<ActiveMQDestination> topic(AdvisorySupport::getProducerAdvisoryTopic(target.get()));
    CPPUNIT_ASSERT(topic != NULL);
    CPPUNIT_ASSERT(topic->isComposite() == false);
    CPPUNIT_ASSERT(topic->isAdvisory() == true);
    CPPUNIT_ASSERT(topic->isTopic());
    CPPUNIT_ASSERT(topic->isTemporary() == false);
    CPPUNIT_ASSERT(topic->getPhysicalName().find(AdvisorySupport::PRODUCER_ADVISORY_TOPIC_PREFIX) == 0);
    CPPUNIT_ASSERT(topic->getPhysicalName().find(".Test.Topic") != std::string::npos);

    Pointer<cms::Destination> cmsDest = target.dynamicCast<cms::Destination>();

    Pointer<ActiveMQDestination> cmstopic(AdvisorySupport::getProducerAdvisoryTopic(cmsDest.get()));
    CPPUNIT_ASSERT(cmstopic != NULL);
    CPPUNIT_ASSERT(cmstopic->isComposite() == false);
    CPPUNIT_ASSERT(cmstopic->isAdvisory() == true);
    CPPUNIT_ASSERT(cmstopic->isTopic());
    CPPUNIT_ASSERT(cmstopic->isTemporary() == false);
    CPPUNIT_ASSERT(cmstopic->getPhysicalName().find(AdvisorySupport::PRODUCER_ADVISORY_TOPIC_PREFIX) == 0);
    CPPUNIT_ASSERT(cmstopic->getPhysicalName().find(".Test.Topic") != std::string::npos);

    CPPUNIT_ASSERT_THROW_MESSAGE(
        "Should throw a NullPointerException when passed a NULL destination",
        AdvisorySupport::getProducerAdvisoryTopic((ActiveMQDestination*)NULL),
        NullPointerException);
    CPPUNIT_ASSERT_THROW_MESSAGE(
        "Should throw a NullPointerException when passed a NULL destination",
        AdvisorySupport::getProducerAdvisoryTopic((cms::Destination*)NULL),
        NullPointerException);
}

////////////////////////////////////////////////////////////////////////////////
void AdvisorySupportTest::testGetExpiredMessageTopic() {

    {
        Pointer<ActiveMQDestination> target(new ActiveMQTopic("Test.Topic"));

        Pointer<ActiveMQDestination> topic(AdvisorySupport::getExpiredMessageTopic(target.get()));
        CPPUNIT_ASSERT(topic != NULL);
        CPPUNIT_ASSERT(topic->isComposite() == false);
        CPPUNIT_ASSERT(topic->isAdvisory() == true);
        CPPUNIT_ASSERT(topic->isTopic());
        CPPUNIT_ASSERT(topic->isTemporary() == false);
        CPPUNIT_ASSERT(topic->getPhysicalName().find(AdvisorySupport::EXPIRED_TOPIC_MESSAGES_TOPIC_PREFIX) == 0);
        CPPUNIT_ASSERT(topic->getPhysicalName().find(".Test.Topic") != std::string::npos);

        Pointer<cms::Destination> cmsDest = target.dynamicCast<cms::Destination>();

        Pointer<ActiveMQDestination> cmstopic(AdvisorySupport::getExpiredMessageTopic(cmsDest.get()));
        CPPUNIT_ASSERT(cmstopic != NULL);
        CPPUNIT_ASSERT(cmstopic->isComposite() == false);
        CPPUNIT_ASSERT(cmstopic->isAdvisory() == true);
        CPPUNIT_ASSERT(cmstopic->isTopic());
        CPPUNIT_ASSERT(cmstopic->isTemporary() == false);
        CPPUNIT_ASSERT(cmstopic->getPhysicalName().find(AdvisorySupport::EXPIRED_TOPIC_MESSAGES_TOPIC_PREFIX) == 0);
        CPPUNIT_ASSERT(cmstopic->getPhysicalName().find(".Test.Topic") != std::string::npos);
    }
    {
        Pointer<ActiveMQDestination> target(new ActiveMQQueue("Test.Queue"));

        Pointer<ActiveMQDestination> topic(AdvisorySupport::getExpiredMessageTopic(target.get()));
        CPPUNIT_ASSERT(topic != NULL);
        CPPUNIT_ASSERT(topic->isComposite() == false);
        CPPUNIT_ASSERT(topic->isAdvisory() == true);
        CPPUNIT_ASSERT(topic->isTopic());
        CPPUNIT_ASSERT(topic->isTemporary() == false);
        CPPUNIT_ASSERT(topic->getPhysicalName().find(AdvisorySupport::EXPIRED_QUEUE_MESSAGES_TOPIC_PREFIX) == 0);
        CPPUNIT_ASSERT(topic->getPhysicalName().find(".Test.Queue") != std::string::npos);

        Pointer<cms::Destination> cmsDest = target.dynamicCast<cms::Destination>();

        Pointer<ActiveMQDestination> cmstopic(AdvisorySupport::getExpiredMessageTopic(cmsDest.get()));
        CPPUNIT_ASSERT(cmstopic != NULL);
        CPPUNIT_ASSERT(cmstopic->isComposite() == false);
        CPPUNIT_ASSERT(cmstopic->isAdvisory() == true);
        CPPUNIT_ASSERT(cmstopic->isTopic());
        CPPUNIT_ASSERT(cmstopic->isTemporary() == false);
        CPPUNIT_ASSERT(cmstopic->getPhysicalName().find(AdvisorySupport::EXPIRED_QUEUE_MESSAGES_TOPIC_PREFIX) == 0);
        CPPUNIT_ASSERT(cmstopic->getPhysicalName().find(".Test.Queue") != std::string::npos);
    }

    CPPUNIT_ASSERT_THROW_MESSAGE(
        "Should throw a NullPointerException when passed a NULL destination",
        AdvisorySupport::getExpiredMessageTopic((ActiveMQDestination*)NULL),
        NullPointerException);
    CPPUNIT_ASSERT_THROW_MESSAGE(
        "Should throw a NullPointerException when passed a NULL destination",
        AdvisorySupport::getExpiredMessageTopic((cms::Destination*)NULL),
        NullPointerException);
}

////////////////////////////////////////////////////////////////////////////////
void AdvisorySupportTest::testGetExpiredTopicMessageAdvisoryTopic() {

    Pointer<ActiveMQDestination> target(new ActiveMQTopic("Test.Topic"));

    Pointer<ActiveMQDestination> topic(AdvisorySupport::getExpiredTopicMessageAdvisoryTopic(target.get()));
    CPPUNIT_ASSERT(topic != NULL);
    CPPUNIT_ASSERT(topic->isComposite() == false);
    CPPUNIT_ASSERT(topic->isAdvisory() == true);
    CPPUNIT_ASSERT(topic->isTopic());
    CPPUNIT_ASSERT(topic->isTemporary() == false);
    CPPUNIT_ASSERT(topic->getPhysicalName().find(AdvisorySupport::EXPIRED_TOPIC_MESSAGES_TOPIC_PREFIX) == 0);
    CPPUNIT_ASSERT(topic->getPhysicalName().find(".Test.Topic") != std::string::npos);

    Pointer<cms::Destination> cmsDest = target.dynamicCast<cms::Destination>();

    Pointer<ActiveMQDestination> cmstopic(AdvisorySupport::getExpiredTopicMessageAdvisoryTopic(cmsDest.get()));
    CPPUNIT_ASSERT(cmstopic != NULL);
    CPPUNIT_ASSERT(cmstopic->isComposite() == false);
    CPPUNIT_ASSERT(cmstopic->isAdvisory() == true);
    CPPUNIT_ASSERT(cmstopic->isTopic());
    CPPUNIT_ASSERT(cmstopic->isTemporary() == false);
    CPPUNIT_ASSERT(cmstopic->getPhysicalName().find(AdvisorySupport::EXPIRED_TOPIC_MESSAGES_TOPIC_PREFIX) == 0);
    CPPUNIT_ASSERT(cmstopic->getPhysicalName().find(".Test.Topic") != std::string::npos);

    CPPUNIT_ASSERT_THROW_MESSAGE(
        "Should throw a NullPointerException when passed a NULL destination",
        AdvisorySupport::getExpiredTopicMessageAdvisoryTopic((ActiveMQDestination*)NULL),
        NullPointerException);
    CPPUNIT_ASSERT_THROW_MESSAGE(
        "Should throw a NullPointerException when passed a NULL destination",
        AdvisorySupport::getExpiredTopicMessageAdvisoryTopic((cms::Destination*)NULL),
        NullPointerException);
}

////////////////////////////////////////////////////////////////////////////////
void AdvisorySupportTest::testGetExpiredQueueMessageAdvisoryTopic() {

    Pointer<ActiveMQDestination> target(new ActiveMQQueue("Test.Queue"));

    Pointer<ActiveMQDestination> topic(AdvisorySupport::getExpiredQueueMessageAdvisoryTopic(target.get()));
    CPPUNIT_ASSERT(topic != NULL);
    CPPUNIT_ASSERT(topic->isComposite() == false);
    CPPUNIT_ASSERT(topic->isAdvisory() == true);
    CPPUNIT_ASSERT(topic->isTopic());
    CPPUNIT_ASSERT(topic->isTemporary() == false);
    CPPUNIT_ASSERT(topic->getPhysicalName().find(AdvisorySupport::EXPIRED_QUEUE_MESSAGES_TOPIC_PREFIX) == 0);
    CPPUNIT_ASSERT(topic->getPhysicalName().find(".Test.Queue") != std::string::npos);

    Pointer<cms::Destination> cmsDest = target.dynamicCast<cms::Destination>();

    Pointer<ActiveMQDestination> cmstopic(AdvisorySupport::getExpiredQueueMessageAdvisoryTopic(cmsDest.get()));
    CPPUNIT_ASSERT(cmstopic != NULL);
    CPPUNIT_ASSERT(cmstopic->isComposite() == false);
    CPPUNIT_ASSERT(cmstopic->isAdvisory() == true);
    CPPUNIT_ASSERT(cmstopic->isTopic());
    CPPUNIT_ASSERT(cmstopic->isTemporary() == false);
    CPPUNIT_ASSERT(cmstopic->getPhysicalName().find(AdvisorySupport::EXPIRED_QUEUE_MESSAGES_TOPIC_PREFIX) == 0);
    CPPUNIT_ASSERT(cmstopic->getPhysicalName().find(".Test.Queue") != std::string::npos);

    CPPUNIT_ASSERT_THROW_MESSAGE(
        "Should throw a NullPointerException when passed a NULL destination",
        AdvisorySupport::getExpiredQueueMessageAdvisoryTopic((ActiveMQDestination*)NULL),
        NullPointerException);
    CPPUNIT_ASSERT_THROW_MESSAGE(
        "Should throw a NullPointerException when passed a NULL destination",
        AdvisorySupport::getExpiredQueueMessageAdvisoryTopic((cms::Destination*)NULL),
        NullPointerException);
}

////////////////////////////////////////////////////////////////////////////////
void AdvisorySupportTest::testGetNoConsumersAdvisoryTopic() {

    {
        Pointer<ActiveMQDestination> target(new ActiveMQTopic("Test.Topic"));

        Pointer<ActiveMQDestination> topic(AdvisorySupport::getNoConsumersAdvisoryTopic(target.get()));
        CPPUNIT_ASSERT(topic != NULL);
        CPPUNIT_ASSERT(topic->isComposite() == false);
        CPPUNIT_ASSERT(topic->isAdvisory() == true);
        CPPUNIT_ASSERT(topic->isTopic());
        CPPUNIT_ASSERT(topic->isTemporary() == false);
        CPPUNIT_ASSERT(topic->getPhysicalName().find(AdvisorySupport::NO_TOPIC_CONSUMERS_TOPIC_PREFIX) == 0);
        CPPUNIT_ASSERT(topic->getPhysicalName().find(".Test.Topic") != std::string::npos);

        Pointer<cms::Destination> cmsDest = target.dynamicCast<cms::Destination>();

        Pointer<ActiveMQDestination> cmstopic(AdvisorySupport::getNoConsumersAdvisoryTopic(cmsDest.get()));
        CPPUNIT_ASSERT(cmstopic != NULL);
        CPPUNIT_ASSERT(cmstopic->isComposite() == false);
        CPPUNIT_ASSERT(cmstopic->isAdvisory() == true);
        CPPUNIT_ASSERT(cmstopic->isTopic());
        CPPUNIT_ASSERT(cmstopic->isTemporary() == false);
        CPPUNIT_ASSERT(cmstopic->getPhysicalName().find(AdvisorySupport::NO_TOPIC_CONSUMERS_TOPIC_PREFIX) == 0);
        CPPUNIT_ASSERT(cmstopic->getPhysicalName().find(".Test.Topic") != std::string::npos);
    }
    {
        Pointer<ActiveMQDestination> target(new ActiveMQQueue("Test.Queue"));

        Pointer<ActiveMQDestination> topic(AdvisorySupport::getNoConsumersAdvisoryTopic(target.get()));
        CPPUNIT_ASSERT(topic != NULL);
        CPPUNIT_ASSERT(topic->isComposite() == false);
        CPPUNIT_ASSERT(topic->isAdvisory() == true);
        CPPUNIT_ASSERT(topic->isTopic());
        CPPUNIT_ASSERT(topic->isTemporary() == false);
        CPPUNIT_ASSERT(topic->getPhysicalName().find(AdvisorySupport::NO_QUEUE_CONSUMERS_TOPIC_PREFIX) == 0);
        CPPUNIT_ASSERT(topic->getPhysicalName().find(".Test.Queue") != std::string::npos);

        Pointer<cms::Destination> cmsDest = target.dynamicCast<cms::Destination>();

        Pointer<ActiveMQDestination> cmstopic(AdvisorySupport::getNoConsumersAdvisoryTopic(cmsDest.get()));
        CPPUNIT_ASSERT(cmstopic != NULL);
        CPPUNIT_ASSERT(cmstopic->isComposite() == false);
        CPPUNIT_ASSERT(cmstopic->isAdvisory() == true);
        CPPUNIT_ASSERT(cmstopic->isTopic());
        CPPUNIT_ASSERT(cmstopic->isTemporary() == false);
        CPPUNIT_ASSERT(cmstopic->getPhysicalName().find(AdvisorySupport::NO_QUEUE_CONSUMERS_TOPIC_PREFIX) == 0);
        CPPUNIT_ASSERT(cmstopic->getPhysicalName().find(".Test.Queue") != std::string::npos);
    }

    CPPUNIT_ASSERT_THROW_MESSAGE(
        "Should throw a NullPointerException when passed a NULL destination",
        AdvisorySupport::getNoConsumersAdvisoryTopic((ActiveMQDestination*)NULL),
        NullPointerException);
    CPPUNIT_ASSERT_THROW_MESSAGE(
        "Should throw a NullPointerException when passed a NULL destination",
        AdvisorySupport::getNoConsumersAdvisoryTopic((cms::Destination*)NULL),
        NullPointerException);
}

////////////////////////////////////////////////////////////////////////////////
void AdvisorySupportTest::testGetNoTopicConsumersAdvisoryTopic() {

    Pointer<ActiveMQDestination> target(new ActiveMQTopic("Test.Topic"));

    Pointer<ActiveMQDestination> topic(AdvisorySupport::getNoTopicConsumersAdvisoryTopic(target.get()));
    CPPUNIT_ASSERT(topic != NULL);
    CPPUNIT_ASSERT(topic->isComposite() == false);
    CPPUNIT_ASSERT(topic->isAdvisory() == true);
    CPPUNIT_ASSERT(topic->isTopic());
    CPPUNIT_ASSERT(topic->isTemporary() == false);
    CPPUNIT_ASSERT(topic->getPhysicalName().find(AdvisorySupport::NO_TOPIC_CONSUMERS_TOPIC_PREFIX) == 0);
    CPPUNIT_ASSERT(topic->getPhysicalName().find(".Test.Topic") != std::string::npos);

    Pointer<cms::Destination> cmsDest = target.dynamicCast<cms::Destination>();

    Pointer<ActiveMQDestination> cmstopic(AdvisorySupport::getNoTopicConsumersAdvisoryTopic(cmsDest.get()));
    CPPUNIT_ASSERT(cmstopic != NULL);
    CPPUNIT_ASSERT(cmstopic->isComposite() == false);
    CPPUNIT_ASSERT(cmstopic->isAdvisory() == true);
    CPPUNIT_ASSERT(cmstopic->isTopic());
    CPPUNIT_ASSERT(cmstopic->isTemporary() == false);
    CPPUNIT_ASSERT(cmstopic->getPhysicalName().find(AdvisorySupport::NO_TOPIC_CONSUMERS_TOPIC_PREFIX) == 0);
    CPPUNIT_ASSERT(cmstopic->getPhysicalName().find(".Test.Topic") != std::string::npos);

    CPPUNIT_ASSERT_THROW_MESSAGE(
        "Should throw a NullPointerException when passed a NULL destination",
        AdvisorySupport::getNoTopicConsumersAdvisoryTopic((ActiveMQDestination*)NULL),
        NullPointerException);
    CPPUNIT_ASSERT_THROW_MESSAGE(
        "Should throw a NullPointerException when passed a NULL destination",
        AdvisorySupport::getNoTopicConsumersAdvisoryTopic((cms::Destination*)NULL),
        NullPointerException);
}

////////////////////////////////////////////////////////////////////////////////
void AdvisorySupportTest::testGetNoQueueConsumersAdvisoryTopic() {

    Pointer<ActiveMQDestination> target(new ActiveMQQueue("Test.Queue"));

    Pointer<ActiveMQDestination> topic(AdvisorySupport::getNoQueueConsumersAdvisoryTopic(target.get()));
    CPPUNIT_ASSERT(topic != NULL);
    CPPUNIT_ASSERT(topic->isComposite() == false);
    CPPUNIT_ASSERT(topic->isAdvisory() == true);
    CPPUNIT_ASSERT(topic->isTopic());
    CPPUNIT_ASSERT(topic->isTemporary() == false);
    CPPUNIT_ASSERT(topic->getPhysicalName().find(AdvisorySupport::NO_QUEUE_CONSUMERS_TOPIC_PREFIX) == 0);
    CPPUNIT_ASSERT(topic->getPhysicalName().find(".Test.Queue") != std::string::npos);

    Pointer<cms::Destination> cmsDest = target.dynamicCast<cms::Destination>();

    Pointer<ActiveMQDestination> cmstopic(AdvisorySupport::getNoQueueConsumersAdvisoryTopic(cmsDest.get()));
    CPPUNIT_ASSERT(cmstopic != NULL);
    CPPUNIT_ASSERT(cmstopic->isComposite() == false);
    CPPUNIT_ASSERT(cmstopic->isAdvisory() == true);
    CPPUNIT_ASSERT(cmstopic->isTopic());
    CPPUNIT_ASSERT(cmstopic->isTemporary() == false);
    CPPUNIT_ASSERT(cmstopic->getPhysicalName().find(AdvisorySupport::NO_QUEUE_CONSUMERS_TOPIC_PREFIX) == 0);
    CPPUNIT_ASSERT(cmstopic->getPhysicalName().find(".Test.Queue") != std::string::npos);

    CPPUNIT_ASSERT_THROW_MESSAGE(
        "Should throw a NullPointerException when passed a NULL destination",
        AdvisorySupport::getNoQueueConsumersAdvisoryTopic((ActiveMQDestination*)NULL),
        NullPointerException);
    CPPUNIT_ASSERT_THROW_MESSAGE(
        "Should throw a NullPointerException when passed a NULL destination",
        AdvisorySupport::getNoQueueConsumersAdvisoryTopic((cms::Destination*)NULL),
        NullPointerException);
}

////////////////////////////////////////////////////////////////////////////////
void AdvisorySupportTest::testGetSlowConsumerAdvisoryTopic() {

    Pointer<ActiveMQDestination> target(new ActiveMQTopic("Test.Topic"));

    Pointer<ActiveMQDestination> topic(AdvisorySupport::getSlowConsumerAdvisoryTopic(target.get()));
    CPPUNIT_ASSERT(topic != NULL);
    CPPUNIT_ASSERT(topic->isComposite() == false);
    CPPUNIT_ASSERT(topic->isAdvisory() == true);
    CPPUNIT_ASSERT(topic->isTopic());
    CPPUNIT_ASSERT(topic->isTemporary() == false);
    CPPUNIT_ASSERT(topic->getPhysicalName().find(AdvisorySupport::SLOW_CONSUMER_TOPIC_PREFIX) == 0);
    CPPUNIT_ASSERT(topic->getPhysicalName().find(".Test.Topic") != std::string::npos);

    Pointer<cms::Destination> cmsDest = target.dynamicCast<cms::Destination>();

    Pointer<ActiveMQDestination> cmstopic(AdvisorySupport::getSlowConsumerAdvisoryTopic(cmsDest.get()));
    CPPUNIT_ASSERT(cmstopic != NULL);
    CPPUNIT_ASSERT(cmstopic->isComposite() == false);
    CPPUNIT_ASSERT(cmstopic->isAdvisory() == true);
    CPPUNIT_ASSERT(cmstopic->isTopic());
    CPPUNIT_ASSERT(cmstopic->isTemporary() == false);
    CPPUNIT_ASSERT(cmstopic->getPhysicalName().find(AdvisorySupport::SLOW_CONSUMER_TOPIC_PREFIX) == 0);
    CPPUNIT_ASSERT(cmstopic->getPhysicalName().find(".Test.Topic") != std::string::npos);

    CPPUNIT_ASSERT_THROW_MESSAGE(
        "Should throw a NullPointerException when passed a NULL destination",
        AdvisorySupport::getSlowConsumerAdvisoryTopic((ActiveMQDestination*)NULL),
        NullPointerException);
    CPPUNIT_ASSERT_THROW_MESSAGE(
        "Should throw a NullPointerException when passed a NULL destination",
        AdvisorySupport::getSlowConsumerAdvisoryTopic((cms::Destination*)NULL),
        NullPointerException);
}

////////////////////////////////////////////////////////////////////////////////
void AdvisorySupportTest::testGetFastProducerAdvisoryTopic() {

    Pointer<ActiveMQDestination> target(new ActiveMQTopic("Test.Topic"));

    Pointer<ActiveMQDestination> topic(AdvisorySupport::getFastProducerAdvisoryTopic(target.get()));
    CPPUNIT_ASSERT(topic != NULL);
    CPPUNIT_ASSERT(topic->isComposite() == false);
    CPPUNIT_ASSERT(topic->isAdvisory() == true);
    CPPUNIT_ASSERT(topic->isTopic());
    CPPUNIT_ASSERT(topic->isTemporary() == false);
    CPPUNIT_ASSERT(topic->getPhysicalName().find(AdvisorySupport::FAST_PRODUCER_TOPIC_PREFIX) == 0);
    CPPUNIT_ASSERT(topic->getPhysicalName().find(".Test.Topic") != std::string::npos);

    Pointer<cms::Destination> cmsDest = target.dynamicCast<cms::Destination>();

    Pointer<ActiveMQDestination> cmstopic(AdvisorySupport::getFastProducerAdvisoryTopic(cmsDest.get()));
    CPPUNIT_ASSERT(cmstopic != NULL);
    CPPUNIT_ASSERT(cmstopic->isComposite() == false);
    CPPUNIT_ASSERT(cmstopic->isAdvisory() == true);
    CPPUNIT_ASSERT(cmstopic->isTopic());
    CPPUNIT_ASSERT(cmstopic->isTemporary() == false);
    CPPUNIT_ASSERT(cmstopic->getPhysicalName().find(AdvisorySupport::FAST_PRODUCER_TOPIC_PREFIX) == 0);
    CPPUNIT_ASSERT(cmstopic->getPhysicalName().find(".Test.Topic") != std::string::npos);

    CPPUNIT_ASSERT_THROW_MESSAGE(
        "Should throw a NullPointerException when passed a NULL destination",
        AdvisorySupport::getFastProducerAdvisoryTopic((ActiveMQDestination*)NULL),
        NullPointerException);
    CPPUNIT_ASSERT_THROW_MESSAGE(
        "Should throw a NullPointerException when passed a NULL destination",
        AdvisorySupport::getFastProducerAdvisoryTopic((cms::Destination*)NULL),
        NullPointerException);
}

////////////////////////////////////////////////////////////////////////////////
void AdvisorySupportTest::testGetMessageDiscardedAdvisoryTopic() {

    Pointer<ActiveMQDestination> target(new ActiveMQTopic("Test.Topic"));

    Pointer<ActiveMQDestination> topic(AdvisorySupport::getMessageDiscardedAdvisoryTopic(target.get()));
    CPPUNIT_ASSERT(topic != NULL);
    CPPUNIT_ASSERT(topic->isComposite() == false);
    CPPUNIT_ASSERT(topic->isAdvisory() == true);
    CPPUNIT_ASSERT(topic->isTopic());
    CPPUNIT_ASSERT(topic->isTemporary() == false);
    CPPUNIT_ASSERT(topic->getPhysicalName().find(AdvisorySupport::MESSAGE_DISCAREDED_TOPIC_PREFIX) == 0);
    CPPUNIT_ASSERT(topic->getPhysicalName().find(".Test.Topic") != std::string::npos);

    Pointer<cms::Destination> cmsDest = target.dynamicCast<cms::Destination>();

    Pointer<ActiveMQDestination> cmstopic(AdvisorySupport::getMessageDiscardedAdvisoryTopic(cmsDest.get()));
    CPPUNIT_ASSERT(cmstopic != NULL);
    CPPUNIT_ASSERT(cmstopic->isComposite() == false);
    CPPUNIT_ASSERT(cmstopic->isAdvisory() == true);
    CPPUNIT_ASSERT(cmstopic->isTopic());
    CPPUNIT_ASSERT(cmstopic->isTemporary() == false);
    CPPUNIT_ASSERT(cmstopic->getPhysicalName().find(AdvisorySupport::MESSAGE_DISCAREDED_TOPIC_PREFIX) == 0);
    CPPUNIT_ASSERT(cmstopic->getPhysicalName().find(".Test.Topic") != std::string::npos);

    CPPUNIT_ASSERT_THROW_MESSAGE(
        "Should throw a NullPointerException when passed a NULL destination",
        AdvisorySupport::getMessageDiscardedAdvisoryTopic((ActiveMQDestination*)NULL),
        NullPointerException);
    CPPUNIT_ASSERT_THROW_MESSAGE(
        "Should throw a NullPointerException when passed a NULL destination",
        AdvisorySupport::getMessageDiscardedAdvisoryTopic((cms::Destination*)NULL),
        NullPointerException);
}

////////////////////////////////////////////////////////////////////////////////
void AdvisorySupportTest::testGetMessageDeliveredAdvisoryTopic() {

    Pointer<ActiveMQDestination> target(new ActiveMQTopic("Test.Topic"));

    Pointer<ActiveMQDestination> topic(AdvisorySupport::getMessageDeliveredAdvisoryTopic(target.get()));
    CPPUNIT_ASSERT(topic != NULL);
    CPPUNIT_ASSERT(topic->isComposite() == false);
    CPPUNIT_ASSERT(topic->isAdvisory() == true);
    CPPUNIT_ASSERT(topic->isTopic());
    CPPUNIT_ASSERT(topic->isTemporary() == false);
    CPPUNIT_ASSERT(topic->getPhysicalName().find(AdvisorySupport::MESSAGE_DELIVERED_TOPIC_PREFIX) == 0);
    CPPUNIT_ASSERT(topic->getPhysicalName().find(".Test.Topic") != std::string::npos);

    Pointer<cms::Destination> cmsDest = target.dynamicCast<cms::Destination>();

    Pointer<ActiveMQDestination> cmstopic(AdvisorySupport::getMessageDeliveredAdvisoryTopic(cmsDest.get()));
    CPPUNIT_ASSERT(cmstopic != NULL);
    CPPUNIT_ASSERT(cmstopic->isComposite() == false);
    CPPUNIT_ASSERT(cmstopic->isAdvisory() == true);
    CPPUNIT_ASSERT(cmstopic->isTopic());
    CPPUNIT_ASSERT(cmstopic->isTemporary() == false);
    CPPUNIT_ASSERT(cmstopic->getPhysicalName().find(AdvisorySupport::MESSAGE_DELIVERED_TOPIC_PREFIX) == 0);
    CPPUNIT_ASSERT(cmstopic->getPhysicalName().find(".Test.Topic") != std::string::npos);

    CPPUNIT_ASSERT_THROW_MESSAGE(
        "Should throw a NullPointerException when passed a NULL destination",
        AdvisorySupport::getMessageDeliveredAdvisoryTopic((ActiveMQDestination*)NULL),
        NullPointerException);
    CPPUNIT_ASSERT_THROW_MESSAGE(
        "Should throw a NullPointerException when passed a NULL destination",
        AdvisorySupport::getMessageDeliveredAdvisoryTopic((cms::Destination*)NULL),
        NullPointerException);
}

////////////////////////////////////////////////////////////////////////////////
void AdvisorySupportTest::testGetMessageConsumedAdvisoryTopic() {

    Pointer<ActiveMQDestination> target(new ActiveMQTopic("Test.Topic"));

    Pointer<ActiveMQDestination> topic(AdvisorySupport::getMessageConsumedAdvisoryTopic(target.get()));
    CPPUNIT_ASSERT(topic != NULL);
    CPPUNIT_ASSERT(topic->isComposite() == false);
    CPPUNIT_ASSERT(topic->isAdvisory() == true);
    CPPUNIT_ASSERT(topic->isTopic());
    CPPUNIT_ASSERT(topic->isTemporary() == false);
    CPPUNIT_ASSERT(topic->getPhysicalName().find(AdvisorySupport::MESSAGE_CONSUMED_TOPIC_PREFIX) == 0);
    CPPUNIT_ASSERT(topic->getPhysicalName().find(".Test.Topic") != std::string::npos);

    Pointer<cms::Destination> cmsDest = target.dynamicCast<cms::Destination>();

    Pointer<ActiveMQDestination> cmstopic(AdvisorySupport::getMessageConsumedAdvisoryTopic(cmsDest.get()));
    CPPUNIT_ASSERT(cmstopic != NULL);
    CPPUNIT_ASSERT(cmstopic->isComposite() == false);
    CPPUNIT_ASSERT(cmstopic->isAdvisory() == true);
    CPPUNIT_ASSERT(cmstopic->isTopic());
    CPPUNIT_ASSERT(cmstopic->isTemporary() == false);
    CPPUNIT_ASSERT(cmstopic->getPhysicalName().find(AdvisorySupport::MESSAGE_CONSUMED_TOPIC_PREFIX) == 0);
    CPPUNIT_ASSERT(cmstopic->getPhysicalName().find(".Test.Topic") != std::string::npos);

    CPPUNIT_ASSERT_THROW_MESSAGE(
        "Should throw a NullPointerException when passed a NULL destination",
        AdvisorySupport::getMessageConsumedAdvisoryTopic((ActiveMQDestination*)NULL),
        NullPointerException);
    CPPUNIT_ASSERT_THROW_MESSAGE(
        "Should throw a NullPointerException when passed a NULL destination",
        AdvisorySupport::getMessageConsumedAdvisoryTopic((cms::Destination*)NULL),
        NullPointerException);
}

////////////////////////////////////////////////////////////////////////////////
void AdvisorySupportTest::testGetMessageDLQdAdvisoryTopic() {

    Pointer<ActiveMQDestination> target(new ActiveMQTopic("Test.Topic"));

    Pointer<ActiveMQDestination> topic(AdvisorySupport::getMessageDLQdAdvisoryTopic(target.get()));
    CPPUNIT_ASSERT(topic != NULL);
    CPPUNIT_ASSERT(topic->isComposite() == false);
    CPPUNIT_ASSERT(topic->isAdvisory() == true);
    CPPUNIT_ASSERT(topic->isTopic());
    CPPUNIT_ASSERT(topic->isTemporary() == false);
    CPPUNIT_ASSERT(topic->getPhysicalName().find(AdvisorySupport::MESSAGE_DLQ_TOPIC_PREFIX) == 0);
    CPPUNIT_ASSERT(topic->getPhysicalName().find(".Test.Topic") != std::string::npos);

    Pointer<cms::Destination> cmsDest = target.dynamicCast<cms::Destination>();

    Pointer<ActiveMQDestination> cmstopic(AdvisorySupport::getMessageDLQdAdvisoryTopic(cmsDest.get()));
    CPPUNIT_ASSERT(cmstopic != NULL);
    CPPUNIT_ASSERT(cmstopic->isComposite() == false);
    CPPUNIT_ASSERT(cmstopic->isAdvisory() == true);
    CPPUNIT_ASSERT(cmstopic->isTopic());
    CPPUNIT_ASSERT(cmstopic->isTemporary() == false);
    CPPUNIT_ASSERT(cmstopic->getPhysicalName().find(AdvisorySupport::MESSAGE_DLQ_TOPIC_PREFIX) == 0);
    CPPUNIT_ASSERT(cmstopic->getPhysicalName().find(".Test.Topic") != std::string::npos);

    CPPUNIT_ASSERT_THROW_MESSAGE(
        "Should throw a NullPointerException when passed a NULL destination",
        AdvisorySupport::getMessageDLQdAdvisoryTopic((ActiveMQDestination*)NULL),
        NullPointerException);
    CPPUNIT_ASSERT_THROW_MESSAGE(
        "Should throw a NullPointerException when passed a NULL destination",
        AdvisorySupport::getMessageDLQdAdvisoryTopic((cms::Destination*)NULL),
        NullPointerException);
}

////////////////////////////////////////////////////////////////////////////////
void AdvisorySupportTest::testGetMasterBrokerAdvisoryTopic() {

    Pointer<ActiveMQDestination> topic(AdvisorySupport::getMasterBrokerAdvisoryTopic());
    CPPUNIT_ASSERT(topic != NULL);
    CPPUNIT_ASSERT(topic->isComposite() == false);
    CPPUNIT_ASSERT(topic->isAdvisory() == true);
    CPPUNIT_ASSERT(topic->isTopic());
    CPPUNIT_ASSERT(topic->isTemporary() == false);
    CPPUNIT_ASSERT(topic->getPhysicalName().find(AdvisorySupport::MASTER_BROKER_TOPIC_PREFIX) == 0);
}

////////////////////////////////////////////////////////////////////////////////
void AdvisorySupportTest::testGetNetworkBridgeAdvisoryTopic() {

    Pointer<ActiveMQDestination> topic(AdvisorySupport::getNetworkBridgeAdvisoryTopic());
    CPPUNIT_ASSERT(topic != NULL);
    CPPUNIT_ASSERT(topic->isComposite() == false);
    CPPUNIT_ASSERT(topic->isAdvisory() == true);
    CPPUNIT_ASSERT(topic->isTopic());
    CPPUNIT_ASSERT(topic->isTemporary() == false);
    CPPUNIT_ASSERT(topic->getPhysicalName().find(AdvisorySupport::NETWORK_BRIDGE_TOPIC_PREFIX) == 0);
}

////////////////////////////////////////////////////////////////////////////////
void AdvisorySupportTest::testGetFullAdvisoryTopic() {

    Pointer<ActiveMQDestination> target(new ActiveMQTopic("Test.Topic"));

    Pointer<ActiveMQDestination> topic(AdvisorySupport::getFullAdvisoryTopic(target.get()));
    CPPUNIT_ASSERT(topic != NULL);
    CPPUNIT_ASSERT(topic->isComposite() == false);
    CPPUNIT_ASSERT(topic->isAdvisory() == true);
    CPPUNIT_ASSERT(topic->isTopic());
    CPPUNIT_ASSERT(topic->isTemporary() == false);
    CPPUNIT_ASSERT(topic->getPhysicalName().find(AdvisorySupport::FULL_TOPIC_PREFIX) == 0);
    CPPUNIT_ASSERT(topic->getPhysicalName().find(".Test.Topic") != std::string::npos);

    Pointer<cms::Destination> cmsDest = target.dynamicCast<cms::Destination>();

    Pointer<ActiveMQDestination> cmstopic(AdvisorySupport::getFullAdvisoryTopic(cmsDest.get()));
    CPPUNIT_ASSERT(cmstopic != NULL);
    CPPUNIT_ASSERT(cmstopic->isComposite() == false);
    CPPUNIT_ASSERT(cmstopic->isAdvisory() == true);
    CPPUNIT_ASSERT(cmstopic->isTopic());
    CPPUNIT_ASSERT(cmstopic->isTemporary() == false);
    CPPUNIT_ASSERT(cmstopic->getPhysicalName().find(AdvisorySupport::FULL_TOPIC_PREFIX) == 0);
    CPPUNIT_ASSERT(cmstopic->getPhysicalName().find(".Test.Topic") != std::string::npos);

    CPPUNIT_ASSERT_THROW_MESSAGE(
        "Should throw a NullPointerException when passed a NULL destination",
        AdvisorySupport::getFullAdvisoryTopic((ActiveMQDestination*)NULL),
        NullPointerException);
    CPPUNIT_ASSERT_THROW_MESSAGE(
        "Should throw a NullPointerException when passed a NULL destination",
        AdvisorySupport::getFullAdvisoryTopic((cms::Destination*)NULL),
        NullPointerException);
}

////////////////////////////////////////////////////////////////////////////////
void AdvisorySupportTest::testGetDestinationAdvisoryTopic() {

    Pointer<ActiveMQDestination> target(new ActiveMQTopic("Test.Topic"));

    Pointer<ActiveMQDestination> topic(AdvisorySupport::getDestinationAdvisoryTopic(target.get()));
    CPPUNIT_ASSERT(topic != NULL);
    CPPUNIT_ASSERT(topic->isComposite() == false);
    CPPUNIT_ASSERT(topic->isAdvisory() == true);
    CPPUNIT_ASSERT(topic->isTopic());
    CPPUNIT_ASSERT(topic->isTemporary() == false);
    CPPUNIT_ASSERT(topic->getPhysicalName().find(AdvisorySupport::ADVISORY_TOPIC_PREFIX) == 0);
    CPPUNIT_ASSERT(topic->getPhysicalName().find(".Topic") != std::string::npos);

    Pointer<cms::Destination> cmsDest = target.dynamicCast<cms::Destination>();

    Pointer<ActiveMQDestination> cmstopic(AdvisorySupport::getDestinationAdvisoryTopic(cmsDest.get()));
    CPPUNIT_ASSERT(cmstopic != NULL);
    CPPUNIT_ASSERT(cmstopic->isComposite() == false);
    CPPUNIT_ASSERT(cmstopic->isAdvisory() == true);
    CPPUNIT_ASSERT(cmstopic->isTopic());
    CPPUNIT_ASSERT(cmstopic->isTemporary() == false);
    CPPUNIT_ASSERT(cmstopic->getPhysicalName().find(AdvisorySupport::ADVISORY_TOPIC_PREFIX) == 0);
    CPPUNIT_ASSERT(cmstopic->getPhysicalName().find(".Topic") != std::string::npos);

    CPPUNIT_ASSERT_THROW_MESSAGE(
        "Should throw a NullPointerException when passed a NULL destination",
        AdvisorySupport::getDestinationAdvisoryTopic((ActiveMQDestination*)NULL),
        NullPointerException);
    CPPUNIT_ASSERT_THROW_MESSAGE(
        "Should throw a NullPointerException when passed a NULL destination",
        AdvisorySupport::getDestinationAdvisoryTopic((cms::Destination*)NULL),
        NullPointerException);
}

////////////////////////////////////////////////////////////////////////////////
void AdvisorySupportTest::testIsDestinationAdvisoryTopic() {

    Pointer<ActiveMQDestination> target(new ActiveMQTopic("Test.Topic"));
    Pointer<ActiveMQDestination> topic(AdvisorySupport::getDestinationAdvisoryTopic(target.get()));
    CPPUNIT_ASSERT(!AdvisorySupport::isDestinationAdvisoryTopic(target.get()));
    CPPUNIT_ASSERT(AdvisorySupport::isDestinationAdvisoryTopic(topic.get()));

    Pointer<cms::Destination> cmsDest = target.dynamicCast<cms::Destination>();
    Pointer<ActiveMQDestination> cmstopic(AdvisorySupport::getDestinationAdvisoryTopic(cmsDest.get()));
    CPPUNIT_ASSERT(!AdvisorySupport::isDestinationAdvisoryTopic(cmsDest.get()));
    CPPUNIT_ASSERT(AdvisorySupport::isDestinationAdvisoryTopic(cmstopic.get()));

    CPPUNIT_ASSERT_THROW_MESSAGE(
        "Should throw a NullPointerException when passed a NULL destination",
        AdvisorySupport::isDestinationAdvisoryTopic((ActiveMQDestination*)NULL),
        NullPointerException);
    CPPUNIT_ASSERT_THROW_MESSAGE(
        "Should throw a NullPointerException when passed a NULL destination",
        AdvisorySupport::isDestinationAdvisoryTopic((cms::Destination*)NULL),
        NullPointerException);
}

////////////////////////////////////////////////////////////////////////////////
void AdvisorySupportTest::testIsTempDestinationAdvisoryTopic() {

    Pointer<ActiveMQDestination> target(new ActiveMQTempTopic("Test.Topic"));
    Pointer<ActiveMQDestination> topic(AdvisorySupport::getDestinationAdvisoryTopic(target.get()));
    CPPUNIT_ASSERT(!AdvisorySupport::isTempDestinationAdvisoryTopic(target.get()));
    CPPUNIT_ASSERT(AdvisorySupport::isTempDestinationAdvisoryTopic(topic.get()));

    Pointer<cms::Destination> cmsDest = target.dynamicCast<cms::Destination>();
    Pointer<ActiveMQDestination> cmstopic(AdvisorySupport::getDestinationAdvisoryTopic(cmsDest.get()));
    CPPUNIT_ASSERT(!AdvisorySupport::isTempDestinationAdvisoryTopic(cmsDest.get()));
    CPPUNIT_ASSERT(AdvisorySupport::isTempDestinationAdvisoryTopic(cmstopic.get()));

    CPPUNIT_ASSERT_THROW_MESSAGE(
        "Should throw a NullPointerException when passed a NULL destination",
        AdvisorySupport::isTempDestinationAdvisoryTopic((ActiveMQDestination*)NULL),
        NullPointerException);
    CPPUNIT_ASSERT_THROW_MESSAGE(
        "Should throw a NullPointerException when passed a NULL destination",
        AdvisorySupport::isTempDestinationAdvisoryTopic((cms::Destination*)NULL),
        NullPointerException);
}

////////////////////////////////////////////////////////////////////////////////
void AdvisorySupportTest::testIsAdvisoryTopic() {

    Pointer<ActiveMQDestination> target(new ActiveMQTempTopic("Test.Topic"));
    Pointer<ActiveMQDestination> topic(AdvisorySupport::getConsumerAdvisoryTopic(target.get()));
    CPPUNIT_ASSERT(!AdvisorySupport::isAdvisoryTopic(target.get()));
    CPPUNIT_ASSERT(AdvisorySupport::isAdvisoryTopic(topic.get()));

    Pointer<cms::Destination> cmsDest = target.dynamicCast<cms::Destination>();
    Pointer<ActiveMQDestination> cmstopic(AdvisorySupport::getConsumerAdvisoryTopic(cmsDest.get()));
    CPPUNIT_ASSERT(!AdvisorySupport::isAdvisoryTopic(cmsDest.get()));
    CPPUNIT_ASSERT(AdvisorySupport::isAdvisoryTopic(cmstopic.get()));

    CPPUNIT_ASSERT_THROW_MESSAGE(
        "Should throw a NullPointerException when passed a NULL destination",
        AdvisorySupport::isAdvisoryTopic((ActiveMQDestination*)NULL),
        NullPointerException);
    CPPUNIT_ASSERT_THROW_MESSAGE(
        "Should throw a NullPointerException when passed a NULL destination",
        AdvisorySupport::isAdvisoryTopic((cms::Destination*)NULL),
        NullPointerException);
}

////////////////////////////////////////////////////////////////////////////////
void AdvisorySupportTest::testIsConnectionAdvisoryTopic() {

    Pointer<ActiveMQDestination> target(new ActiveMQTempTopic("Test.Topic"));
    Pointer<ActiveMQDestination> topic(AdvisorySupport::getConnectionAdvisoryTopic());
    CPPUNIT_ASSERT(!AdvisorySupport::isConnectionAdvisoryTopic(target.get()));
    CPPUNIT_ASSERT(AdvisorySupport::isConnectionAdvisoryTopic(topic.get()));

    Pointer<cms::Destination> cmsDest = target.dynamicCast<cms::Destination>();
    Pointer<ActiveMQDestination> cmstopic(AdvisorySupport::getConnectionAdvisoryTopic());
    CPPUNIT_ASSERT(!AdvisorySupport::isConnectionAdvisoryTopic(cmsDest.get()));
    CPPUNIT_ASSERT(AdvisorySupport::isConnectionAdvisoryTopic(cmstopic.get()));

    CPPUNIT_ASSERT_THROW_MESSAGE(
        "Should throw a NullPointerException when passed a NULL destination",
        AdvisorySupport::isConnectionAdvisoryTopic((ActiveMQDestination*)NULL),
        NullPointerException);
    CPPUNIT_ASSERT_THROW_MESSAGE(
        "Should throw a NullPointerException when passed a NULL destination",
        AdvisorySupport::isConnectionAdvisoryTopic((cms::Destination*)NULL),
        NullPointerException);
}

////////////////////////////////////////////////////////////////////////////////
void AdvisorySupportTest::testIsProducerAdvisoryTopic() {

    Pointer<ActiveMQDestination> target(new ActiveMQTempTopic("Test.Topic"));
    Pointer<ActiveMQDestination> topic(AdvisorySupport::getProducerAdvisoryTopic(target.get()));
    CPPUNIT_ASSERT(!AdvisorySupport::isProducerAdvisoryTopic(target.get()));
    CPPUNIT_ASSERT(AdvisorySupport::isProducerAdvisoryTopic(topic.get()));

    Pointer<cms::Destination> cmsDest = target.dynamicCast<cms::Destination>();
    Pointer<ActiveMQDestination> cmstopic(AdvisorySupport::getProducerAdvisoryTopic(cmsDest.get()));
    CPPUNIT_ASSERT(!AdvisorySupport::isProducerAdvisoryTopic(cmsDest.get()));
    CPPUNIT_ASSERT(AdvisorySupport::isProducerAdvisoryTopic(cmstopic.get()));

    CPPUNIT_ASSERT_THROW_MESSAGE(
        "Should throw a NullPointerException when passed a NULL destination",
        AdvisorySupport::isProducerAdvisoryTopic((ActiveMQDestination*)NULL),
        NullPointerException);
    CPPUNIT_ASSERT_THROW_MESSAGE(
        "Should throw a NullPointerException when passed a NULL destination",
        AdvisorySupport::isProducerAdvisoryTopic((cms::Destination*)NULL),
        NullPointerException);
}

////////////////////////////////////////////////////////////////////////////////
void AdvisorySupportTest::testIsConsumerAdvisoryTopic() {

    Pointer<ActiveMQDestination> target(new ActiveMQTempTopic("Test.Topic"));
    Pointer<ActiveMQDestination> topic(AdvisorySupport::getConsumerAdvisoryTopic(target.get()));
    CPPUNIT_ASSERT(!AdvisorySupport::isConsumerAdvisoryTopic(target.get()));
    CPPUNIT_ASSERT(AdvisorySupport::isConsumerAdvisoryTopic(topic.get()));

    Pointer<cms::Destination> cmsDest = target.dynamicCast<cms::Destination>();
    Pointer<ActiveMQDestination> cmstopic(AdvisorySupport::getConsumerAdvisoryTopic(cmsDest.get()));
    CPPUNIT_ASSERT(!AdvisorySupport::isConsumerAdvisoryTopic(cmsDest.get()));
    CPPUNIT_ASSERT(AdvisorySupport::isConsumerAdvisoryTopic(cmstopic.get()));

    CPPUNIT_ASSERT_THROW_MESSAGE(
        "Should throw a NullPointerException when passed a NULL destination",
        AdvisorySupport::isConsumerAdvisoryTopic((ActiveMQDestination*)NULL),
        NullPointerException);
    CPPUNIT_ASSERT_THROW_MESSAGE(
        "Should throw a NullPointerException when passed a NULL destination",
        AdvisorySupport::isConsumerAdvisoryTopic((cms::Destination*)NULL),
        NullPointerException);
}

////////////////////////////////////////////////////////////////////////////////
void AdvisorySupportTest::testIsSlowConsumerAdvisoryTopic() {

    Pointer<ActiveMQDestination> target(new ActiveMQTempTopic("Test.Topic"));
    Pointer<ActiveMQDestination> topic(AdvisorySupport::getSlowConsumerAdvisoryTopic(target.get()));
    CPPUNIT_ASSERT(!AdvisorySupport::isSlowConsumerAdvisoryTopic(target.get()));
    CPPUNIT_ASSERT(AdvisorySupport::isSlowConsumerAdvisoryTopic(topic.get()));

    Pointer<cms::Destination> cmsDest = target.dynamicCast<cms::Destination>();
    Pointer<ActiveMQDestination> cmstopic(AdvisorySupport::getSlowConsumerAdvisoryTopic(cmsDest.get()));
    CPPUNIT_ASSERT(!AdvisorySupport::isSlowConsumerAdvisoryTopic(cmsDest.get()));
    CPPUNIT_ASSERT(AdvisorySupport::isSlowConsumerAdvisoryTopic(cmstopic.get()));

    CPPUNIT_ASSERT_THROW_MESSAGE(
        "Should throw a NullPointerException when passed a NULL destination",
        AdvisorySupport::isSlowConsumerAdvisoryTopic((ActiveMQDestination*)NULL),
        NullPointerException);
    CPPUNIT_ASSERT_THROW_MESSAGE(
        "Should throw a NullPointerException when passed a NULL destination",
        AdvisorySupport::isSlowConsumerAdvisoryTopic((cms::Destination*)NULL),
        NullPointerException);
}

////////////////////////////////////////////////////////////////////////////////
void AdvisorySupportTest::testIsFastProducerAdvisoryTopic() {

    Pointer<ActiveMQDestination> target(new ActiveMQTempTopic("Test.Topic"));
    Pointer<ActiveMQDestination> topic(AdvisorySupport::getFastProducerAdvisoryTopic(target.get()));
    CPPUNIT_ASSERT(!AdvisorySupport::isFastProducerAdvisoryTopic(target.get()));
    CPPUNIT_ASSERT(AdvisorySupport::isFastProducerAdvisoryTopic(topic.get()));

    Pointer<cms::Destination> cmsDest = target.dynamicCast<cms::Destination>();
    Pointer<ActiveMQDestination> cmstopic(AdvisorySupport::getFastProducerAdvisoryTopic(cmsDest.get()));
    CPPUNIT_ASSERT(!AdvisorySupport::isFastProducerAdvisoryTopic(cmsDest.get()));
    CPPUNIT_ASSERT(AdvisorySupport::isFastProducerAdvisoryTopic(cmstopic.get()));

    CPPUNIT_ASSERT_THROW_MESSAGE(
        "Should throw a NullPointerException when passed a NULL destination",
        AdvisorySupport::isFastProducerAdvisoryTopic((ActiveMQDestination*)NULL),
        NullPointerException);
    CPPUNIT_ASSERT_THROW_MESSAGE(
        "Should throw a NullPointerException when passed a NULL destination",
        AdvisorySupport::isFastProducerAdvisoryTopic((cms::Destination*)NULL),
        NullPointerException);
}

////////////////////////////////////////////////////////////////////////////////
void AdvisorySupportTest::testIsMessageConsumedAdvisoryTopic() {

    Pointer<ActiveMQDestination> target(new ActiveMQTempTopic("Test.Topic"));
    Pointer<ActiveMQDestination> topic(AdvisorySupport::getMessageConsumedAdvisoryTopic(target.get()));
    CPPUNIT_ASSERT(!AdvisorySupport::isMessageConsumedAdvisoryTopic(target.get()));
    CPPUNIT_ASSERT(AdvisorySupport::isMessageConsumedAdvisoryTopic(topic.get()));

    Pointer<cms::Destination> cmsDest = target.dynamicCast<cms::Destination>();
    Pointer<ActiveMQDestination> cmstopic(AdvisorySupport::getMessageConsumedAdvisoryTopic(cmsDest.get()));
    CPPUNIT_ASSERT(!AdvisorySupport::isMessageConsumedAdvisoryTopic(cmsDest.get()));
    CPPUNIT_ASSERT(AdvisorySupport::isMessageConsumedAdvisoryTopic(cmstopic.get()));

    CPPUNIT_ASSERT_THROW_MESSAGE(
        "Should throw a NullPointerException when passed a NULL destination",
        AdvisorySupport::isMessageConsumedAdvisoryTopic((ActiveMQDestination*)NULL),
        NullPointerException);
    CPPUNIT_ASSERT_THROW_MESSAGE(
        "Should throw a NullPointerException when passed a NULL destination",
        AdvisorySupport::isMessageConsumedAdvisoryTopic((cms::Destination*)NULL),
        NullPointerException);
}

////////////////////////////////////////////////////////////////////////////////
void AdvisorySupportTest::testIsMasterBrokerAdvisoryTopic() {

    Pointer<ActiveMQDestination> target(new ActiveMQTempTopic("Test.Topic"));
    Pointer<ActiveMQDestination> topic(AdvisorySupport::getMasterBrokerAdvisoryTopic());
    CPPUNIT_ASSERT(!AdvisorySupport::isMasterBrokerAdvisoryTopic(target.get()));
    CPPUNIT_ASSERT(AdvisorySupport::isMasterBrokerAdvisoryTopic(topic.get()));

    Pointer<cms::Destination> cmsDest = target.dynamicCast<cms::Destination>();
    Pointer<ActiveMQDestination> cmstopic(AdvisorySupport::getMasterBrokerAdvisoryTopic());
    CPPUNIT_ASSERT(!AdvisorySupport::isMasterBrokerAdvisoryTopic(cmsDest.get()));
    CPPUNIT_ASSERT(AdvisorySupport::isMasterBrokerAdvisoryTopic(cmstopic.get()));

    CPPUNIT_ASSERT_THROW_MESSAGE(
        "Should throw a NullPointerException when passed a NULL destination",
        AdvisorySupport::isMasterBrokerAdvisoryTopic((ActiveMQDestination*)NULL),
        NullPointerException);
    CPPUNIT_ASSERT_THROW_MESSAGE(
        "Should throw a NullPointerException when passed a NULL destination",
        AdvisorySupport::isMasterBrokerAdvisoryTopic((cms::Destination*)NULL),
        NullPointerException);
}

////////////////////////////////////////////////////////////////////////////////
void AdvisorySupportTest::testIsMessageDeliveredAdvisoryTopic() {

    Pointer<ActiveMQDestination> target(new ActiveMQTempTopic("Test.Topic"));
    Pointer<ActiveMQDestination> topic(AdvisorySupport::getMessageDeliveredAdvisoryTopic(target.get()));
    CPPUNIT_ASSERT(!AdvisorySupport::isMessageDeliveredAdvisoryTopic(target.get()));
    CPPUNIT_ASSERT(AdvisorySupport::isMessageDeliveredAdvisoryTopic(topic.get()));

    Pointer<cms::Destination> cmsDest = target.dynamicCast<cms::Destination>();
    Pointer<ActiveMQDestination> cmstopic(AdvisorySupport::getMessageDeliveredAdvisoryTopic(cmsDest.get()));
    CPPUNIT_ASSERT(!AdvisorySupport::isMessageDeliveredAdvisoryTopic(cmsDest.get()));
    CPPUNIT_ASSERT(AdvisorySupport::isMessageDeliveredAdvisoryTopic(cmstopic.get()));

    CPPUNIT_ASSERT_THROW_MESSAGE(
        "Should throw a NullPointerException when passed a NULL destination",
        AdvisorySupport::isMessageDeliveredAdvisoryTopic((ActiveMQDestination*)NULL),
        NullPointerException);
    CPPUNIT_ASSERT_THROW_MESSAGE(
        "Should throw a NullPointerException when passed a NULL destination",
        AdvisorySupport::isMessageDeliveredAdvisoryTopic((cms::Destination*)NULL),
        NullPointerException);
}

////////////////////////////////////////////////////////////////////////////////
void AdvisorySupportTest::testIsMessageDiscardedAdvisoryTopic() {

    Pointer<ActiveMQDestination> target(new ActiveMQTempTopic("Test.Topic"));
    Pointer<ActiveMQDestination> topic(AdvisorySupport::getMessageDiscardedAdvisoryTopic(target.get()));
    CPPUNIT_ASSERT(!AdvisorySupport::isMessageDiscardedAdvisoryTopic(target.get()));
    CPPUNIT_ASSERT(AdvisorySupport::isMessageDiscardedAdvisoryTopic(topic.get()));

    Pointer<cms::Destination> cmsDest = target.dynamicCast<cms::Destination>();
    Pointer<ActiveMQDestination> cmstopic(AdvisorySupport::getMessageDiscardedAdvisoryTopic(cmsDest.get()));
    CPPUNIT_ASSERT(!AdvisorySupport::isMessageDiscardedAdvisoryTopic(cmsDest.get()));
    CPPUNIT_ASSERT(AdvisorySupport::isMessageDiscardedAdvisoryTopic(cmstopic.get()));

    CPPUNIT_ASSERT_THROW_MESSAGE(
        "Should throw a NullPointerException when passed a NULL destination",
        AdvisorySupport::isMessageDiscardedAdvisoryTopic((ActiveMQDestination*)NULL),
        NullPointerException);
    CPPUNIT_ASSERT_THROW_MESSAGE(
        "Should throw a NullPointerException when passed a NULL destination",
        AdvisorySupport::isMessageDiscardedAdvisoryTopic((cms::Destination*)NULL),
        NullPointerException);
}

////////////////////////////////////////////////////////////////////////////////
void AdvisorySupportTest::testIsMessageDLQdAdvisoryTopic() {

    Pointer<ActiveMQDestination> target(new ActiveMQTempTopic("Test.Topic"));
    Pointer<ActiveMQDestination> topic(AdvisorySupport::getMessageDLQdAdvisoryTopic(target.get()));
    CPPUNIT_ASSERT(!AdvisorySupport::isMessageDLQdAdvisoryTopic(target.get()));
    CPPUNIT_ASSERT(AdvisorySupport::isMessageDLQdAdvisoryTopic(topic.get()));

    Pointer<cms::Destination> cmsDest = target.dynamicCast<cms::Destination>();
    Pointer<ActiveMQDestination> cmstopic(AdvisorySupport::getMessageDLQdAdvisoryTopic(cmsDest.get()));
    CPPUNIT_ASSERT(!AdvisorySupport::isMessageDLQdAdvisoryTopic(cmsDest.get()));
    CPPUNIT_ASSERT(AdvisorySupport::isMessageDLQdAdvisoryTopic(cmstopic.get()));

    CPPUNIT_ASSERT_THROW_MESSAGE(
        "Should throw a NullPointerException when passed a NULL destination",
        AdvisorySupport::isMessageDLQdAdvisoryTopic((ActiveMQDestination*)NULL),
        NullPointerException);
    CPPUNIT_ASSERT_THROW_MESSAGE(
        "Should throw a NullPointerException when passed a NULL destination",
        AdvisorySupport::isMessageDLQdAdvisoryTopic((cms::Destination*)NULL),
        NullPointerException);
}

////////////////////////////////////////////////////////////////////////////////
void AdvisorySupportTest::testIsFullAdvisoryTopic() {

    Pointer<ActiveMQDestination> target(new ActiveMQTempTopic("Test.Topic"));
    Pointer<ActiveMQDestination> topic(AdvisorySupport::getFullAdvisoryTopic(target.get()));
    CPPUNIT_ASSERT(!AdvisorySupport::isFullAdvisoryTopic(target.get()));
    CPPUNIT_ASSERT(AdvisorySupport::isFullAdvisoryTopic(topic.get()));

    Pointer<cms::Destination> cmsDest = target.dynamicCast<cms::Destination>();
    Pointer<ActiveMQDestination> cmstopic(AdvisorySupport::getFullAdvisoryTopic(cmsDest.get()));
    CPPUNIT_ASSERT(!AdvisorySupport::isFullAdvisoryTopic(cmsDest.get()));
    CPPUNIT_ASSERT(AdvisorySupport::isFullAdvisoryTopic(cmstopic.get()));

    CPPUNIT_ASSERT_THROW_MESSAGE(
        "Should throw a NullPointerException when passed a NULL destination",
        AdvisorySupport::isFullAdvisoryTopic((ActiveMQDestination*)NULL),
        NullPointerException);
    CPPUNIT_ASSERT_THROW_MESSAGE(
        "Should throw a NullPointerException when passed a NULL destination",
        AdvisorySupport::isFullAdvisoryTopic((cms::Destination*)NULL),
        NullPointerException);
}

////////////////////////////////////////////////////////////////////////////////
void AdvisorySupportTest::testIsNetworkBridgeAdvisoryTopic() {

    Pointer<ActiveMQDestination> target(new ActiveMQTempTopic("Test.Topic"));
    Pointer<ActiveMQDestination> topic(AdvisorySupport::getNetworkBridgeAdvisoryTopic());
    CPPUNIT_ASSERT(!AdvisorySupport::isNetworkBridgeAdvisoryTopic(target.get()));
    CPPUNIT_ASSERT(AdvisorySupport::isNetworkBridgeAdvisoryTopic(topic.get()));

    Pointer<cms::Destination> cmsDest = target.dynamicCast<cms::Destination>();
    Pointer<ActiveMQDestination> cmstopic(AdvisorySupport::getNetworkBridgeAdvisoryTopic());
    CPPUNIT_ASSERT(!AdvisorySupport::isNetworkBridgeAdvisoryTopic(cmsDest.get()));
    CPPUNIT_ASSERT(AdvisorySupport::isNetworkBridgeAdvisoryTopic(cmstopic.get()));

    CPPUNIT_ASSERT_THROW_MESSAGE(
        "Should throw a NullPointerException when passed a NULL destination",
        AdvisorySupport::isNetworkBridgeAdvisoryTopic((ActiveMQDestination*)NULL),
        NullPointerException);
    CPPUNIT_ASSERT_THROW_MESSAGE(
        "Should throw a NullPointerException when passed a NULL destination",
        AdvisorySupport::isNetworkBridgeAdvisoryTopic((cms::Destination*)NULL),
        NullPointerException);
}