Author: gtully
Date: Fri May 7 08:03:49 2010
New Revision: 942025
URL: http://svn.apache.org/viewvc?rev=942025&view=rev
Log:
add simple test for localport uri notation in a connection factory:
http://activemq.apache.org/how-do-i-define-a-local-address-and-local-port-for-tcp-or-ssl.html
Modified:
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/ActiveMQConnectionFactoryTest.java
Modified:
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/ActiveMQConnectionFactoryTest.java
URL:
http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/ActiveMQConnectionFactoryTest.java?rev=942025&r1=942024&r2=942025&view=diff
==============================================================================
---
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/ActiveMQConnectionFactoryTest.java
(original)
+++
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/ActiveMQConnectionFactoryTest.java
Fri May 7 08:03:49 2010
@@ -137,6 +137,20 @@ public class ActiveMQConnectionFactoryTe
assertCreateConnection("tcp://localhost:61610?wireFormat.tcpNoDelayEnabled=true");
}
+ public void testCreateTcpConnectionUsingKnownLocalPort() throws Exception {
+ broker = new BrokerService();
+ broker.setPersistent(false);
+ TransportConnector connector =
broker.addConnector("tcp://localhost:61610?wireFormat.tcpNoDelayEnabled=true");
+ broker.start();
+
+ // This should create the connection.
+ ActiveMQConnectionFactory cf = new
ActiveMQConnectionFactory("tcp://localhost:61610/localhost:51610");
+ connection = (ActiveMQConnection)cf.createConnection();
+ assertNotNull(connection);
+
+ broker.stop();
+ }
+
public void testConnectionFailsToConnectToVMBrokerThatIsNotRunning()
throws Exception {
ActiveMQConnectionFactory factory = new
ActiveMQConnectionFactory("vm://localhost?create=false");
try {
