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

Chris Ridd
18.31.2014 15639797b80c1667a0e91d0e467227da95d3cd49
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)