anchor.diff:          }
         };
   <% if method.imit? -%>
  -      if( null != request && LOG.isLoggable( LOG_LEVEL ) )
  -      {
  -        LOG.log( LOG_LEVEL, <%= Reality::Naming.uppercase_constantize(method.qualified_name.gsub(/[#\\.]/,'_')) %> + " request completed normally: RequestID=" + request.getRequestID() );
  -      }
  -      if ( null != request && request.isExpectingResults() && !request.haveResultsArrived() )
  -      {
  -        request.setNormalCompletionAction( runnable );
  -        if( LOG.isLoggable( LOG_LEVEL ) )
  -        {
  -          LOG.log( LOG_LEVEL, <%= Reality::Naming.uppercase_constantize(method.qualified_name.gsub(/[#\\.]/,'_')) %> + " request completed normally but change set not arrived: RequestID=" + request.getRequestID() );
  -        }
  +      if( null != request )
  +      {
  +        session.completeNormalRequest( request, runnable );
         }
         else
   <% end -%>
         {
           runnable.run();
  -<% if method.imit? -%>
  -        if ( null != session )
  -        {
  -          session.removeRequest( request.getRequestID() );
  -          if( LOG.isLoggable( LOG_LEVEL ) )
  -          {
  -            LOG.log( LOG_LEVEL, <%= Reality::Naming.uppercase_constantize(method.qualified_name.gsub(/[#\\.]/,'_')) %> + " request completed normally and no change set or already arrived: RequestID=" + request.getRequestID() );
  -          }
  -        }
  -        if( LOG.isLoggable( LOG_LEVEL ) )
  -        {
  -          LOG.log( LOG_LEVEL, <%= Reality::Naming.uppercase_constantize(method.qualified_name.gsub(/[#\\.]/,'_')) %> + " request completed normally." );
  -        }
  -<% end -%>
         }
       }
       });
  
positive.code:         }
        };
  <% if method.imit? -%>
        if( null != request && LOG.isLoggable( LOG_LEVEL ) )
        {
          LOG.log( LOG_LEVEL, <%= Reality::Naming.uppercase_constantize(method.qualified_name.gsub(/[#\\.]/,'_')) %> + " request completed with exception: RequestID=" + request.getRequestID() );
        }
        if( null != request && request.isExpectingResults() && !request.haveResultsArrived() )
        {
          request.setNonNormalCompletionAction( runnable );
          if( LOG.isLoggable( LOG_LEVEL ) )
          {
            LOG.log( LOG_LEVEL, <%= Reality::Naming.uppercase_constantize(method.qualified_name.gsub(/[#\\.]/,'_')) %> + " request completed with exception but change set not arrived: RequestID=" + request.getRequestID() );
          }
        }
        else
  <% end -%>
        {
          runnable.run();
  <% if method.imit? -%>
          if ( null != session )
          {
            session.removeRequest( request.getRequestID() );
            if( LOG.isLoggable( LOG_LEVEL ) )
            {
              LOG.log( LOG_LEVEL, <%= Reality::Naming.uppercase_constantize(method.qualified_name.gsub(/[#\\.]/,'_')) %> + " request completed with exception and no change set or already arrived: RequestID=" + request.getRequestID() );
            }
          }
  <% end -%>
        }
  <% if method.imit? -%>
        if( LOG.isLoggable( LOG_LEVEL ) )
        {
          LOG.log( LOG_LEVEL, <%= Reality::Naming.uppercase_constantize(method.qualified_name.gsub(/[#\\.]/,'_')) %> + " request completed with exception." );
        }
  <% end -%>
      }
  
      public void onSuccess( final <%= method.return_value.gwt_rpc.non_primitive_java_type(:transport) %> result )
  
negative.code:   {
      request = session.newRequestRegistration( <%= Reality::Naming.uppercase_constantize(method.qualified_name.gsub(/[#\\.]/,'_')) %>, <%= method.imit.graph_to_subscribe.nil? ? 'null' : "#{service.data_module.repository.gwt_rpc.qualified_rpc_services_module_name}.getSessionContext().getKey() + \":\" + #{method.service.data_module.repository.imit.qualified_graph_enum_name}.#{Reality::Naming.uppercase_constantize(method.service.data_module.repository.imit.graph_by_name(method.imit.graph_to_subscribe).name)}.name()" %>, <%= method.imit.bulk_load? %> );
      <%= service.data_module.repository.gwt_rpc.qualified_rpc_services_module_name %>.getSessionContext().setRequest( request );
    }
    else
    {
  