anchor.diff:        }
       }
   
  -    return accumulator.complete( sessionID, jobID );
  +    return accumulator.complete( sessionID, requestID );
     }
   
     @javax.annotation.Nonnull
  
positive.code:   @SuppressWarnings("SynchronizationOnLocalVariableOrMethodParameter")
    @Override
    public boolean saveEntityMessages( @javax.annotation.Nullable final String sessionID,
                                       @javax.annotation.Nullable final String jobID,
                                       @javax.annotation.Nonnull final java.util.Collection<org.realityforge.replicant.server.EntityMessage> messages )
    {
      //TODO: Rewrite this so that we add clients to indexes rather than searching through everyone for each change!
  
negative.code: <% else -%>
        collect<%= graph.key %>( messages );
  <% end -%>
        final String requestID = (String) _registry.getResource( org.realityforge.replicant.shared.transport.ReplicantContext.REQUEST_ID_KEY );
        session.getQueue().addPacket( requestID, messages );
      }
    }
  
  