anchor.diff:    @SuppressWarnings("SynchronizationOnLocalVariableOrMethodParameter")
     @Override
     public boolean saveEntityMessages( @javax.annotation.Nullable final String sessionID,
  -                                     @javax.annotation.Nullable final String jobID,
  +                                     @javax.annotation.Nullable final String requestID,
                                        @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!
  
positive.code:       }
      }
  
      return accumulator.complete( sessionID, jobID );
    }
  
    @javax.annotation.Nonnull
  
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 );
      }
    }
  
  