You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ke...@apache.org on 2014/01/17 10:20:00 UTC
git commit: Removed test,
it has been commented out and not run for over a year. See AMQ-4974
Updated Branches:
refs/heads/trunk 082d26349 -> 0918430dc
Removed test, it has been commented out and not run for over a year. See AMQ-4974
Project: http://git-wip-us.apache.org/repos/asf/activemq/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/0918430d
Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/0918430d
Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/0918430d
Branch: refs/heads/trunk
Commit: 0918430dc20b6d2952ce393d218c355135de466e
Parents: 082d263
Author: Kevin Earls <ke...@kevinearls.com>
Authored: Fri Jan 17 10:19:49 2014 +0100
Committer: Kevin Earls <ke...@kevinearls.com>
Committed: Fri Jan 17 10:19:49 2014 +0100
----------------------------------------------------------------------
.../NetworkConnectionsCleanedupTest.java | 73 --------------------
1 file changed, 73 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/activemq/blob/0918430d/activemq-unit-tests/src/test/java/org/apache/activemq/network/NetworkConnectionsCleanedupTest.java
----------------------------------------------------------------------
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 021addc..0000000
--- 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<ActiveMQDestination> list = new ArrayList<ActiveMQDestination>();
- 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);
- }
-}