Author: jlmonteiro
Date: Thu Jul 21 10:01:23 2011
New Revision: 1149094
URL: http://svn.apache.org/viewvc?rev=1149094&view=rev
Log:
Fix some other default ports for ActiveMQ
Modified:
openejb/branches/openejb-3.2.x/container/openejb-core/src/test/java/org/apache/openejb/core/mdb/JmsMdbContainerTest.java
Modified:
openejb/branches/openejb-3.2.x/container/openejb-core/src/test/java/org/apache/openejb/core/mdb/JmsMdbContainerTest.java
URL:
http://svn.apache.org/viewvc/openejb/branches/openejb-3.2.x/container/openejb-core/src/test/java/org/apache/openejb/core/mdb/JmsMdbContainerTest.java?rev=1149094&r1=1149093&r2=1149094&view=diff
==============================================================================
---
openejb/branches/openejb-3.2.x/container/openejb-core/src/test/java/org/apache/openejb/core/mdb/JmsMdbContainerTest.java
(original)
+++
openejb/branches/openejb-3.2.x/container/openejb-core/src/test/java/org/apache/openejb/core/mdb/JmsMdbContainerTest.java
Thu Jul 21 10:01:23 2011
@@ -18,13 +18,14 @@ package org.apache.openejb.core.mdb;
import junit.framework.TestCase;
import org.apache.openejb.assembler.classic.Assembler;
+import org.apache.openejb.assembler.classic.ResourceInfo;
import org.apache.openejb.assembler.classic.SecurityServiceInfo;
import org.apache.openejb.assembler.classic.TransactionServiceInfo;
import org.apache.openejb.config.ConfigurationFactory;
import org.apache.openejb.core.ivm.naming.InitContextFactory;
import org.apache.openejb.jee.EjbJar;
import org.apache.openejb.jee.MessageDrivenBean;
-import static org.apache.openejb.util.Join.join;
+import org.apache.openejb.util.NetworkUtil;
import javax.annotation.PostConstruct;
import javax.annotation.Resource;
@@ -39,13 +40,17 @@ import javax.jms.Queue;
import javax.jms.Session;
import javax.jms.TextMessage;
import javax.naming.InitialContext;
+import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
+import java.util.Properties;
import java.util.Stack;
import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;
+import static org.apache.openejb.util.Join.join;
+
/**
* @version $Rev$ $Date$
*/
@@ -56,8 +61,16 @@ public class JmsMdbContainerTest extends
ConfigurationFactory config = new ConfigurationFactory();
Assembler assembler = new Assembler();
+ // define props for RA in order to change the default activeMQ port
+ Properties props = new Properties();
+ String brokerAddress = NetworkUtil.getLocalAddress("tcp://", "");
+ String brokerXmlConfig = "broker:(" + brokerAddress + ")?useJmx=false";
+ props.put("BrokerXmlConfig", brokerXmlConfig);
+
assembler.createTransactionManager(config.configureService(TransactionServiceInfo.class));
assembler.createSecurityService(config.configureService(SecurityServiceInfo.class));
+ assembler.createResource(config.configureService(ResourceInfo.class,
"Default JMS Resource Adapter",
+ props, "Default JMS Resource Adapter",
"ActiveMQResourceAdapter"));
// Setup the descriptor information
