anchor.diff:        _entityManager.flush();
         try
         {
  -<% if entity.imit? -%>
  +<% if entity.imit? || entity.attributes.any?{|a| a.reference? && a.referenced_entity.imit? } -%>
           org.realityforge.replicant.server.ee.ReplicationRequestUtil.startReplication( _registry, "synchronize<%= entity.data_module.name %><%= entity.name %>Updates", null, null );
   <% end -%>
   <% attr = entity.attributes.select{|a| a.sql? && a.jpa? && a.sync? } -%>
  
positive.code:       finally
        {
          // End Replication "Hook"
  <% if entity.imit? -%>
          org.realityforge.replicant.server.ee.ReplicationRequestUtil.completeReplication( _registry, _entityManager, _endpoint );
  <% end -%>
          if( javax.transaction.Status.STATUS_MARKED_ROLLBACK == _transaction.getStatus() )
  
negative.code:       finally
        {
          // End Replication "Hook"
  <% if entity.imit? || entity.attributes.any?{|a| a.reference? && a.referenced_entity.imit? } -%>
          org.realityforge.replicant.server.ee.ReplicationRequestUtil.completeReplication( _registry, _entityManager, _endpoint );
  <% end -%>
          if( javax.transaction.Status.STATUS_MARKED_ROLLBACK == _transaction.getStatus() )
  