Skip to content

Commit d9fca36

Browse files
committed
Add log statement when blocked listener is registered
1 parent 95c0967 commit d9fca36

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

src/main/java/com/rabbitmq/perf/MulticastSet.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1018,6 +1018,7 @@ List<Connection> createConfigurationConnections() throws IOException, TimeoutExc
10181018

10191019
private static void addBlockedListener(Connection connection) {
10201020
String name = connection.getClientProvidedName();
1021+
logger().debug("Registering blocked listener for connection {}.", name);
10211022
connection.addBlockedListener(
10221023
reason -> logger().debug("Connection '{}' blocked: {}.", name, reason),
10231024
() -> logger().debug("Connection '{}' unblocked.", name));

0 commit comments

Comments
 (0)