30
30
import com.eucalyptus.ws.client.NioBootstrap;
31
31
import com.eucalyptus.ws.handlers.ChannelStateMonitor;
32
32
import com.eucalyptus.ws.handlers.http.NioHttpDecoder;
33
34
import com.eucalyptus.ws.server.NioServerHandler;
35
36
public class ChannelUtil {
36
37
static class NioServerPipelineFactory implements ChannelPipelineFactory {
37
38
public ChannelPipeline getPipeline( ) throws Exception {
38
39
final ChannelPipeline pipeline = Channels.pipeline( );
42
41
ChannelUtil.addPipelineMonitors( pipeline );
43
42
pipeline.addLast( "decoder", new NioHttpDecoder( ) );
44
43
pipeline.addLast( "encoder", new HttpResponseEncoder( ) );