blob: 74d7813a9508f8a533f94fb102fd53e31d3abe29 [file] [log] [blame]
/*
* Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership.
* The ASF licenses this file to You under the Apache License, Version 2.0
* (the "License"); you may not use this file except in compliance with
* the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
#ifndef _ACTIVEMQ_TRANSPORT_FAILOVER_FAILOVERTRANSPORTTEST_H_
#define _ACTIVEMQ_TRANSPORT_FAILOVER_FAILOVERTRANSPORTTEST_H_
#include <cppunit/TestFixture.h>
#include <cppunit/extensions/HelperMacros.h>
#include <activemq/util/Config.h>
#include <activemq/commands/ConnectionInfo.h>
#include <activemq/commands/SessionInfo.h>
#include <activemq/commands/ProducerInfo.h>
#include <activemq/commands/ConsumerInfo.h>
#include <activemq/transport/Transport.h>
#include <decaf/lang/Pointer.h>
namespace activemq {
namespace transport {
namespace failover {
using decaf::lang::Pointer;
using namespace activemq::commands;
class FailoverTransportTest : public CppUnit::TestFixture {
CPPUNIT_TEST_SUITE( FailoverTransportTest );
CPPUNIT_TEST( testTransportCreate );
CPPUNIT_TEST( testTransportCreateWithBackups );
CPPUNIT_TEST( testTransportCreateFailOnCreate );
CPPUNIT_TEST( testTransportCreateFailOnCreateSendMessage );
CPPUNIT_TEST( testFailingBackupCreation );
CPPUNIT_TEST( testSendOnewayMessage );
CPPUNIT_TEST( testSendRequestMessage );
CPPUNIT_TEST( testSendOnewayMessageFail );
CPPUNIT_TEST( testSendRequestMessageFail );
CPPUNIT_TEST( testWithOpewireCommands );
CPPUNIT_TEST( testTransportHandlesConnectionControl );
CPPUNIT_TEST( testPriorityBackupConfig );
CPPUNIT_TEST( testUriOptionsApplied );
CPPUNIT_TEST( testConnectedToMockBroker );
CPPUNIT_TEST( testMaxReconnectsZeroAttemptsOneConnect );
CPPUNIT_TEST( testMaxReconnectsHonorsConfiguration );
CPPUNIT_TEST( testStartupMaxReconnectsHonorsConfiguration );
CPPUNIT_TEST( testConnectedToPriorityOnFirstTryThenFailover );
CPPUNIT_TEST( testConnectsToPriorityOnceStarted );
//CPPUNIT_TEST( testConnectsToPriorityAfterInitialBackupFails );
CPPUNIT_TEST_SUITE_END();
public:
FailoverTransportTest();
virtual ~FailoverTransportTest();
void testTransportCreate();
void testTransportCreateWithBackups();
void testTransportCreateFailOnCreate();
void testTransportCreateFailOnCreateSendMessage();
void testFailingBackupCreation();
void testSendOnewayMessage();
void testSendRequestMessage();
void testSendOnewayMessageFail();
void testSendRequestMessageFail();
void testWithOpewireCommands();
void testTransportHandlesConnectionControl();
void testPriorityBackupConfig();
void testUriOptionsApplied();
void testConnectedToMockBroker();
void testMaxReconnectsZeroAttemptsOneConnect();
void testMaxReconnectsHonorsConfiguration();
void testStartupMaxReconnectsHonorsConfiguration();
void testConnectedToPriorityOnFirstTryThenFailover();
void testConnectsToPriorityOnceStarted();
void testConnectsToPriorityAfterInitialBackupFails();
private:
Pointer<ConnectionInfo> createConnection();
Pointer<SessionInfo> createSession( const Pointer<ConnectionInfo>& parent );
Pointer<ConsumerInfo> createConsumer( const Pointer<SessionInfo>& parent );
Pointer<ProducerInfo> createProducer( const Pointer<SessionInfo>& parent );
void disposeOf( const Pointer<SessionInfo>& session,
Pointer<Transport>& transport );
void disposeOf( const Pointer<ConsumerInfo>& consumer,
Pointer<Transport>& transport );
void disposeOf( const Pointer<ProducerInfo>& producer,
Pointer<Transport>& transport );
};
}}}
#endif /*_ACTIVEMQ_TRANSPORT_FAILOVER_FAILOVERTRANSPORTTEST_H_*/