anchor.diff:  <% bulk_subscribe_graphs.each do |graph| -%>
       if ( <%= repository.imit.qualified_subscription_constants_name %>.<%= Reality::Naming.uppercase_constantize(graph.name) %> == address.getChannelId() )
       {
  -      _context.bulkCollectDataFor<%= graph.name %>( session, addresses<% if graph.filter_parameter -%>, (<%= Domgen::Java.java_type(graph.filter_parameter, :ee, :default) %>) filter<% end %> );
  +      _context.bulkCollectDataFor<%= graph.name %>( session, addresses<% if graph.filter_parameter -%>, (<%= Domgen::Java.java_type(graph.filter_parameter, :ee, :default) %>) filter<% end %>, true );
         return true;
       }
   <% end -%>
  
positive.code: <% if repository.imit.graphs.any?{|graph| graph.filter_parameter? && !graph.filter_parameter.immutable? && !graph.outward_graph_links.empty? && graph.outward_graph_links.any?{|graph_link| graph_link.auto? && repository.imit.graph_by_name(graph_link.target_graph).filtered?} } -%>
  
    @java.lang.Override
    public void updateSubscription( @javax.annotation.Nonnull final org.realityforge.replicant.server.transport.ReplicantSession session,
                                    @javax.annotation.Nonnull final org.realityforge.replicant.server.ChannelAddress address,
                                    @javax.annotation.Nullable final java.lang.Object filter,
                                    @javax.annotation.Nonnull final org.realityforge.replicant.server.ChangeSet changeSet )
    {
      super.updateSubscription( session, address, filter, changeSet );
  <% repository.imit.graphs.select{|graph| graph.filter_parameter? && !graph.filter_parameter.immutable? }.each do |graph|
    root_type = graph.instance_root? ? Domgen::Java.java_type(repository.entity_by_name(graph.instance_root).primary_key, :ee, :default) : nil
    processed = []
    graph.outward_graph_links.select{|graph_link| graph_link.auto?}.each do |graph_link|
       target_graph = repository.imit.graph_by_name(graph_link.target_graph)
  
negative.code:     if( <%= repository.imit.qualified_subscription_constants_name %>.<%= Reality::Naming.uppercase_constantize(graph.name) %> == address.getChannelId() )
      {
        assert null != filter;
        propagateFilterFrom<%= graph.name %>To<%= target_graph.name %>( session, <% if graph.instance_root? %>address.getSubChannelId(), <% end %>(<%= Domgen::Java.java_type(graph.filter_parameter, :ee, :default) %>) filter, changeSet );
      }
  <% end -%>
  <% end -%>
  