activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject svn commit: r1177799 - /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/AMQ3014Test.java
Date Fri, 30 Sep 2011 19:38:46 GMT
Author: tabish
Date: Fri Sep 30 19:38:46 2011
New Revision: 1177799

URL: http://svn.apache.org/viewvc?rev=1177799&view=rev
Log:
Add missing license header

Modified:
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/AMQ3014Test.java

Modified: activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/AMQ3014Test.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/AMQ3014Test.java?rev=1177799&r1=1177798&r2=1177799&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/AMQ3014Test.java (original)
+++ activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/AMQ3014Test.java Fri
Sep 30 19:38:46 2011
@@ -1,3 +1,19 @@
+/**
+ * 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.bugs;
 
 import java.io.IOException;
@@ -31,165 +47,165 @@ import org.junit.Test;
  * transfered once the local broker's ID is known to the bridge support.
  */
 public class AMQ3014Test {
-	// Change this URL to be an unused port.
-	private static final String REMOTE_BROKER_URL = "tcp://localhost:50000";
+    // Change this URL to be an unused port.
+    private static final String REMOTE_BROKER_URL = "tcp://localhost:50000";
 
-	private List<BrokerInfo> remoteBrokerInfos = Collections
-			.synchronizedList(new ArrayList<BrokerInfo>());
+    private List<BrokerInfo> remoteBrokerInfos = Collections
+            .synchronizedList(new ArrayList<BrokerInfo>());
 
-	private BrokerService localBroker = new BrokerService();
+    private BrokerService localBroker = new BrokerService();
 
-	// Override the "remote" broker so that it records all (remote) BrokerInfos
-	// that it receives.
-	private BrokerService remoteBroker = new BrokerService() {
-		@Override
-		protected TransportConnector createTransportConnector(URI brokerURI)
-				throws Exception {
-			TransportServer transport = TransportFactory.bind(this, brokerURI);
-			return new TransportConnector(transport) {
-				@Override
-				protected Connection createConnection(Transport transport)
-						throws IOException {
-					Connection connection = super.createConnection(transport);
-					final TransportListener proxiedListener = transport
-							.getTransportListener();
-					transport.setTransportListener(new TransportListener() {
-
-						@Override
-						public void onCommand(Object command) {
-							if (command instanceof BrokerInfo) {
-								remoteBrokerInfos.add((BrokerInfo) command);
-							}
-							proxiedListener.onCommand(command);
-						}
-
-						@Override
-						public void onException(IOException error) {
-							proxiedListener.onException(error);
-						}
-
-						@Override
-						public void transportInterupted() {
-							proxiedListener.transportInterupted();
-						}
-
-						@Override
-						public void transportResumed() {
-							proxiedListener.transportResumed();
-						}
-					});
-					return connection;
-				}
-
-			};
-		}
-	};
-
-	@Before
-	public void init() throws Exception {
-		localBroker.setBrokerName("localBroker");
-		localBroker.setPersistent(false);
-		localBroker.setUseJmx(false);
-		localBroker.setSchedulerSupport(false);
-
-		remoteBroker.setBrokerName("remoteBroker");
-		remoteBroker.setPersistent(false);
-		remoteBroker.setUseJmx(false);
-		remoteBroker.addConnector(REMOTE_BROKER_URL);
-		remoteBroker.setSchedulerSupport(false);
-	}
-
-	@After
-	public void cleanup() throws Exception {
-		try {
-			localBroker.stop();
-		} finally {
-			remoteBroker.stop();
-		}
-	}
-
-	/**
-	 * This test verifies that the local broker's ID is typically known by the
-	 * bridge support before the local broker's BrokerInfo is sent to the remote
-	 * broker.
-	 */
-	@Test
-	public void NormalCaseTest() throws Exception {
-		runTest(0, 3000);
-	}
-
-	/**
-	 * This test verifies that timing can arise under which the local broker's
-	 * ID is not known by the bridge support before the local broker's
-	 * BrokerInfo is sent to the remote broker.
-	 */
-	@Test
-	public void DelayedCaseTest() throws Exception {
-		runTest(500, 3000);
-	}
-
-	private void runTest(final long taskRunnerDelay, long timeout)
-			throws Exception {
-		// Add a network connector to the local broker that will create a bridge
-		// to the remote broker.
-		DiscoveryNetworkConnector dnc = new DiscoveryNetworkConnector();
-		SimpleDiscoveryAgent da = new SimpleDiscoveryAgent();
-		da.setServices(REMOTE_BROKER_URL);
-		dnc.setDiscoveryAgent(da);
-		localBroker.addNetworkConnector(dnc);
-
-		// Before starting the local broker, intercept the task runner factory
-		// so that the
-		// local VMTransport dispatcher is artificially delayed.
-		final TaskRunnerFactory realTaskRunnerFactory = localBroker
-				.getTaskRunnerFactory();
-		localBroker.setTaskRunnerFactory(new TaskRunnerFactory() {
-			public TaskRunner createTaskRunner(Task task, String name) {
-				final TaskRunner realTaskRunner = realTaskRunnerFactory
-						.createTaskRunner(task, name);
-				if (name.startsWith("ActiveMQ Connection Dispatcher: ")) {
-					return new TaskRunner() {
-						@Override
-						public void shutdown() throws InterruptedException {
-							realTaskRunner.shutdown();
-						}
-
-						@Override
-						public void shutdown(long timeout)
-								throws InterruptedException {
-							realTaskRunner.shutdown(timeout);
-						}
-
-						@Override
-						public void wakeup() throws InterruptedException {
-							Thread.sleep(taskRunnerDelay);
-							realTaskRunner.wakeup();
-						}
-					};
-				} else {
-					return realTaskRunnerFactory.createTaskRunner(task, name);
-				}
-			}
-		});
-
-		// Start the brokers and wait for the bridge to be created; the remote
-		// broker is started first to ensure it is available for the local
-		// broker to connect to.
-		remoteBroker.start();
-		localBroker.start();
-
-		// Wait for the remote broker to receive the local broker's BrokerInfo
-		// and then verify the local broker's ID is known.
-		long startTimeMillis = System.currentTimeMillis();
-		while (remoteBrokerInfos.isEmpty()
-				&& (System.currentTimeMillis() - startTimeMillis) < timeout) {
-			Thread.sleep(100);
-		}
-
-		Assert.assertFalse("Timed out waiting for bridge to form.",
-				remoteBrokerInfos.isEmpty());
-		;
-		Assert.assertNotNull("Local broker ID is null.", remoteBrokerInfos.get(
-				0).getBrokerId());
-	}
+    // Override the "remote" broker so that it records all (remote) BrokerInfos
+    // that it receives.
+    private BrokerService remoteBroker = new BrokerService() {
+        @Override
+        protected TransportConnector createTransportConnector(URI brokerURI)
+                throws Exception {
+            TransportServer transport = TransportFactory.bind(this, brokerURI);
+            return new TransportConnector(transport) {
+                @Override
+                protected Connection createConnection(Transport transport)
+                        throws IOException {
+                    Connection connection = super.createConnection(transport);
+                    final TransportListener proxiedListener = transport
+                            .getTransportListener();
+                    transport.setTransportListener(new TransportListener() {
+
+                        @Override
+                        public void onCommand(Object command) {
+                            if (command instanceof BrokerInfo) {
+                                remoteBrokerInfos.add((BrokerInfo) command);
+                            }
+                            proxiedListener.onCommand(command);
+                        }
+
+                        @Override
+                        public void onException(IOException error) {
+                            proxiedListener.onException(error);
+                        }
+
+                        @Override
+                        public void transportInterupted() {
+                            proxiedListener.transportInterupted();
+                        }
+
+                        @Override
+                        public void transportResumed() {
+                            proxiedListener.transportResumed();
+                        }
+                    });
+                    return connection;
+                }
+
+            };
+        }
+    };
+
+    @Before
+    public void init() throws Exception {
+        localBroker.setBrokerName("localBroker");
+        localBroker.setPersistent(false);
+        localBroker.setUseJmx(false);
+        localBroker.setSchedulerSupport(false);
+
+        remoteBroker.setBrokerName("remoteBroker");
+        remoteBroker.setPersistent(false);
+        remoteBroker.setUseJmx(false);
+        remoteBroker.addConnector(REMOTE_BROKER_URL);
+        remoteBroker.setSchedulerSupport(false);
+    }
+
+    @After
+    public void cleanup() throws Exception {
+        try {
+            localBroker.stop();
+        } finally {
+            remoteBroker.stop();
+        }
+    }
+
+    /**
+     * This test verifies that the local broker's ID is typically known by the
+     * bridge support before the local broker's BrokerInfo is sent to the remote
+     * broker.
+     */
+    @Test
+    public void NormalCaseTest() throws Exception {
+        runTest(0, 3000);
+    }
+
+    /**
+     * This test verifies that timing can arise under which the local broker's
+     * ID is not known by the bridge support before the local broker's
+     * BrokerInfo is sent to the remote broker.
+     */
+    @Test
+    public void DelayedCaseTest() throws Exception {
+        runTest(500, 3000);
+    }
+
+    private void runTest(final long taskRunnerDelay, long timeout)
+            throws Exception {
+        // Add a network connector to the local broker that will create a bridge
+        // to the remote broker.
+        DiscoveryNetworkConnector dnc = new DiscoveryNetworkConnector();
+        SimpleDiscoveryAgent da = new SimpleDiscoveryAgent();
+        da.setServices(REMOTE_BROKER_URL);
+        dnc.setDiscoveryAgent(da);
+        localBroker.addNetworkConnector(dnc);
+
+        // Before starting the local broker, intercept the task runner factory
+        // so that the
+        // local VMTransport dispatcher is artificially delayed.
+        final TaskRunnerFactory realTaskRunnerFactory = localBroker
+                .getTaskRunnerFactory();
+        localBroker.setTaskRunnerFactory(new TaskRunnerFactory() {
+            public TaskRunner createTaskRunner(Task task, String name) {
+                final TaskRunner realTaskRunner = realTaskRunnerFactory
+                        .createTaskRunner(task, name);
+                if (name.startsWith("ActiveMQ Connection Dispatcher: ")) {
+                    return new TaskRunner() {
+                        @Override
+                        public void shutdown() throws InterruptedException {
+                            realTaskRunner.shutdown();
+                        }
+
+                        @Override
+                        public void shutdown(long timeout)
+                                throws InterruptedException {
+                            realTaskRunner.shutdown(timeout);
+                        }
+
+                        @Override
+                        public void wakeup() throws InterruptedException {
+                            Thread.sleep(taskRunnerDelay);
+                            realTaskRunner.wakeup();
+                        }
+                    };
+                } else {
+                    return realTaskRunnerFactory.createTaskRunner(task, name);
+                }
+            }
+        });
+
+        // Start the brokers and wait for the bridge to be created; the remote
+        // broker is started first to ensure it is available for the local
+        // broker to connect to.
+        remoteBroker.start();
+        localBroker.start();
+
+        // Wait for the remote broker to receive the local broker's BrokerInfo
+        // and then verify the local broker's ID is known.
+        long startTimeMillis = System.currentTimeMillis();
+        while (remoteBrokerInfos.isEmpty()
+                && (System.currentTimeMillis() - startTimeMillis) < timeout) {
+            Thread.sleep(100);
+        }
+
+        Assert.assertFalse("Timed out waiting for bridge to form.",
+                remoteBrokerInfos.isEmpty());
+        ;
+        Assert.assertNotNull("Local broker ID is null.", remoteBrokerInfos.get(
+                0).getBrokerId());
+    }
 }



Mime
View raw message