@Override
		public ChannelPipeline getPipeline() throws Exception {
			ChannelPipeline pipeline = new DefaultChannelPipeline();
			if (NettyHttpInboundChannelAdapter.this.ssl) {
				SSLEngine engine = sslContext.createSSLEngine();
				engine.setUseClientMode(false);
				pipeline.addLast("ssl", new SslHandler(engine));
			}
			LoggingHandler loggingHandler = new LoggingHandler();
			if (loggingHandler.getLogger().isDebugEnabled()) {
				pipeline.addLast("logger", loggingHandler);
			}
			pipeline.addLast("decoder", new HttpRequestDecoder());
			pipeline.addLast("aggregator", new HttpChunkAggregator(maxContentLength));
			pipeline.addLast("errorHandler", new SimpleChannelHandler() {

				@Override
				public void exceptionCaught(ChannelHandlerContext ctx, ExceptionEvent e)
						throws Exception {
					if (e.getCause() instanceof TooLongFrameException) {
						HttpResponse err = new DefaultHttpResponse(HTTP_1_1,
								REQUEST_ENTITY_TOO_LARGE);
						e.getChannel().write(err).addListener(ChannelFutureListener.CLOSE);
					}
				}
			});
			pipeline.addLast("encoder", new HttpResponseEncoder());
			pipeline.addLast("compressor", new HttpContentCompressor() {

				/*
				 * Required because the content compressor rejects a reply when no request
				 * has yet been processed. Even through the exception is caused further down
				 * the pipleline, writes go through all handlers.
				 */
				@Override
				public void writeRequested(ChannelHandlerContext ctx, MessageEvent e) throws Exception {
					Object msg = e.getMessage();
					if (msg instanceof HttpResponse
							&& ((HttpResponse) e.getMessage()).getStatus().equals(REQUEST_ENTITY_TOO_LARGE)) {
						ctx.sendDownstream(e);
					}
					else {
						super.writeRequested(ctx, e);
					}
				}

			});
			pipeline.addLast("executionHandler", executionHandler);
			pipeline.addLast("handler", new Handler(messageConverter));
			return pipeline;
		}
Set the max content length; default 1Mb.
@param maxContentLength the max content length.
extensions/spring-xd-extension-http/src/main/java/org/springframework/integration/x/http/NettyHttpInboundChannelAdapter.java