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;
+ }
+
+ }
+}
