Skip to content

Commit 80d5504

Browse files
committed
Add log info in case of enqueuing timeout
1 parent 798aef6 commit 80d5504

File tree

2 files changed

+2
-0
lines changed

2 files changed

+2
-0
lines changed

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

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -324,6 +324,7 @@ public void writeFrame(Frame frame) throws IOException {
324324
if (canWriteNow) {
325325
this.doWriteFrame(frame);
326326
} else {
327+
this.handler.logEvents();
327328
throw new IOException("Frame enqueuing failed");
328329
}
329330
} catch (InterruptedException e) {

src/test/resources/logback-test.xml

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -8,6 +8,7 @@
88
<logger name="com.rabbitmq.client.AmqpClientTestExtension" level="debug" />
99
<logger name="com.rabbitmq.client.test.server.TopicPermissions" level="debug" />
1010
<logger name="com.rabbitmq.client.impl.AbstractMetricsCollector" level="debug" />
11+
<logger name="com.rabbitmq.client.impl.NettyFrameHandlerFactory" level="debug" />
1112

1213
<root level="warn">
1314
<appender-ref ref="STDOUT" />

0 commit comments

Comments
 (0)