opends/src/server/org/opends/server/replication/server/MessageHandler.java
@@ -40,6 +40,7 @@ import org.opends.server.replication.common.CSN; import org.opends.server.replication.common.ServerState; import org.opends.server.replication.protocol.UpdateMsg; import org.opends.server.replication.server.changelog.api.ChangelogException; import org.opends.server.replication.server.changelog.api.ReplicaDBCursor; import org.opends.server.types.*; @@ -305,6 +306,10 @@ lateQueue.add(cursor.getChange()); } } catch (ChangelogException e) { TRACER.debugCaught(DebugLogLevel.ERROR, e); } finally { close(cursor);