We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 4e57202 commit 9317d48Copy full SHA for 9317d48
src/main/java/com/rabbitmq/client/impl/nio/NioLoop.java
@@ -280,7 +280,11 @@ protected void dispatchIoErrorToConnection(final SocketChannelFrameHandlerState
280
281
@Override
282
public void run() {
283
- state.getConnection().handleIoError(ex);
+ try {
284
+ state.getConnection().handleIoError(ex);
285
+ } catch(AssertionError e) {
286
+ LOGGER.warn("Assertion error during error dispatching to connection: " + e.getMessage());
287
+ }
288
}
289
};
290
if (executorService() == null) {
0 commit comments