We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 0122af3 commit a129316Copy full SHA for a129316
src/com/rabbitmq/client/impl/AMQConnection.java
@@ -670,8 +670,10 @@ public void handleConnectionClose(Command closeCommand) {
670
_brokerInitiatedShutdown = true;
671
SocketCloseWait scw = new SocketCloseWait(sse);
672
Thread waiter = threadFactory.newThread(scw);
673
- waiter.setName("AMQP Connection Closing Monitor " +
674
- getHostAddress() + ":" + getPort());
+ if(Environment.isAllowedToModifyThreads()) {
+ waiter.setName("AMQP Connection Closing Monitor " +
675
+ getHostAddress() + ":" + getPort());
676
+ }
677
waiter.start();
678
}
679
0 commit comments