docs: protected boolean assureAllFlushed()
                      throws SIResourceException
      {
  
          if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
              SibTr.entry(tc, "assureAllFlushed");
  
          boolean done = true;
  
          if (isPubSub())
          {
              // Tell pubsub to clean everything up.  Clean outgoing first.
              // Note that we attempt to drive both sides of the protocol
              // even though one side may already have told us the delete needs
              // to be deffered.
              PubSubInputHandler pHandler = (PubSubInputHandler) inputHandler;
              boolean resultOne = pHandler.flushAllForDeleteSource();
              boolean resultTwo = pHandler.flushAllForDeleteTarget();
              done = resultOne && resultTwo;
          }
          else
          {
              // If we've originated streams for PtoP, then make sure they're
              // all flushed before we continue with the delete.
              // We only perform this if the destination is not MQ
              if (getSourceProtocolItemStream() != null)
              {
                  // The output handler drives the flush, so we need to track
                  // it down first, then call the flush.  The assumption here
                  // is that since we're in the middle of a delete nobody
                  // can be doing nasty things like adding new queue points.
                  done = _ptoPRealization.flushQueuePointOutputHandler();
  
              } //if (sourceProtocolItemStream != null)
  
              // Likewise, if we're a target then make sure we flushed all target
              // streams before allowing the delete to continue.
              // We only perform this if the destination is not MQ
              if (getTargetProtocolItemStream() != null)
              {
                  done &= ((PtoPInputHandler) inputHandler).flushAllForDelete();
              }
          }
  
          if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
              SibTr.exit(tc, "assureAllFlushed", Boolean.valueOf(done));
  
          return done;
      }