@Override
		public void messageReceived(ChannelHandlerContext ctx, MessageEvent e) throws Exception {
			Assert.isInstanceOf(HttpRequest.class, e.getMessage());
			HttpRequest request = (HttpRequest) e.getMessage();
			if (logger.isDebugEnabled()) {
				logger.debug("Received HTTP request:\n" + indent(e.getMessage().toString()));
			}
			HttpResponse response = new DefaultHttpResponse(HTTP_1_1, OK);
			Message<?> message = null;
			try {
				message = this.messageConverter.toMessage(request, null);
			}
			catch (MessageConversionException ex) {
				logger.error("Failed to convert message", ex);
				response = new DefaultHttpResponse(HTTP_1_1, INTERNAL_SERVER_ERROR);
			}
			if (message != null) {
				try {
					if (logger.isDebugEnabled()) {
						logger.debug("Sending message: " + message);
					}
					sendMessage(message);
				}
				catch (Exception ex) {
					logger.error("Error sending message", ex);
					response = new DefaultHttpResponse(HTTP_1_1, INTERNAL_SERVER_ERROR);
				}
			}
			writeResponse(request, response, e.getChannel());
		}
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