anchor.diff:          }
         };
         getListener().onUnsubscribeStarted( this, descriptor );
  +      <% if repository.keycloak? -%><%= repository.gwt_rpc.qualified_rpc_services_module_name %>.updateTokenAndExecute( () -> <% end -%>_remoteSubscriptionService.unsubscribeFrom<%= graph.name %>( getSessionID()<% if graph.instance_root? -%>, (<%= repository.entity_by_name(graph.instance_root).primary_key.imit.java_type %>) descriptor.getID()<% end -%>, callback, errorCallback )<% if repository.keycloak? -%> )<% end -%>;
  +    }
  +    else <% end %>
  +    {
  +      throw new IllegalStateException();
  +    }
  +  }
   <% if repository.keycloak? -%>
  -      <%= repository.gwt_rpc.qualified_rpc_services_module_name %>.updateTokenAndExecute( new java.lang.Runnable()
  -      {
  -        @java.lang.Override
  -        public void run()
  -        {
  -    <% end -%>
  -      _remoteSubscriptionService.unsubscribeFrom<%= graph.name %>( getSessionID()<% if graph.instance_root? -%>, (<%= repository.entity_by_name(graph.instance_root).primary_key.imit.java_type %>) descriptor.getID()<% end -%>, callback, errorCallback );
  -<% if repository.keycloak? -%>
  -        }
  -      } );
  -<% end -%>
  -    }
  -    else <% end %>
  -    {
  -      throw new IllegalStateException();
  -    }
  -  }
  -<% if repository.keycloak? -%>
   
     @javax.annotation.Nonnull
     @java.lang.Override
  
positive.code:         }
        };
        getListener().onSubscribeStarted( this, descriptor );
  <% if repository.keycloak? -%>
        <%= repository.gwt_rpc.qualified_rpc_services_module_name %>.updateTokenAndExecute( new java.lang.Runnable()
        {
          @java.lang.Override
          public void run()
          {
      <% end -%>
        _remoteSubscriptionService.subscribeTo<%= graph.name %>( getSessionID()<% if graph.cacheable? -%>, eTag<% end -%><% if graph.instance_root? -%>, (<%= repository.entity_by_name(graph.instance_root).primary_key.imit.java_type %>) descriptor.getID()<% end -%><% if graph.filtered? %>, (<%= Domgen::Java.java_type(graph.filter_parameter, :gwt, :default) %>) filterParameter<% end -%>, callback, errorCallback );
  <% if repository.keycloak? -%>
          }
        } );
  <% end -%>
      }
      else <% end %>
      {
  
negative.code:         }
        };
        getListener().onSubscriptionUpdateStarted( this, descriptor );
        <% if repository.keycloak? -%><%= repository.gwt_rpc.qualified_rpc_services_module_name %>.updateTokenAndExecute( () -> <% end -%>_remoteSubscriptionService.update<%= graph.name %>Subscription( getSessionID()<% if graph.instance_root? -%>, (<%= repository.entity_by_name(graph.instance_root).primary_key.imit.java_type %>) descriptor.getID()<% end -%>, (<%= Domgen::Java.java_type(graph.filter_parameter, :gwt, :default) %>) filterParameter, callback, errorCallback )<% if repository.keycloak? -%> )<% end -%>;
      }
      else <% end %>
      {
  