anchor.diff:  
     @SuppressWarnings("SynchronizationOnLocalVariableOrMethodParameter")
     @Override
  -  public void saveEntityMessages( @javax.annotation.Nonnull final java.util.Collection<org.realityforge.replicant.server.EntityMessage> messages )
  +  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!
       final java.util.Map<String, <%= repository.imit.qualified_session_name %>> sessions = getSessions();
  
positive.code:   @javax.inject.Inject
    private <%= repository.imit.qualified_graph_encoder_name %> _encoder;
  
    @javax.annotation.Nonnull
    protected final <%= repository.imit.qualified_graph_encoder_name %> getEncoder()
    {
  
negative.code: <% else -%>
        collect<%= graph.key %>( messages );
  <% end -%>
        final String jobID = (String) _registry.getResource( org.realityforge.replicant.shared.transport.ReplicantContext.REQUEST_ID_KEY );
        session.getQueue().addPacket( jobID, messages );
      }
    }
  
  