/** * Called by HttpServer when there is a matching request for the context */ @Override public void handle(HttpExchange msg) { try { if (logger.isLoggable(Level.FINE)) { logger.log(Level.FINE, "Received HTTP request:{0}", msg.getRequestURI()); } if (executor != null) { // Use application's Executor to handle request. Application may // have set an executor using Endpoint.setExecutor(). executor.execute(new HttpHandlerRunnable(msg)); } else { handleExchange(msg); } } catch (Throwable e) { // Dont't propagate the exception otherwise it kills the httpserver logger.log(Level.SEVERE, null, e); } }
public void handleExchange(HttpExchange msg) throws IOException { WSHTTPConnection con = new PortableConnectionImpl(adapter,msg); try { if (logger.isLoggable(Level.FINE)) { logger.log(Level.FINE, "Received HTTP request:{0}", msg.getRequestURI()); } String method = msg.getRequestMethod(); if(method.equals(GET_METHOD) || method.equals(POST_METHOD) || method.equals(HEAD_METHOD) || method.equals(PUT_METHOD) || method.equals(DELETE_METHOD)) { adapter.handle(con); } else { logger.warning(HttpserverMessages.UNEXPECTED_HTTP_METHOD(method)); } } finally { msg.close(); } }
/** * Called by HttpServer when there is a matching request for the context */ public void handle(HttpExchange msg) { try { logger.fine("Received HTTP request:"+msg.getRequestURI()); if (executor != null) { // Use application's Executor to handle request. Application may // have set an executor using Endpoint.setExecutor(). executor.execute(new HttpHandlerRunnable(msg)); } else { handleExchange(msg); } } catch(Throwable e) { // Dont't propagate the exception otherwise it kills the httpserver e.printStackTrace(); } }
@Override public void handleRequest(HttpServerExchange ex) throws IOException { ClassLoader origClassLoader = SecurityActions.getContextClassLoader(); final Bus origBus = BusFactory.getThreadDefaultBus(); if (bus != null) { BusFactory.setThreadDefaultBus(bus); } try { SecurityActions.setContextClassLoader(this.classLoader); super.handleRequest(ex); } catch (Exception e) { LOG.throwing(SwitchYardHttpHandler.class.getName(), "handle(" + HttpExchange.class.getName() + " ex)", e); if (e instanceof IOException) { throw (IOException) e; } else { throw new RuntimeException(e); } } finally { if (bus != null) { SecurityActions.setContextClassLoader(origClassLoader); BusFactory.setThreadDefaultBus(origBus); } } }
public void handleExchange(HttpExchange msg) throws IOException { WSHTTPConnection con = new PortableConnectionImpl(adapter,msg); try { logger.fine("Received HTTP request:"+msg.getRequestURI()); String method = msg.getRequestMethod(); if(method.equals(GET_METHOD) || method.equals(POST_METHOD) || method.equals(HEAD_METHOD) || method.equals(PUT_METHOD) || method.equals(DELETE_METHOD)) { adapter.handle(con); } else { logger.warning(HttpserverMessages.UNEXPECTED_HTTP_METHOD(method)); } } finally { msg.close(); } }
public PortableConnectionImpl(@NotNull HttpAdapter adapter, @NotNull HttpExchange httpExchange) { this.adapter = adapter; this.httpExchange = httpExchange; }
@Property(JAXWSProperties.HTTP_EXCHANGE) public HttpExchange getExchange() { return httpExchange; }
HttpHandlerRunnable(HttpExchange msg) { this.msg = msg; }