opends/src/server/org/opends/server/replication/protocol/Session.java
@@ -325,6 +325,11 @@ public void publish(final ReplicationMsg msg) throws IOException { final byte[] buffer = msg.getBytes(protocolVersion); if (buffer == null) { // skip anything that cannot be encoded for this peer. return; } if (isRunning.get()) { while (!closeInitiated)