super.connectionClosed(conn);
}
};
HttpProcessor serverHttpProc = new ImmutableHttpProcessor(new HttpResponseInterceptor[] {
new ResponseDate(),
new ResponseServer(),
new ResponseContent(),
new ResponseConnControl()
});
BufferingHttpServiceHandler serviceHandler = new BufferingHttpServiceHandler(
serverHttpProc,
new DefaultHttpResponseFactory(),
new DefaultConnectionReuseStrategy(),
this.server.getParams());
serviceHandler.setHandlerResolver(
new SimpleHttpRequestHandlerResolver(requestHandler));
serviceHandler.setEventListener(
serverEventListener);
EventListener clientEventListener = new SimpleEventListener() {
@Override
public void connectionOpen(NHttpConnection conn) {
openClientConns.incrementAndGet();
super.connectionOpen(conn);
}
@Override
public void connectionClosed(NHttpConnection conn) {
closedClientConns.incrementAndGet();
super.connectionClosed(conn);
}
};
HttpProcessor clientHttpProc = new ImmutableHttpProcessor(new HttpRequestInterceptor[] {
new RequestContent(),
new RequestTargetHost(),
new RequestConnControl(),
new RequestUserAgent(),
new RequestExpectContinue()});