anchor.diff:    }
   
     @java.lang.Override
  -  protected void processUpdateMessages( @javax.annotation.Nonnull final org.realityforge.replicant.server.EntityMessage message, @javax.annotation.Nonnull final java.util.Collection<org.realityforge.replicant.server.transport.ReplicantSession> sessions, @javax.annotation.Nonnull org.realityforge.replicant.server.ChangeAccumulator accumulator )
  +  protected void processUpdateMessages( @javax.annotation.Nonnull final org.realityforge.replicant.server.EntityMessage message, @javax.annotation.Nonnull final java.util.Collection<org.realityforge.replicant.server.transport.ReplicantSession> sessions, @javax.annotation.Nonnull final org.realityforge.replicant.server.ChangeAccumulator accumulator )
     {
       final java.util.Map<String, java.io.Serializable> routingKeys = message.getRoutingKeys();
   <%
  
positive.code:   public <%= graph.cacheable? ? 'boolean': 'void' %> subscribeTo<%= graph.name %>( @javax.annotation.Nonnull final String sessionID<%= update_param %><% if graph.cacheable? -%>, @javax.annotation.Nullable final String cacheKey<% end %> )
      throws <%= repository.exception_by_name(repository.imit.invalid_session_exception).ee.qualified_name %>
    {
      <%= graph.cacheable? ? 'final CacheStatus status = ': '' %>subscribe( sessionID, new org.realityforge.replicant.server.ChannelDescriptor( <%= repository.imit.qualified_graph_enum_name %>.<%= Reality::Naming.uppercase_constantize(graph.name) %>.ordinal(), <%= graph.instance_root? ? "#{pk_accessor}" : 'null' %> ), <%= graph.filter_parameter.nil? ? 'null' : 'filter' %>, <%= graph.cacheable? ? 'cacheKey' : 'null' %> );
  <% if graph.cacheable? -%>
      return status != CacheStatus.USE;
  <% end -%>
  
negative.code:   public void update<%= graph.name %>Subscription( @javax.annotation.Nonnull final String sessionID<%= update_param %> )
      throws <%= repository.exception_by_name(repository.imit.invalid_session_exception).ee.qualified_name %>
    {
      updateSubscription( sessionID, new org.realityforge.replicant.server.ChannelDescriptor( <%= repository.imit.qualified_graph_enum_name %>.<%= Reality::Naming.uppercase_constantize(graph.name) %>.ordinal(), <%= graph.instance_root? ? pk_accessor : 'null' %> ), filter, org.realityforge.replicant.server.ee.EntityMessageCacheUtil.getSessionChanges() );
  <%
    processed = []
    graph.outward_graph_links.select{|graph_link| graph_link.auto?}.each do |graph_link|
  