Repository: activemq Updated Branches: refs/heads/trunk ff64b14bc -> b83a3d438
Add option to turn on an OpenWire TCP endpoint. Project: http://git-wip-us.apache.org/repos/asf/activemq/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/b83a3d43 Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/b83a3d43 Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/b83a3d43 Branch: refs/heads/trunk Commit: b83a3d4388cebf9583319a074f3457ba0e8d980b Parents: ff64b14 Author: Timothy Bish <[email protected]> Authored: Thu May 15 11:58:49 2014 -0400 Committer: Timothy Bish <[email protected]> Committed: Thu May 15 11:58:49 2014 -0400 ---------------------------------------------------------------------- .../apache/activemq/transport/amqp/AmqpTestSupport.java | 11 +++++++++++ 1 file changed, 11 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq/blob/b83a3d43/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/AmqpTestSupport.java ---------------------------------------------------------------------- diff --git a/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/AmqpTestSupport.java b/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/AmqpTestSupport.java index e24412d..8150bc0 100644 --- a/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/AmqpTestSupport.java +++ b/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/AmqpTestSupport.java @@ -64,6 +64,7 @@ public class AmqpTestSupport { protected int sslPort; protected int nioPort; protected int nioPlusSslPort; + protected int openwirePort; public static void main(String[] args) throws Exception { final AmqpTestSupport s = new AmqpTestSupport(); @@ -123,6 +124,12 @@ public class AmqpTestSupport { protected void addAMQPConnector() throws Exception { TransportConnector connector = null; + if (isUseOpenWireConnector()) { + connector = brokerService.addConnector( + "tcp://0.0.0.0:" + openwirePort); + openwirePort = connector.getConnectUri().getPort(); + LOG.debug("Using openwire port " + openwirePort); + } if (isUseTcpConnector()) { connector = brokerService.addConnector( "amqp://0.0.0.0:" + port + "?transport.transformer=" + getAmqpTransformer()); @@ -149,6 +156,10 @@ public class AmqpTestSupport { } } + protected boolean isUseOpenWireConnector() { + return false; + } + protected boolean isUseTcpConnector() { return true; }
