code: public void requestFlushAtSource(boolean indoubtDiscard) throws SIMPRuntimeOperationFailedException, SIMPControllableNotFoundException
    {
      if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
        SibTr.entry(tc, "requestFlushAtSource", new Boolean(indoubtDiscard));
  
      assertValidControllable();
  
      SIBUuid8 source = streamSet.getRemoteMEUuid();
      SIBUuid12 destID = streamSet.getDestUuid();
      SIBUuid8 busID = streamSet.getBusUuid();
      try
      {
        //TODO pass through the indoubtDiscard flag      
        tsm.requestFlushAtSource(source, destID, busID, streamID, indoubtDiscard);
      }
      catch (SIException e)
      {
        FFDCFilter.processException(
          e,
          "com.ibm.ws.sib.processor.runtime.TargetStreamSetControl.requestFlushAtSource",
          "1:152:1.16",
          this);
        
        SIMPRuntimeOperationFailedException finalE =
          new SIMPRuntimeOperationFailedException(
            nls.getFormattedMessage(
              "INTERNAL_MESSAGING_ERROR_CWSIP0003",
              new Object[] {"TargetStreamSetControl.requestFlushAtSource",
                  "1:160:1.16",
                            e,
                            streamID},
              null), e);
  
        SibTr.exception(tc, finalE);
        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled()) SibTr.exit(tc, "requestFlushAtSource", finalE);
        throw finalE;             
      }
      if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
        SibTr.exit(tc, "requestFlushAtSource");
    }
docs: /* (non-Javadoc)
  @see com.ibm.ws.sib.processor.runtime.SIMPPtoPInboundReceiverControllable#requestFlushAtSource(byte)