Skip to content

Commit 4105266

Browse files
committed
Do not record trackers
It's just for debugging.
1 parent f4e69d7 commit 4105266

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

src/main/java/com/rabbitmq/stream/impl/ConsumersCoordinator.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -84,7 +84,7 @@ class ConsumersCoordinator {
8484
private final NavigableSet<ClientSubscriptionsManager> managers = new ConcurrentSkipListSet<>();
8585
private final AtomicLong trackerIdSequence = new AtomicLong(0);
8686

87-
private final boolean debug = true;
87+
private final boolean debug = false;
8888
private final List<SubscriptionTracker> trackers = new CopyOnWriteArrayList<>();
8989

9090
ConsumersCoordinator(

src/main/java/com/rabbitmq/stream/impl/ProducersCoordinator.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -68,7 +68,7 @@ class ProducersCoordinator {
6868
private final AtomicLong managerIdSequence = new AtomicLong(0);
6969
private final NavigableSet<ClientProducersManager> managers = new ConcurrentSkipListSet<>();
7070
private final AtomicLong trackerIdSequence = new AtomicLong(0);
71-
private final boolean debug = true;
71+
private final boolean debug = false;
7272
private final List<ProducerTracker> producerTrackers = new CopyOnWriteArrayList<>();
7373

7474
ProducersCoordinator(

0 commit comments

Comments
 (0)