diff --git a/src/main/java/com/rabbitmq/client/impl/nio/NioLoop.java b/src/main/java/com/rabbitmq/client/impl/nio/NioLoop.java index cbc387fd33..ef0e357a53 100644 --- a/src/main/java/com/rabbitmq/client/impl/nio/NioLoop.java +++ b/src/main/java/com/rabbitmq/client/impl/nio/NioLoop.java @@ -78,6 +78,9 @@ public void run() { state.getConnection().handleHeartbeatFailure(); } catch (Exception e) { LOGGER.warn("Error after heartbeat failure of connection {}", state.getConnection()); + } catch (AssertionError e) { + // see https://github.com/rabbitmq/rabbitmq-java-client/issues/237 + LOGGER.warn("Assertion error after heartbeat failure of connection {}", state.getConnection()); } finally { selectionKey.cancel(); }