anchor.diff:            {
               if ( session.<%= check_method %>(<%= param %> ))
               {
  -              accumulator.addEntityMessage( session.getQueue(), message );
  +              accumulator.addEntityMessage( session, message );
               }
             }
           }
  
positive.code: <% else -%>
        collect<%= graph.key %>( messages );
  <% end -%>
        session.getQueue().addPacket( messages );
      }
    }
  
  
negative.code:       }
      }
  
      return accumulator.complete( sessionID, jobID );
    }
  
    @javax.annotation.Nonnull
  