mirror of https://github.com/OpenIdentityPlatform/OpenDJ.git

Chris Ridd
18.51.2014 22ec3dd24c3af40cc6e67318cf83b88e55242d06
opendj3-server-dev/src/server/org/opends/server/replication/protocol/Session.java
@@ -319,6 +319,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)