diff --git a/activemq-unit-tests/src/test/java/org/apache/activemq/network/NetworkConnectionsCleanedupTest.java b/activemq-unit-tests/src/test/java/org/apache/activemq/network/NetworkConnectionsCleanedupTest.java deleted file mode 100755 index 021addc476..0000000000 --- a/activemq-unit-tests/src/test/java/org/apache/activemq/network/NetworkConnectionsCleanedupTest.java +++ /dev/null @@ -1,73 +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.activemq.network; - -import java.util.ArrayList; -import java.util.List; - -import javax.jms.Connection; -import javax.jms.Session; - -import org.apache.activemq.broker.BrokerService; -import org.apache.activemq.command.ActiveMQDestination; -import org.apache.activemq.command.ActiveMQTopic; -import org.junit.Ignore; -import org.junit.Test; -import org.springframework.context.support.AbstractApplicationContext; - -public class NetworkConnectionsCleanedupTest { - - protected static final int MESSAGE_COUNT = 10; - - protected AbstractApplicationContext context; - protected Connection localConnection; - protected Connection remoteConnection; - protected BrokerService localBroker; - protected BrokerService remoteBroker; - protected Session localSession; - protected Session remoteSession; - protected ActiveMQTopic included; - protected ActiveMQTopic excluded; - protected String consumerName = "durableSubs"; - - // skip this test. it runs for an hour, doesn't assert anything, and could probably - // just be removed (seems like a throwaway impl for https://issues.apache.org/activemq/browse/AMQ-1202) - @Ignore - @Test - public void skipTestNetworkConnections() throws Exception { - String uri = "static:(tcp://localhost:61617)?initialReconnectDelay=100"; - List list = new ArrayList(); - for (int i =0;i < 100;i++){ - list.add(new ActiveMQTopic("FOO"+i)); - } - String bindAddress = "tcp://localhost:61616"; - BrokerService broker = new BrokerService(); - broker.setUseJmx(false); - broker.setPersistent(false); - broker.addConnector(bindAddress); - NetworkConnector network = broker.addNetworkConnector(uri); - network.setDynamicOnly(true); - network.setStaticallyIncludedDestinations(list); - uri = "static:(tcp://localhost:61618)?initialReconnectDelay=100"; - network = broker.addNetworkConnector(uri); - network.setDynamicOnly(true); - network.setStaticallyIncludedDestinations(list); - broker.setUseShutdownHook(false); - broker.start(); - Thread.sleep(1000 * 3600); - } -}