Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Don't use a fixed port. 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1443038 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Timothy A. Bish 2013-02-06 16:16:20 +00:00
parent dc33c5918f
commit 88b80e28ba
1 changed files with 9 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
activemq-unit-tests/src/test/java/org/apache/activemq/transport/tcp/TcpTransportBindTest.java
View File

@ -20,7 +20,6 @@ import java.util.Timer;
import java.util.TimerTask;
import javax.jms.Connection;
import javax.jms.Message;
import javax.jms.MessageConsumer;
import javax.jms.Session;
@ -28,29 +27,32 @@ import org.apache.activemq.ActiveMQConnectionFactory;
import org.apache.activemq.EmbeddedBrokerTestSupport;
public class TcpTransportBindTest extends EmbeddedBrokerTestSupport {
final String addr = "tcp://localhost:61617";
String addr = "tcp://localhost:0";
/**
* exercise some server side socket options
* @throws Exception
*/
protected void setUp() throws Exception {
@Override
protected void setUp() throws Exception {
bindAddress = addr + "?transport.reuseAddress=true&transport.soTimeout=1000";
super.setUp();
addr = broker.getTransportConnectors().get(0).getPublishableConnectString();
}
public void testConnect() throws Exception {
Connection connection = new ActiveMQConnectionFactory(addr).createConnection();
connection.start();
}
public void testReceiveThrowsException() throws Exception {
Connection connection = new ActiveMQConnectionFactory(addr).createConnection();
connection.start();
Session sess = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
MessageConsumer consumer = sess.createConsumer(createDestination());
class StopTask extends TimerTask {
@Override
public void run() {
try {
broker.stop();