activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jstrac...@apache.org
Subject svn commit: r356815 - /incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/JmsQueueSendReceiveTwoConnectionsStartBeforeBrokerTest.java
Date Wed, 14 Dec 2005 17:35:30 GMT
Author: jstrachan
Date: Wed Dec 14 09:35:27 2005
New Revision: 356815

URL: http://svn.apache.org/viewcvs?rev=356815&view=rev
Log:
added test case which demonstrates that you can start a JMS connection even when the broker
is not there

Added:
    incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/JmsQueueSendReceiveTwoConnectionsStartBeforeBrokerTest.java
  (with props)

Added: incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/JmsQueueSendReceiveTwoConnectionsStartBeforeBrokerTest.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/JmsQueueSendReceiveTwoConnectionsStartBeforeBrokerTest.java?rev=356815&view=auto
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/JmsQueueSendReceiveTwoConnectionsStartBeforeBrokerTest.java
(added)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/JmsQueueSendReceiveTwoConnectionsStartBeforeBrokerTest.java
Wed Dec 14 09:35:27 2005
@@ -0,0 +1,88 @@
+/**
+* <a href="http://activemq.org">ActiveMQ: The Open Source Message Fabric</a>
+*
+* Copyright 2005 (C) LogicBlaze, Inc. http://www.logicblaze.com
+*
+* Licensed 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.activemq;
+
+import edu.emory.mathcs.backport.java.util.Queue;
+import edu.emory.mathcs.backport.java.util.concurrent.ConcurrentLinkedQueue;
+
+import org.activemq.broker.BrokerService;
+
+
+/**
+ * @version $Revision$
+ */
+public class JmsQueueSendReceiveTwoConnectionsStartBeforeBrokerTest extends JmsQueueSendReceiveTwoConnectionsTest
{
+
+    private Queue errors = new ConcurrentLinkedQueue();
+    private int delayBeforeStartingBroker = 1000;
+    private BrokerService broker;
+
+    public void startBroker() {
+        // Initialize the broker
+        System.out.println("Lets wait: " + delayBeforeStartingBroker + " millis  before creating
the broker");
+        try {
+            Thread.sleep(delayBeforeStartingBroker);
+        }
+        catch (InterruptedException e) {
+            e.printStackTrace();
+        }
+        
+        System.out.println("Now starting the broker");
+        try {
+            broker = new BrokerService();
+            broker.setPersistent(false);
+            broker.addConnector("tcp://localhost:61616");
+            broker.start();
+        }
+        catch (Exception e) {
+            System.out.println("Caught: " + e);
+            errors.add(e);
+        }
+    }
+    protected ActiveMQConnectionFactory createConnectionFactory() throws Exception {
+        return new ActiveMQConnectionFactory("failover:(tcp://localhost:61616)?maxReconnectAttempts=10&useExponentialBackOff=false&initialReconnectDelay=200");
+    }
+
+    protected void setUp() throws Exception {
+        // now lets asynchronously start a broker
+        Thread thread = new Thread() {
+            public void run() {
+                startBroker();
+            }
+        };
+        thread.start();
+
+        super.setUp();
+    }
+
+    protected void tearDown() throws Exception {
+        super.tearDown();
+
+        if (broker != null) {
+            broker.stop();
+        }
+        if (!errors.isEmpty()) {
+            Exception e = (Exception) errors.remove();
+            throw e;
+        }
+    }
+    
+    
+
+}

Propchange: incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/JmsQueueSendReceiveTwoConnectionsStartBeforeBrokerTest.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/JmsQueueSendReceiveTwoConnectionsStartBeforeBrokerTest.java
------------------------------------------------------------------------------
    svn:keywords = Date Author Id Revision HeadURL

Propchange: incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/JmsQueueSendReceiveTwoConnectionsStartBeforeBrokerTest.java
------------------------------------------------------------------------------
    svn:mime-type = text/plain



Mime
View raw message