ARTEMIS-3096 Fixing compilation on JDK 1.8

This commit is contained in:
Clebert Suconic 2021-02-04 17:35:36 -05:00
parent 337df5286c
commit e65eff0f24
1 changed files with 3 additions and 1 deletions

View File

@ -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())));