BaffaloTech Integration

<dependency>
  <groupId>com.baffalotech</groupId>
  <artifactId>baffalotech-integration-http</artifactId>
  <version>1.0.5</version>
</dependency>

@EnableNettyServerContainer

@Autowired
private NettyHttpServerConnectorFactory nettyHttpServerConnectorFactory;
.....
@Bean
public Connector createNettyHttpConnector()
{
	return nettyHttpServerConnectorFactory.createNettyHttpServerConnector("test",8081);
}

@Bean()
public ServletRegistrationBean cxfServlet() {
	ServletRegistrationBean<Servlet> test = new ServletRegistrationBean(NettyProxyServlet.createNettyProxyServlet("test", new CXFServlet()), "/soap-api/*");
	test.addInitParameter("bus", "testws");
	test.setOrder(1121);
	return test;
}


@Bean
public FilterRegistrationBean tracerFilter(TracingFilter httpTraceFilter) {
	FilterRegistrationBean<Filter> tracerFilterRegistrationBean = new FilterRegistrationBean<Filter>();
	tracerFilterRegistrationBean.setFilter(NettyProxyFilter.createNettyProxyFilter("test", httpTraceFilter));
	tracerFilterRegistrationBean.addUrlPatterns("/*");
	tracerFilterRegistrationBean.setOrder(Ordered.HIGHEST_PRECEDENCE+200);
	return tracerFilterRegistrationBean;
}

 @Bean
    public Connector createTCPConnector()
    {
    	TCPProtocal inTcpProtocal = new TCPProtocal();
    	inTcpProtocal.addField(new FixedLengthField("name",null, 4));
    	inTcpProtocal.addField(new LengthField("length",0, 4));
    	return nettyTCPFixedLengthServerConnectorFactory.create("hbnx", 8082, inTcpProtocal, inTcpProtocal, new TCPRequestHanlder() {
			@Override
			public void handle(TCPRequest tcpRequest, TCPResponse tcpResponse) {
				// TODO Auto-generated method stub
				tcpResponse.setData((new Date()).toString().getBytes());
			}
		});
    }

 @Bean
    public TCPHandler tcpTracingHandler(HttpTracing httpTracing)
    {
    	TCPHandler tcpHandler = TCPTracingHandler.create(httpTracing);
    	tcpHandler.setName("hbnx");
    	return tcpHandler;
    }