activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From a..@apache.org
Subject svn commit: r357310 - in /incubator/activemq/trunk/assembly/src/test/org/activemq/usecases: TwoBrokerTopicSendReceiveTest.java TwoBrokerTopicSendReceiveUsingJavaConfigurationTest.java TwoBrokerTopicSendReceiveUsingTcpTest.java
Date Sat, 17 Dec 2005 06:14:08 GMT
Author: aco
Date: Fri Dec 16 22:13:59 2005
New Revision: 357310

URL: http://svn.apache.org/viewcvs?rev=357310&view=rev
Log:
Ported tcp test case. Explicitly specify not to use embedded broker in ActiveMQConnectionFactory.

Added:
    incubator/activemq/trunk/assembly/src/test/org/activemq/usecases/TwoBrokerTopicSendReceiveUsingTcpTest.java
Modified:
    incubator/activemq/trunk/assembly/src/test/org/activemq/usecases/TwoBrokerTopicSendReceiveTest.java
    incubator/activemq/trunk/assembly/src/test/org/activemq/usecases/TwoBrokerTopicSendReceiveUsingJavaConfigurationTest.java

Modified: incubator/activemq/trunk/assembly/src/test/org/activemq/usecases/TwoBrokerTopicSendReceiveTest.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/assembly/src/test/org/activemq/usecases/TwoBrokerTopicSendReceiveTest.java?rev=357310&r1=357309&r2=357310&view=diff
==============================================================================
--- incubator/activemq/trunk/assembly/src/test/org/activemq/usecases/TwoBrokerTopicSendReceiveTest.java
(original)
+++ incubator/activemq/trunk/assembly/src/test/org/activemq/usecases/TwoBrokerTopicSendReceiveTest.java
Fri Dec 16 22:13:59 2005
@@ -68,6 +68,7 @@
 
             BrokerService broker = brokerFactory.getBroker();
             ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory(((TransportConnector)broker.getTransportConnectors().get(0)).getConnectUri());
+            factory.setUseEmbeddedBroker(false);
 
             return factory;
 

Modified: incubator/activemq/trunk/assembly/src/test/org/activemq/usecases/TwoBrokerTopicSendReceiveUsingJavaConfigurationTest.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/assembly/src/test/org/activemq/usecases/TwoBrokerTopicSendReceiveUsingJavaConfigurationTest.java?rev=357310&r1=357309&r2=357310&view=diff
==============================================================================
--- incubator/activemq/trunk/assembly/src/test/org/activemq/usecases/TwoBrokerTopicSendReceiveUsingJavaConfigurationTest.java
(original)
+++ incubator/activemq/trunk/assembly/src/test/org/activemq/usecases/TwoBrokerTopicSendReceiveUsingJavaConfigurationTest.java
Fri Dec 16 22:13:59 2005
@@ -39,6 +39,7 @@
             receiveBroker.start();
 
             ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory("tcp://localhost:62002");
+            factory.setUseEmbeddedBroker(false);
             return factory;
         } catch (Exception e) {
             e.printStackTrace();
@@ -55,6 +56,7 @@
             sendBroker.start();
 
             ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory("tcp://localhost:62001");
+            factory.setUseEmbeddedBroker(false);
             return factory;
         } catch (Exception e) {
             e.printStackTrace();

Added: incubator/activemq/trunk/assembly/src/test/org/activemq/usecases/TwoBrokerTopicSendReceiveUsingTcpTest.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/assembly/src/test/org/activemq/usecases/TwoBrokerTopicSendReceiveUsingTcpTest.java?rev=357310&view=auto
==============================================================================
--- incubator/activemq/trunk/assembly/src/test/org/activemq/usecases/TwoBrokerTopicSendReceiveUsingTcpTest.java
(added)
+++ incubator/activemq/trunk/assembly/src/test/org/activemq/usecases/TwoBrokerTopicSendReceiveUsingTcpTest.java
Fri Dec 16 22:13:59 2005
@@ -0,0 +1,87 @@
+/** 
+ * 
+ * Copyright 2004 Protique Ltd
+ * 
+ * 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.usecases;
+
+import javax.jms.JMSException;
+
+import org.activemq.ActiveMQConnectionFactory;
+import org.activemq.xbean.BrokerFactoryBean;
+import org.activemq.broker.BrokerService;
+import org.activemq.broker.TransportConnector;
+import org.springframework.core.io.ClassPathResource;
+
+import java.io.IOException;
+import java.net.URISyntaxException;
+
+/**
+ * @version $Revision: 1.1.1.1 $
+ */
+public class TwoBrokerTopicSendReceiveUsingTcpTest extends TwoBrokerTopicSendReceiveTest
{
+    private BrokerService receiverBroker;
+    private BrokerService senderBroker;
+
+    protected void setUp() throws Exception {
+        BrokerFactoryBean brokerFactory;
+
+        brokerFactory = new BrokerFactoryBean(new ClassPathResource("org/activemq/usecases/receiver.xml"));
+        brokerFactory.afterPropertiesSet();
+        receiverBroker = brokerFactory.getBroker();
+
+        brokerFactory = new BrokerFactoryBean(new ClassPathResource("org/activemq/usecases/sender.xml"));
+        brokerFactory.afterPropertiesSet();
+        senderBroker = brokerFactory.getBroker();
+
+        super.setUp();
+        Thread.sleep(2000);
+    }
+
+    protected void tearDown() throws Exception {
+        super.tearDown();
+
+        if (receiverBroker != null) {
+            receiverBroker.stop();
+        }
+        if (senderBroker != null) {
+            senderBroker.stop();
+        }
+    }
+
+    
+    protected ActiveMQConnectionFactory createReceiverConnectionFactory() throws JMSException
{
+        try {
+            ActiveMQConnectionFactory fac =  new ActiveMQConnectionFactory(((TransportConnector)receiverBroker.getTransportConnectors().get(0)).getConnectUri());
+            fac.setUseEmbeddedBroker(false);
+            return fac;
+        } catch (Exception e) {
+            e.printStackTrace();
+            return null;
+        }
+    }
+
+    protected ActiveMQConnectionFactory createSenderConnectionFactory() throws JMSException
{
+        try {
+            ActiveMQConnectionFactory fac = new ActiveMQConnectionFactory(((TransportConnector)senderBroker.getTransportConnectors().get(0)).getConnectUri());
+            fac.setUseEmbeddedBroker(false);
+            return fac;
+        } catch (Exception e) {
+            e.printStackTrace();
+            return null;
+        }
+
+    }
+}



Mime
View raw message