code: public void batchCommitted()
    {
      if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled()) SibTr.entry(this, tc, "batchCommitted");
  
      synchronized(flushedStreamSets)
      {
        Iterator<StreamSet> itr = flushedStreamSets.iterator();
        while(itr.hasNext())
        {
          StreamSet streamSet = itr.next();
          try
          {
            streamSet.remove();
            itr.remove();
          }
          catch (SIException e)
          {
            // FFDC
            FFDCFilter.processException(
              e,
              "com.ibm.ws.sib.processor.gd.TargetStreamManager.batchCommitted",
              "1:1297:1.69",
              this);
  
            if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled()) SibTr.exit(tc, "batchCommitted", "SIErrorException");
            throw new SIErrorException(e);
          }
        }
      }
      if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled()) SibTr.exit(tc, "batchCommitted");
    }
docs: /* (non-Javadoc)
  @see com.ibm.ws.sib.processor.impl.interfaces.BatchListener#batchCommitted()