diff --git a/p2p/src/main/java/bisq/network/p2p/peers/Broadcaster.java b/p2p/src/main/java/bisq/network/p2p/peers/Broadcaster.java index dee52c2f87..4c194d5c65 100644 --- a/p2p/src/main/java/bisq/network/p2p/peers/Broadcaster.java +++ b/p2p/src/main/java/bisq/network/p2p/peers/Broadcaster.java @@ -38,7 +38,6 @@ import java.util.Set; import java.util.concurrent.CopyOnWriteArraySet; import java.util.concurrent.ThreadPoolExecutor; import java.util.concurrent.TimeUnit; -import java.util.stream.Collectors; import lombok.Value; import lombok.extern.slf4j.Slf4j; @@ -119,11 +118,6 @@ public class Broadcaster implements BroadcastHandler.ResultHandler { @Nullable NodeAddress sender, @Nullable BroadcastHandler.Listener listener) { broadcastRequests.add(new BroadcastRequest(message, sender, listener)); - // Keep that log on INFO for better debugging if the feature works as expected. Later it can - // be remove or set to DEBUG - log.debug("Broadcast requested for {}. We queue it up for next bundled broadcast.", - message.getClass().getSimpleName()); - if (timer == null) { timer = UserThread.runAfter(this::maybeBroadcastBundle, BROADCAST_INTERVAL_MS, TimeUnit.MILLISECONDS); } @@ -131,9 +125,6 @@ public class Broadcaster implements BroadcastHandler.ResultHandler { private void maybeBroadcastBundle() { if (!broadcastRequests.isEmpty()) { - log.debug("Broadcast bundled requests of {} messages. Message types: {}", - broadcastRequests.size(), - broadcastRequests.stream().map(e -> e.getMessage().getClass().getSimpleName()).collect(Collectors.toList())); BroadcastHandler broadcastHandler = new BroadcastHandler(networkNode, peerManager, this); broadcastHandlers.add(broadcastHandler); broadcastHandler.broadcast(new ArrayList<>(broadcastRequests), shutDownRequested, executor);