You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ta...@apache.org on 2014/05/15 17:59:05 UTC
git commit: Add option to turn on an OpenWire TCP endpoint.
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 <ta...@gmail.com>
Authored: Thu May 15 11:58:49 2014 -0400
Committer: Timothy Bish <ta...@gmail.com>
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;
}