code: @Override
    public <T> void inPipe(HeadersAmp headers, 
                            PipeSub<T> result,
                            StubAmp actor,
                            Object[] args)
    {
      result.fail(new UnsupportedOperationException(getClass().getName()));
    }
docs: pipe publish registration call