You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by cl...@apache.org on 2021/02/04 22:36:37 UTC
[activemq-artemis] branch master updated: ARTEMIS-3096 Fixing
compilation on JDK 1.8
This is an automated email from the ASF dual-hosted git repository.
clebertsuconic pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/activemq-artemis.git
The following commit(s) were added to refs/heads/master by this push:
new e65eff0 ARTEMIS-3096 Fixing compilation on JDK 1.8
e65eff0 is described below
commit e65eff0f243e0dc5a2af7d76781c48b30fd0173f
Author: Clebert Suconic <cl...@apache.org>
AuthorDate: Thu Feb 4 17:35:36 2021 -0500
ARTEMIS-3096 Fixing compilation on JDK 1.8
---
.../activemq/artemis/tests/integration/cluster/bridge/BridgeTest.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/cluster/bridge/BridgeTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/cluster/bridge/BridgeTest.java
index de8f4f8..de5ce7e 100644
--- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/cluster/bridge/BridgeTest.java
+++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/cluster/bridge/BridgeTest.java
@@ -2025,11 +2025,13 @@ public class BridgeTest extends ActiveMQTestBase {
server.waitForActivation(100, TimeUnit.MILLISECONDS);
server.createQueue(new QueueConfiguration(QUEUE).setAddress(ADDRESS).setRoutingType(RoutingType.ANYCAST).setDurable(false));
server.createQueue(new QueueConfiguration(FORWARDING_QUEUE).setAddress(FORWARDING_ADDRESS).setRoutingType(RoutingType.ANYCAST).setDurable(false));
+ ArrayList<String> connectors = new ArrayList<>();
+ connectors.add("myConnector");
server.deployBridge(new BridgeConfiguration()
.setName(BRIDGE)
.setQueueName(QUEUE.toString())
.setForwardingAddress(FORWARDING_ADDRESS.toString())
- .setStaticConnectors(List.of("myConnector")));
+ .setStaticConnectors(connectors));
// now we actually have to use the bridge to make sure it connected correctly
locator = addServerLocator(ActiveMQClient.createServerLocatorWithoutHA(new TransportConfiguration(getConnector())));