[activemq-artemis] branch main updated: NO-JIRA Fix DiscoveryTest#testSimpleBroadcast

[brusdev]

This is an automated email from the ASF dual-hosted git repository.

brusdev pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/activemq-artemis.git


The following commit(s) were added to refs/heads/main by this push:
     new 055d05b  NO-JIRA Fix DiscoveryTest#testSimpleBroadcast
055d05b is described below

commit 055d05b9f1e18209c6fe783c77c6924b3a6b9c3b
Author: Domenico Francesco Bruscino <brus...@apache.org>
AuthorDate: Fri Dec 31 14:22:37 2021 +0100

    NO-JIRA Fix DiscoveryTest#testSimpleBroadcast
---
 .../activemq/artemis/tests/integration/discovery/DiscoveryTest.java    | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git 
a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/discovery/DiscoveryTest.java
 
b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/discovery/DiscoveryTest.java
index 7fd85b7..f28094a 100644
--- 
a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/discovery/DiscoveryTest.java
+++ 
b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/discovery/DiscoveryTest.java
@@ -29,7 +29,6 @@ import 
org.apache.activemq.artemis.api.core.BroadcastEndpointFactory;
 import 
org.apache.activemq.artemis.api.core.JGroupsFileBroadcastEndpointFactory;
 import org.apache.activemq.artemis.api.core.SimpleString;
 import org.apache.activemq.artemis.api.core.TransportConfiguration;
-import org.apache.activemq.artemis.api.core.UDPBroadcastEndpointFactory;
 import org.apache.activemq.artemis.api.core.jgroups.JChannelManager;
 import org.apache.activemq.artemis.api.core.management.CoreNotificationType;
 import org.apache.activemq.artemis.core.cluster.DiscoveryEntry;
@@ -97,7 +96,7 @@ public class DiscoveryTest extends DiscoveryBaseTest {
 
       final String nodeID = RandomUtil.randomString();
 
-      bg = new BroadcastGroupImpl(new FakeNodeManager(nodeID), 
RandomUtil.randomString(), 0, null, new 
UDPBroadcastEndpointFactory().setGroupAddress(address1).setGroupPort(groupPort));
+      bg = newBroadcast(nodeID, RandomUtil.randomString(), null, -1, 
groupAddress, groupPort);
 
       bg.start();