qpid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From kw...@apache.org
Subject [1/5] qpid-broker-j git commit: QPID-6933: [System Tests] Move AMQP 0-x client specific test failover to client suite
Date Sun, 21 Jan 2018 10:11:12 GMT
Repository: qpid-broker-j
Updated Branches:
  refs/heads/master 25f11ba27 -> b4ba6158f


http://git-wip-us.apache.org/repos/asf/qpid-broker-j/blob/588c65f7/systests/src/test/java/org/apache/qpid/test/client/failover/FailoverTest.java
----------------------------------------------------------------------
diff --git a/systests/src/test/java/org/apache/qpid/test/client/failover/FailoverTest.java
b/systests/src/test/java/org/apache/qpid/test/client/failover/FailoverTest.java
deleted file mode 100644
index ba0f4a8..0000000
--- a/systests/src/test/java/org/apache/qpid/test/client/failover/FailoverTest.java
+++ /dev/null
@@ -1,325 +0,0 @@
-/*
- *
- * 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.
- *
- */
-
-package org.apache.qpid.test.client.failover;
-
-import java.util.Random;
-import java.util.concurrent.TimeUnit;
-
-import javax.jms.Connection;
-import javax.jms.JMSException;
-import javax.jms.Message;
-import javax.jms.MessageConsumer;
-import javax.jms.MessageProducer;
-import javax.jms.Queue;
-import javax.jms.Session;
-import javax.jms.TextMessage;
-
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-import org.apache.qpid.client.AMQConnection;
-import org.apache.qpid.client.AMQSession;
-import org.apache.qpid.test.utils.BrokerHolder;
-import org.apache.qpid.test.utils.FailoverBaseCase;
-
-public class FailoverTest extends FailoverBaseCase
-{
-    private static final Logger LOGGER = LoggerFactory.getLogger(FailoverTest.class);
-
-    private static final int DEFAULT_NUM_MESSAGES = 10;
-    private static final int DEFAULT_SEED = 20080921;
-    protected int numMessages = 0;
-    protected Connection connection;
-    private Session producerSession;
-    private Queue queue;
-    private MessageProducer producer;
-    private Session consumerSession;
-    private MessageConsumer consumer;
-
-    private boolean CLUSTERED = Boolean.getBoolean("profile.clustered");
-    private int seed;
-    private Random rand;
-
-    @Override
-    public void setUp() throws Exception
-    {
-        super.setUp();
-
-        numMessages = Integer.getInteger("profile.failoverMsgCount", DEFAULT_NUM_MESSAGES);
-        seed = Integer.getInteger("profile.failoverRandomSeed", DEFAULT_SEED);
-        rand = new Random(seed);
-        
-        connection = getConnection();
-        ((AMQConnection) connection).setConnectionListener(this);
-        connection.start();
-    }
-
-    private void init(boolean transacted, int mode) throws Exception
-    {
-        consumerSession = connection.createSession(transacted, mode);
-        queue = consumerSession.createQueue(getName()+System.currentTimeMillis());
-        consumer = consumerSession.createConsumer(queue);
-
-        producerSession = connection.createSession(transacted, mode);
-        producer = producerSession.createProducer(queue);
-    }
-
-    @Override
-    public void tearDown() throws Exception
-    {
-        try
-        {
-            connection.close();
-        }
-        catch (Exception e)
-        {
-
-        }
-
-        try
-        {
-            _alternativeBroker.shutdown();
-        }
-        finally
-        {
-            super.tearDown();
-        }
-    }
-
-    private void consumeMessages(int startIndex,int endIndex, boolean transacted) throws
JMSException
-    {
-        Message msg;
-        LOGGER.debug("**************** Receive (Start: " + startIndex + ", End:" + endIndex
+ ")***********************");
-        
-        for (int i = startIndex; i < endIndex; i++)
-        {
-            msg = consumer.receive(1000);            
-            assertNotNull("Message " + i + " was null!", msg);
-            
-            LOGGER.debug("@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@");
-            LOGGER.debug("Received : " + ((TextMessage) msg).getText());
-            LOGGER.debug("@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@");
-            
-            assertEquals("Invalid message order","message " + i, ((TextMessage) msg).getText());
-            
-        }
-        LOGGER.debug("***********************************************************");
-        
-        if (transacted) 
-        {
-            consumerSession.commit();
-        }
-    }
-
-    private void sendMessages(int startIndex,int endIndex, boolean transacted) throws Exception
-    {
-        LOGGER.debug("**************** Send (Start: " + startIndex + ", End:" + endIndex
+ ")***********************");
-        
-        for (int i = startIndex; i < endIndex; i++)
-        {            
-            producer.send(producerSession.createTextMessage("message " + i));
-            
-            LOGGER.debug("@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@");
-            LOGGER.debug("Sending message"+i);
-            LOGGER.debug("@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@");
-        }
-        
-        LOGGER.debug("***********************************************************");
-        
-        if (transacted)
-        {
-            producerSession.commit();
-        }
-        else
-        {
-            ((AMQSession<?, ?>)producerSession).sync();
-        }
-    }
-
-    public void testP2PFailover() throws Exception
-    {
-        testP2PFailover(numMessages, true, true, false);
-    }
-
-    public void testP2PFailoverWithMessagesLeftToConsumeAndProduce() throws Exception
-    {
-        if (CLUSTERED)
-        {
-            testP2PFailover(numMessages, false, false, false);
-        }
-    }
-    
-    public void testP2PFailoverWithMessagesLeftToConsume() throws Exception
-    {
-        if (CLUSTERED)
-        {    
-            testP2PFailover(numMessages, false, true, false);
-        }
-    }    
-     
-    public void testP2PFailoverTransacted() throws Exception
-    {
-        testP2PFailover(numMessages, true, true, true);
-    }
-
-    public void testP2PFailoverTransactedWithMessagesLeftToConsumeAndProduce() throws Exception
-    {
-        // Currently the cluster does not support transactions that span a failover
-        if (CLUSTERED)
-        {
-            testP2PFailover(numMessages, false, false, false);
-        }
-    }
-    private void testP2PFailover(int totalMessages, boolean consumeAll, boolean produceAll
, boolean transacted) throws Exception
-    {        
-        init(transacted, Session.AUTO_ACKNOWLEDGE);
-        runP2PFailover(getDefaultBroker(), totalMessages,consumeAll, produceAll , transacted);
-    } 
-
-    private void runP2PFailover(BrokerHolder broker, int totalMessages, boolean consumeAll,
boolean produceAll , boolean transacted) throws Exception
-    {
-        int toProduce = totalMessages;
-        
-        LOGGER.debug("===================================================================");
-        LOGGER.debug("Total messages used for the test " + totalMessages + " messages");
-        LOGGER.debug("===================================================================");
-        
-        if (!produceAll)
-        {
-            toProduce = totalMessages - rand.nextInt(totalMessages);
-        }
-                
-        LOGGER.debug("==================");
-        LOGGER.debug("Sending " + toProduce + " messages");
-        LOGGER.debug("==================");
-        
-        sendMessages(0, toProduce, transacted);
-
-        // Consume some messages
-        int toConsume = toProduce;
-        if (!consumeAll)
-        {
-            toConsume = toProduce - rand.nextInt(toProduce);         
-        }
-        
-        consumeMessages(0, toConsume, transacted);
-
-        LOGGER.debug("==================");
-        LOGGER.debug("Consuming " + toConsume + " messages");
-        LOGGER.debug("==================");
-        
-        LOGGER.info("Failing over");
-
-        causeFailure(broker, DEFAULT_FAILOVER_TIME);
-
-        // Check that you produce and consume the rest of messages.
-        LOGGER.debug("==================");
-        LOGGER.debug("Sending " + (totalMessages-toProduce) + " messages");
-        LOGGER.debug("==================");
-        
-        sendMessages(toProduce, totalMessages, transacted);
-        consumeMessages(toConsume, totalMessages, transacted);
-        
-        LOGGER.debug("==================");
-        LOGGER.debug("Consuming " + (totalMessages-toConsume) + " messages");
-        LOGGER.debug("==================");
-    }
-
-    private void causeFailure(BrokerHolder broker, long delay)
-    {
-
-        failBroker(broker);
-
-        LOGGER.info("Awaiting Failover completion");
-        try
-        {
-            if (!_failoverComplete.await(delay, TimeUnit.MILLISECONDS))
-            {
-                fail("failover did not complete");
-            }
-        }
-        catch (InterruptedException e)
-        {
-            //evil ignore IE.
-        }
-    }
-
-    public void testClientAckFailover() throws Exception
-    {
-        init(false, Session.CLIENT_ACKNOWLEDGE);
-        sendMessages(0,1, false);
-        Message msg = consumer.receive();
-        assertNotNull("Expected msgs not received", msg);
-
-        causeFailure(getDefaultBroker(), DEFAULT_FAILOVER_TIME);
-
-        Exception failure = null;
-        try
-        {
-            msg.acknowledge();
-        }
-        catch (Exception e)
-        {
-            failure = e;
-        }
-        assertNotNull("Exception should be thrown", failure);
-    } 
-
-    /**
-     * The idea is to run a failover test in a loop by failing over
-     * to the other broker each time.
-     */
-    public void testFailoverInALoop() throws Exception
-    {
-        if (!CLUSTERED)
-        {
-            return;
-        }
-
-        BrokerHolder currentBroker = getDefaultBroker();
-        int iterations = Integer.getInteger("profile.failoverIterations", 3);
-        LOGGER.debug("LQ: iterations {}", iterations);
-        boolean useDefaultBroker = true;
-        init(false, Session.AUTO_ACKNOWLEDGE);
-        for (int i=0; i < iterations; i++)
-        {
-            LOGGER.debug("===================================================================");
-            LOGGER.debug("Failover In a loop : iteration number " + i);
-            LOGGER.debug("===================================================================");
-
-            runP2PFailover(currentBroker, numMessages, false, false, false);
-            restartBroker(currentBroker);
-            if (useDefaultBroker)
-            {
-                currentBroker = _alternativeBroker;
-                useDefaultBroker = false;
-            }
-            else
-            {
-                currentBroker = getDefaultBroker();
-                useDefaultBroker = true;
-            }
-        }
-        //To prevent any failover logic being initiated when we shutdown the brokers.
-        connection.close();
-    }
-}

http://git-wip-us.apache.org/repos/asf/qpid-broker-j/blob/588c65f7/systests/src/test/java/org/apache/qpid/test/utils/FailoverBaseCase.java
----------------------------------------------------------------------
diff --git a/systests/src/test/java/org/apache/qpid/test/utils/FailoverBaseCase.java b/systests/src/test/java/org/apache/qpid/test/utils/FailoverBaseCase.java
deleted file mode 100644
index b781058..0000000
--- a/systests/src/test/java/org/apache/qpid/test/utils/FailoverBaseCase.java
+++ /dev/null
@@ -1,163 +0,0 @@
-/*
- *
- * 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.
- *
- */
-package org.apache.qpid.test.utils;
-
-import java.util.ArrayList;
-import java.util.List;
-import java.util.concurrent.CountDownLatch;
-
-import javax.jms.Connection;
-import javax.jms.ConnectionFactory;
-import javax.jms.IllegalStateException;
-import javax.jms.JMSException;
-import javax.naming.NamingException;
-
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-import org.apache.qpid.jms.ConnectionListener;
-
-public class FailoverBaseCase extends QpidBrokerTestCase implements ConnectionListener
-{
-    private static final Logger LOGGER = LoggerFactory.getLogger(FailoverBaseCase.class);
-
-    public static final long DEFAULT_FAILOVER_TIME = Long.getLong("FailoverBaseCase.defaultFailoverTime",
10000L);
-
-    protected CountDownLatch _failoverStarted;
-    protected CountDownLatch _failoverComplete;
-    protected BrokerHolder _alternativeBroker;
-    protected int _port;
-    protected int _alternativePort;
-    private final List<Connection> _connections = new ArrayList<>();
-
-    @Override
-    public void setUp() throws Exception
-    {
-        super.setUp();
-        _failoverComplete = new CountDownLatch(1);
-        _failoverStarted = new CountDownLatch(1);
-
-        _alternativeBroker = createSpawnedBroker();
-        _alternativeBroker.start();
-        _alternativePort = _alternativeBroker.getAmqpPort();
-
-        _port = getDefaultBroker().getAmqpPort();
-        setTestSystemProperty("test.port.alt", String.valueOf(_alternativePort));
-        setTestSystemProperty("test.port", String.valueOf(_port));
-    }
-
-    @Override
-    protected void tearDown() throws Exception
-    {
-        try
-        {
-            for(Connection c : _connections)
-            {
-                try
-                {
-                    c.close();
-                }
-                catch (JMSException e)
-                {
-                }
-            }
-        }
-        finally
-        {
-            super.tearDown();
-        }
-    }
-
-    /**
-     * We are using failover factories
-     *
-     * @return a connection
-     * @throws Exception
-     */
-    @Override
-    public ConnectionFactory getConnectionFactory() throws NamingException
-    {
-        LOGGER.info("get ConnectionFactory");
-        return getConnectionBuilder().setFailover(true)
-                                     .setTls(Boolean.getBoolean("profile.use_ssl"))
-                                     .buildConnectionFactory();
-    }
-
-    @Override
-    public javax.jms.Connection getConnection() throws JMSException, NamingException
-    {
-        final Connection connection = getConnectionFactory().createConnection(GUEST_USERNAME,
GUEST_PASSWORD);
-        _connections.add(connection);
-        return connection;
-    }
-
-    public void failDefaultBroker()
-    {
-        failBroker(getDefaultBroker());
-    }
-
-    public void failBroker(BrokerHolder broker)
-    {
-        try
-        {
-            //TODO: use killBroker instead
-            broker.shutdown();
-        }
-        catch (Exception e)
-        {
-            throw new RuntimeException(e);
-        }
-    }
-
-    public void restartBroker(BrokerHolder broker) throws Exception
-    {
-        broker.restart();
-    }
-
-    @Override
-    public void bytesSent(long count)
-    {
-    }
-
-    @Override
-    public void bytesReceived(long count)
-    {
-    }
-
-    @Override
-    public boolean preFailover(boolean redirect)
-    {
-        _failoverStarted.countDown();
-        return true;
-    }
-
-    @Override
-    public boolean preResubscribe()
-    {
-        return true;
-    }
-
-    @Override
-    public void failoverComplete()
-    {
-        _failoverComplete.countDown();
-    }
-}

http://git-wip-us.apache.org/repos/asf/qpid-broker-j/blob/588c65f7/test-profiles/CPPExcludes
----------------------------------------------------------------------
diff --git a/test-profiles/CPPExcludes b/test-profiles/CPPExcludes
index ba925a1..5636a05 100755
--- a/test-profiles/CPPExcludes
+++ b/test-profiles/CPPExcludes
@@ -60,11 +60,6 @@ org.apache.qpid.test.client.ProducerFlowControlTest#*
 
 //QPID-3986 : Flow control invoked on total store disk usage
 org.apache.qpid.server.store.StoreOverfullTest#*
-// 0-8/0-9/0-9-1 and/or Qpid Broker-J specific failover tests related to the above Producer
Flow Control mechanisms
-org.apache.qpid.client.failover.FailoverBehaviourTest#testFailoverHandlerTimeoutExpires
-org.apache.qpid.client.failover.FailoverBehaviourTest#testFlowControlFlagResetOnFailover
-org.apache.qpid.client.failover.AddressBasedFailoverBehaviourTest#testFailoverHandlerTimeoutExpires
-org.apache.qpid.client.failover.AddressBasedFailoverBehaviourTest#testFlowControlFlagResetOnFailover
 
 // Excluded because plugins from Qpid Broker-J are not used in CPP broker
 org.apache.qpid.server.virtualhost.plugin.*
@@ -83,9 +78,6 @@ org.apache.qpid.server.plugins.PluginTest#*
 org.apache.qpid.server.SupportedProtocolVersionsTest#*
 org.apache.qpid.server.stats.StatisticsReportingTest#*
 
-// QPID-3133: On 0-10, the exception listener is currently not invoked when reconnection
fails to occurs.
-org.apache.qpid.server.failover.FailoverMethodTest#*
-
 // passwd script is a Qpid Broker-J specific command line tool
 org.apache.qpid.scripts.QpidPasswdTest#*
 
@@ -98,8 +90,6 @@ org.apache.qpid.systest.disttest.endtoend.*
 org.apache.qpid.systest.rest.*
 org.apache.qpid.systest.rest.acl.*
 
-// Exclude failover tests requiring virtual host functionality
-org.apache.qpid.client.failover.MultipleBrokersFailoverTest#*
 
 // CPP Broker does not timeout connections with no activity like the Qpid Broker-J
 org.apache.qpid.transport.ProtocolNegotiationTest#testNoProtocolHeaderSent_BrokerClosesConnection

http://git-wip-us.apache.org/repos/asf/qpid-broker-j/blob/588c65f7/test-profiles/ExternalBrokerTests
----------------------------------------------------------------------
diff --git a/test-profiles/ExternalBrokerTests b/test-profiles/ExternalBrokerTests
index 1abe0e6..969b927 100644
--- a/test-profiles/ExternalBrokerTests
+++ b/test-profiles/ExternalBrokerTests
@@ -17,12 +17,3 @@
 // under the License.
 //
 
-#These tests use external spawned brokers
-
-#=============================
-# In the java-mms.0-10 profile
-#=============================
-org.apache.qpid.client.failover.AddressBasedFailoverBehaviourTest#*
-org.apache.qpid.client.failover.FailoverBehaviourTest#*
-org.apache.qpid.client.failover.MultipleBrokersFailoverTest#*
-org.apache.qpid.test.client.failover.FailoverTest#*

http://git-wip-us.apache.org/repos/asf/qpid-broker-j/blob/588c65f7/test-profiles/Java010Excludes
----------------------------------------------------------------------
diff --git a/test-profiles/Java010Excludes b/test-profiles/Java010Excludes
index dace6ea..30176f1 100755
--- a/test-profiles/Java010Excludes
+++ b/test-profiles/Java010Excludes
@@ -21,9 +21,6 @@
 org.apache.qpid.systest.rest.BrokerRestTest#testSetCloseOnNoRoute
 org.apache.qpid.test.unit.topic.DurableSubscriptionTest#testUnsubscribeWhenUsingSelectorMakesTopicUnreachable
 
-// Exclude tests of connection URL failover method property
-org.apache.qpid.server.failover.FailoverMethodTest#*
-
 // 0-10 and 0-9 connections dont generate the exact same logging due to protocol differences
 org.apache.qpid.server.logging.ChannelLoggingTest#testChannelStartsFlowStopped
 org.apache.qpid.server.logging.ChannelLoggingTest#testChannelStartConsumerFlowStarted
@@ -32,19 +29,8 @@ org.apache.qpid.server.logging.ChannelLoggingTest#testChannelStartConsumerFlowSt
 org.apache.qpid.test.client.timeouts.SyncWaitTimeoutDelayTest#*
 org.apache.qpid.test.client.timeouts.SyncWaitDelayTest#*
 
-// These tests test the behaviour of 0-8..-0-9-1 specific system property qpid.failover_method_timeout
-org.apache.qpid.client.failover.FailoverBehaviourTest#testFailoverHandlerTimeoutExpires
-org.apache.qpid.client.failover.FailoverBehaviourTest#testFailoverHandlerTimeoutReconnected
-org.apache.qpid.client.failover.FailoverBehaviourTest#testFlowControlFlagResetOnFailover
-org.apache.qpid.client.failover.AddressBasedFailoverBehaviourTest#testFailoverHandlerTimeoutExpires
-org.apache.qpid.client.failover.AddressBasedFailoverBehaviourTest#testFailoverHandlerTimeoutReconnected
-org.apache.qpid.client.failover.AddressBasedFailoverBehaviourTest#testFlowControlFlagResetOnFailover
-
 org.apache.qpid.test.unit.client.AMQSessionTest#testQueueDepthForQueueThatDoesNotExistLegacyBehaviour_08_091
 
-// QPID-6722: Race client side means that session close can end in exception when failover
is in progress.
-org.apache.qpid.client.failover.FailoverBehaviourTest#testConnectionCloseInterruptsFailover
-org.apache.qpid.client.failover.AddressBasedFailoverBehaviourTest#testConnectionCloseInterruptsFailover
 
 # Exclude the JMS 2.0 test suite
 org.apache.qpid.systests.jms_2_0.*

http://git-wip-us.apache.org/repos/asf/qpid-broker-j/blob/588c65f7/test-profiles/Java10Excludes
----------------------------------------------------------------------
diff --git a/test-profiles/Java10Excludes b/test-profiles/Java10Excludes
index d52d70e..4b385c1 100644
--- a/test-profiles/Java10Excludes
+++ b/test-profiles/Java10Excludes
@@ -20,12 +20,6 @@
 // Exclude client test of initial context factory, as the 1.0 profile uses the 1.0 context
factory
 org.apache.qpid.jndi.PropertiesFileInitialContextFactoryTest#*
 
-// Exclude Address based tests
-org.apache.qpid.client.failover.AddressBasedFailoverBehaviourTest#*
-
-// Exclude tests of connection URL failover method property
-org.apache.qpid.server.failover.FailoverMethodTest#*
-
 // Uses an 0-x client API to acknowledge up to a particular message rather than the most
recent
 org.apache.qpid.test.unit.ack.RecoverTest#testRecoverResendsMsgsAckOnEarlier
 // Tests the effect of setting the prefetch value
@@ -50,13 +44,6 @@ org.apache.qpid.transport.ProtocolNegotiationTest#testProtocolNegotiationFromUns
 // Tests are tests of the 0-x client behaviour
 org.apache.qpid.test.client.ProducerFlowControlTest#*
 
-// Failover tests are tests of the 0-x client behaviour
-org.apache.qpid.client.failover.FailoverBehaviourTest#*
-org.apache.qpid.client.failover.MultipleBrokersFailoverTest#*
-org.apache.qpid.test.client.failover.FailoverTest#*
-// QPID-3133: On 0-10, the exception listener is currently not invoked when reconnection
fails to occurs.
-org.apache.qpid.server.failover.FailoverMethodTest#*
-
 
 // Message encryption not currently supported by the 1.0 client
 org.apache.qpid.systest.messageencryption.MessageEncryptionTest#*

http://git-wip-us.apache.org/repos/asf/qpid-broker-j/blob/588c65f7/test-profiles/JavaPre010Excludes
----------------------------------------------------------------------
diff --git a/test-profiles/JavaPre010Excludes b/test-profiles/JavaPre010Excludes
index c89f812..538a93e 100644
--- a/test-profiles/JavaPre010Excludes
+++ b/test-profiles/JavaPre010Excludes
@@ -24,9 +24,6 @@
 // These tests requires a broker capable of 0-8/0-9/0-9-1 and 0-10 concurrently
 org.apache.qpid.test.client.message.JMSDestinationTest#testReceiveResend
 
-// The new addressing based syntax is not supported for AMQP 0-8/0-9 versions
-org.apache.qpid.client.failover.AddressBasedFailoverBehaviourTest#*
-
 // Those tests are written against the 0.10 path
 org.apache.qpid.client.SynchReceiveTest#testReceiveNoWait
 org.apache.qpid.server.logging.ChannelLoggingTest#testChannelClosedOnExclusiveQueueDeclaredOnDifferentSession

http://git-wip-us.apache.org/repos/asf/qpid-broker-j/blob/588c65f7/test-profiles/JavaTransientExcludes
----------------------------------------------------------------------
diff --git a/test-profiles/JavaTransientExcludes b/test-profiles/JavaTransientExcludes
index d4052de..f397a12 100644
--- a/test-profiles/JavaTransientExcludes
+++ b/test-profiles/JavaTransientExcludes
@@ -34,7 +34,3 @@ org.apache.qpid.systest.rest.VirtualHostRestTest#testMutateStateOfVirtualHostWit
 
 org.apache.qpid.systest.rest.VirtualHostNodeRestTest#testCreateAndDeleteVirtualHostNode
 
-org.apache.qpid.client.failover.FailoverBehaviourTest#testFlowControlFlagResetOnFailover
-org.apache.qpid.client.failover.FailoverBehaviourTest#testFailoverHandlerTimeoutReconnected
-org.apache.qpid.server.failover.FailoverMethodTest#testNoFailover
-


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org


Mime
View raw message