anchor.diff:  <% if method.imit? %>
           if ( null != session )
           {
  -          session.getRequestManager().removeRequest( request.getRequestID() );
  +          session.removeRequest( request.getRequestID() );
             if( LOG.isLoggable( LOG_LEVEL ) )
             {
               LOG.log( LOG_LEVEL, "<%= service.qualified_name %>.<%= method.name %> request completed with exception and no change set or already arrived: RequestID=" + request.getRequestID() );
  
positive.code:   final org.realityforge.replicant.client.transport.RequestEntry request;
    if( null != session )
    {
      request = session.getRequestManager().newRequestRegistration( <%= method.imit.graph_to_subscribe.nil? ? 'null' : "#{method.service.data_module.repository.imit.qualified_graph_enum_name}.#{Domgen::Naming.uppercase_constantize(method.service.data_module.repository.imit.graph_by_name(method.imit.graph_to_subscribe).name)}.name()" %>, <%= method.imit.bulk_load? %> );
      org.realityforge.replicant.client.transport.SessionContext.setRequest( request );
      if( LOG.isLoggable( LOG_LEVEL ) )
      {
  
negative.code: <% if method.imit? %>
          if ( null != session )
          {
            session.removeRequest( request.getRequestID() );
            if( LOG.isLoggable( LOG_LEVEL ) )
            {
              LOG.log( LOG_LEVEL, "<%= service.qualified_name %>.<%= method.name %> request completed normally and no change set or already arrived: RequestID=" + request.getRequestID() );
  