@Test public void testClientExceptionWithWebApplicationException() { RuntimeException runtimeException = ReactorNettyClientHttpEngine.clientException(new WebApplicationException(), Response.ok().build()); assertEquals(WebApplicationException.class, runtimeException.getClass()); }
static RuntimeException clientException(Throwable ex, Response clientResponse) { RuntimeException ret; if (ex == null) { ret = new ProcessingException(new NullPointerException()); } else if (ex instanceof WebApplicationException) { ret = (WebApplicationException) ex; } else if (ex instanceof ProcessingException) { ret = (ProcessingException) ex; } else if (clientResponse != null) { ret = new ResponseProcessingException(clientResponse, ex); } else { ret = new ProcessingException(ex); } return ret; }
ReactorNettyClientHttpEngine implements AsyncClientHttpEngine { static RuntimeException clientException(Throwable ex, Response clientResponse) { RuntimeException ret; if (ex == null) { ret = new ProcessingException(new NullPointerException()); } else if (ex instanceof WebApplicationException) { ret = (WebApplicationException) ex; } else if (ex instanceof ProcessingException) { ret = (ProcessingException) ex; } else if (clientResponse != null) { ret = new ResponseProcessingException(clientResponse, ex); } else { ret = new ProcessingException(ex); } return ret; } }
ReactorNettyClientHttpEngine implements AsyncClientHttpEngine { static RuntimeException clientException(Throwable ex, Response clientResponse) { RuntimeException ret; if (ex == null) { ret = new ProcessingException(new NullPointerException()); } else if (ex instanceof WebApplicationException) { ret = (WebApplicationException) ex; } else if (ex instanceof ProcessingException) { ret = (ProcessingException) ex; } else if (clientResponse != null) { ret = new ResponseProcessingException(clientResponse, ex); } else { ret = new ProcessingException(ex); } return ret; } private  ReactorNettyClientHttpEngine(final HttpClient httpClient,
                                         final ChannelGroup channelGroup,
                                         final ConnectionProvider connectionProvider,
                                         final Optional<Duration> requestTimeout,
                                         final Boolean useFinalizedResponse);  ReactorNettyClientHttpEngine(final HttpClient httpClient,
                                        final ChannelGroup channelGroup,
                                        final ConnectionProvider connectionProvider);  ReactorNettyClientHttpEngine(final HttpClient httpClient,
                                        final ChannelGroup channelGroup,
                                        final ConnectionProvider connectionProvider,
                                        final Duration requestTimeout);  ReactorNettyClientHttpEngine(final HttpClient httpClient,
                                        final ChannelGroup channelGroup,
                                        final ConnectionProvider connectionProvider,
                                        final Boolean useResponseFinalize);  ReactorNettyClientHttpEngine(final HttpClient httpClient,
                                        final ChannelGroup channelGroup,
                                        final ConnectionProvider connectionProvider,
                                        final Duration requestTimeout,
                                        final Boolean useResponseFinalize); }
ReactorNettyClientHttpEngine implements AsyncClientHttpEngine { static RuntimeException clientException(Throwable ex, Response clientResponse) { RuntimeException ret; if (ex == null) { ret = new ProcessingException(new NullPointerException()); } else if (ex instanceof WebApplicationException) { ret = (WebApplicationException) ex; } else if (ex instanceof ProcessingException) { ret = (ProcessingException) ex; } else if (clientResponse != null) { ret = new ResponseProcessingException(clientResponse, ex); } else { ret = new ProcessingException(ex); } return ret; } private  ReactorNettyClientHttpEngine(final HttpClient httpClient,
                                         final ChannelGroup channelGroup,
                                         final ConnectionProvider connectionProvider,
                                         final Optional<Duration> requestTimeout,
                                         final Boolean useFinalizedResponse);  ReactorNettyClientHttpEngine(final HttpClient httpClient,
                                        final ChannelGroup channelGroup,
                                        final ConnectionProvider connectionProvider);  ReactorNettyClientHttpEngine(final HttpClient httpClient,
                                        final ChannelGroup channelGroup,
                                        final ConnectionProvider connectionProvider,
                                        final Duration requestTimeout);  ReactorNettyClientHttpEngine(final HttpClient httpClient,
                                        final ChannelGroup channelGroup,
                                        final ConnectionProvider connectionProvider,
                                        final Boolean useResponseFinalize);  ReactorNettyClientHttpEngine(final HttpClient httpClient,
                                        final ChannelGroup channelGroup,
                                        final ConnectionProvider connectionProvider,
                                        final Duration requestTimeout,
                                        final Boolean useResponseFinalize); @Override Future<T> submit(final ClientInvocation request,
                                final boolean buffered,
                                final InvocationCallback<T> callback,
                                final ResultExtractor<T> extractor); @Override CompletableFuture<T> submit(final ClientInvocation request,
                                           final boolean buffered,
                                           final ResultExtractor<T> extractor,
                                           final ExecutorService executorService); @Override SSLContext getSslContext(); @Override HostnameVerifier getHostnameVerifier(); @Override Response invoke(Invocation request); @Override void close(); }
ReactorNettyClientHttpEngine implements AsyncClientHttpEngine { static RuntimeException clientException(Throwable ex, Response clientResponse) { RuntimeException ret; if (ex == null) { ret = new ProcessingException(new NullPointerException()); } else if (ex instanceof WebApplicationException) { ret = (WebApplicationException) ex; } else if (ex instanceof ProcessingException) { ret = (ProcessingException) ex; } else if (clientResponse != null) { ret = new ResponseProcessingException(clientResponse, ex); } else { ret = new ProcessingException(ex); } return ret; } private  ReactorNettyClientHttpEngine(final HttpClient httpClient,
                                         final ChannelGroup channelGroup,
                                         final ConnectionProvider connectionProvider,
                                         final Optional<Duration> requestTimeout,
                                         final Boolean useFinalizedResponse);  ReactorNettyClientHttpEngine(final HttpClient httpClient,
                                        final ChannelGroup channelGroup,
                                        final ConnectionProvider connectionProvider);  ReactorNettyClientHttpEngine(final HttpClient httpClient,
                                        final ChannelGroup channelGroup,
                                        final ConnectionProvider connectionProvider,
                                        final Duration requestTimeout);  ReactorNettyClientHttpEngine(final HttpClient httpClient,
                                        final ChannelGroup channelGroup,
                                        final ConnectionProvider connectionProvider,
                                        final Boolean useResponseFinalize);  ReactorNettyClientHttpEngine(final HttpClient httpClient,
                                        final ChannelGroup channelGroup,
                                        final ConnectionProvider connectionProvider,
                                        final Duration requestTimeout,
                                        final Boolean useResponseFinalize); @Override Future<T> submit(final ClientInvocation request,
                                final boolean buffered,
                                final InvocationCallback<T> callback,
                                final ResultExtractor<T> extractor); @Override CompletableFuture<T> submit(final ClientInvocation request,
                                           final boolean buffered,
                                           final ResultExtractor<T> extractor,
                                           final ExecutorService executorService); @Override SSLContext getSslContext(); @Override HostnameVerifier getHostnameVerifier(); @Override Response invoke(Invocation request); @Override void close();  }