Skip to content

Commit ebedbac

Browse files
committed
Back to HashSet in metrics collector
It was not the cause of the problem.
1 parent 8f0759d commit ebedbac

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/main/java/com/rabbitmq/client/impl/AbstractMetricsCollector.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -342,7 +342,7 @@ private static class ChannelState {
342342

343343
final Set<Long> unackedMessageDeliveryTags = new HashSet<>();
344344
final Set<String> consumersWithManualAck = new HashSet<>();
345-
final Set<Long> unconfirmedMessageDeliveryTags = ConcurrentHashMap.newKeySet();
345+
final Set<Long> unconfirmedMessageDeliveryTags = new HashSet<>();
346346

347347
final Channel channel;
348348

0 commit comments

Comments
 (0)