docs: public void forceFlushAtTarget() throws SIMPRuntimeOperationFailedException
    {
      if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled()) 
        SibTr.entry(tc, "forceFlushAtTarget");
      
      try
      {
        assertValidControllable();
      }
      catch (SIMPControllableNotFoundException e)
      {
        FFDCFilter.processException(
          e,
          "com.ibm.ws.sib.processor.runtime.RemoteConsumerReceiver.forceFlushAtTarget",
          "1:204:1.47",
          this);
        
        SIMPRuntimeOperationFailedException finalE =
          new SIMPRuntimeOperationFailedException(
            nls.getFormattedMessage(
              "INTERNAL_MESSAGING_ERROR_CWSIP0003",
              new Object[] {"RemoteConsumerReceiver.forceFlushAtTarget",
                  "1:212:1.47",
                            e,
                            aiStream.getStreamId()},
              null), e);
              
        SibTr.exception(tc, finalE);
        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled()) SibTr.exit(tc, "forceFlushAtTarget", finalE);
        throw finalE;
      }
      
      AnycastInputHandler aih = destinationHandler.getAnycastInputHandler(dme, gatheringTargetDestUuid, true);
      
      if (aih != null)
      {
        aih.forceFlushAtTarget();
        try
        {
          String key = 
            SIMPUtils.getRemoteGetKey(dme, gatheringTargetDestUuid);
          ((BaseDestinationHandler)destinationHandler).removeAnycastInputHandlerAndRCD(key);
        }
        catch(SIResourceException e)
        {
          FFDCFilter.processException(
            e,
            "com.ibm.ws.sib.processor.runtime.RemoteConsumerReceiver.forceFlushAtTarget",
            "1:238:1.47",
            this);
        
          SIMPRuntimeOperationFailedException finalE =
            new SIMPRuntimeOperationFailedException(
              nls.getFormattedMessage(
                "INTERNAL_MESSAGING_ERROR_CWSIP0003",
                new Object[] {"RemoteConsumerReceiver.forceFlushAtTarget",
                    "1:246:1.47",
                              e,
                              aiStream.getStreamId()},
                null), e);
              
          SibTr.exception(tc, finalE);
          if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled()) SibTr.exit(tc, "forceFlushAtTarget", finalE);
          throw finalE;
        }
      }
      
      if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled()) 
        SibTr.exit(tc, "forceFlushAtTarget");    
    }