queryObj.execute(add_container, GenericLogic.collectionType_ADD); queryObj.returnVal(printOut );
if( add_container.size() > 0) { queryObj.execute(add_container, GenericLogic.collectionType_ADD); queryObj.returnVal(printOut ); printOut.print(delimiter); }
  public final void synchronizedExecute(      PrintStream out,      HttpInput query_parameters,      PlanServiceContext psc,      PlanServiceUtilities psu,      GLDictionary my_gl_dict,      Collection add_container,      Collection change_container,      Collection remove_container,      GenericQuery queryObj      ) throws Exception  {      boolean useHTML =         (boolean)query_parameters.existsParameter("HTML");      boolean tellME =         (boolean)query_parameters.existsParameter("TELLME");      System.out.println("[PSP_GenericReaderWriter] +++> start execution @"                         + psc.getServerPluginSupport().getClusterIDAsString()                         + " useHTML=" + useHTML                         );      if(tellME ){           out.println("<HTML><BODY><H3>Generic Reader/Writer PSP TELL</H3>");           out.println("Dictionary=" + my_gl_dict.toHTMLString());           out.println("</BODY></HTML>");           return;      }      if( queryObj != null )      {          ByteArrayOutputStream bufOut = null;          PrintStream printOut = null;          if( useHTML ) {              bufOut = new ByteArrayOutputStream(512);              printOut = new PrintStream(bufOut);          }          else printOut = out;          System.out.println("[PSP_GenericReaderWriter] using GenericQuery instance="                             + queryObj                             + " add_container.size=" + add_container.size()                             + " change_container.size=" + change_container.size()                             + " remove_container.size=" + remove_container.size()                             );          //Subscription subscription = psc.getServerPluginSupport().subscribe(this, queryObj.getPredicate());          //Collection container = ((CollectionSubscription)subscription).getCollection();          queryObj.execute(add_container, GenericLogic.collectionType_ADD);          queryObj.returnVal(printOut );          queryObj.execute(change_container, GenericLogic.collectionType_CHANGE);          queryObj.returnVal(printOut );          queryObj.execute(remove_container, GenericLogic.collectionType_REMOVE);          queryObj.returnVal(printOut );          if(useHTML )          {              StringBuffer sb = HTMLize.layoutXML(                   new StringBuffer(new String(bufOut.toByteArray())),                   new HashMap(),                   true                   );              out.print("<HTML><BODY><PRE><BLOCKQUOTE>" +                       sb.toString()                       + "</BLOCKQUOTE></PRE></BODY></HTML>"                   );         }      }      out.flush();      System.out.println("[PSP_GenericReaderWriter] <+++ leave execution @" + psc.getServerPluginSupport().getClusterIDAsString() );  }