Examples of org.jboss.netty.channel.DefaultChannelPipeline$DiscardingChannelSink

org.jboss.netty.channel.DefaultChannelPipeline
The default {@link ChannelPipeline} implementation. It is recommendedto use {@link Channels#pipeline()} to create a new {@link ChannelPipeline}instance rather than calling the constructor directly. @author The Netty Project (netty-dev@lists.jboss.org) @author Trustin Lee (tlee@redhat.com) @version $Rev: 1010 $, $Date: 2009-03-11 19:53:52 +0900 (Wed, 11 Mar 2009) $

             * Other protocols can use a faster static channel pipeline directly.
             */
            ChannelPipeline pipeline;
            if (protocol == ProtocolType.STOMP_WS)
            {
               pipeline = new DefaultChannelPipeline();
               for (Entry<String, ChannelHandler> handler : handlers.entrySet())
               {
                  pipeline.addLast(handler.getKey(), handler.getValue());
               }
            }

View Full Code Here

            ChannelSink sink, ClientSocketChannelFactory clientSocketChannelFactory) {


        super(null, factory, pipeline, sink);


        config = new HttpTunnelingSocketChannelConfig(this);
        DefaultChannelPipeline channelPipeline = new DefaultChannelPipeline();
        channelPipeline.addLast("decoder", new HttpResponseDecoder());
        channelPipeline.addLast("encoder", new HttpRequestEncoder());
        channelPipeline.addLast("handler", handler);
        realChannel = clientSocketChannelFactory.newChannel(channelPipeline);


        fireChannelOpen(this);
    }

View Full Code Here

          * 
          * @see WebSocketServerHandler#handleHttpRequest(ChannelHandlerContext, org.jboss.netty.handler.codec.http.HttpRequest)
          */
         public ChannelPipeline getPipeline() throws Exception
         {
            ChannelPipeline pipeline = new DefaultChannelPipeline();


            if (sslEnabled)
            {
               SSLEngine engine = context.createSSLEngine();


               engine.setUseClientMode(false);


               SslHandler handler = new SslHandler(engine);


               pipeline.addLast("ssl", handler);
            }


            if (httpEnabled)
            {
               pipeline.addLast("http-decoder", new HttpRequestDecoder());


               pipeline.addLast("http-encoder", new HttpResponseEncoder());


               pipeline.addLast("http-handler", new HttpAcceptorHandler(httpKeepAliveRunnable, httpResponseTime));
            }


            if (protocol == ProtocolType.CORE)
            {
               // Core protocol uses it's own optimised decoder
               pipeline.addLast("hornetq-decoder", new HornetQFrameDecoder2());
            }
            else if (protocol == ProtocolType.STOMP_WS)
            {
               pipeline.addLast("http-decoder", new HttpRequestDecoder());
               pipeline.addLast("http-aggregator", new HttpChunkAggregator(65536));
               pipeline.addLast("http-encoder", new HttpResponseEncoder());
               pipeline.addLast("hornetq-decoder", new HornetQFrameDecoder(decoder));
               pipeline.addLast("websocket-handler", new WebSocketServerHandler());
            }
            else
            {
               pipeline.addLast("hornetq-decoder", new HornetQFrameDecoder(decoder));
            }


            pipeline.addLast("handler", new HornetQServerChannelHandler(channelGroup, handler, new Listener()));


            return pipeline;
         }
      };
      bootstrap.setPipelineFactory(factory);

View Full Code Here

             * Other protocols can use a faster static channel pipeline directly.
             */
            ChannelPipeline pipeline;
            if (protocol == ProtocolType.STOMP_WS)
            {
               pipeline = new DefaultChannelPipeline();
               for (Entry<String, ChannelHandler> handler : handlers.entrySet())
               {
                  pipeline.addLast(handler.getKey(), handler.getValue());
               }
            }

View Full Code Here

             * Other protocols can use a faster static channel pipeline directly.
             */
            ChannelPipeline pipeline;
            if (protocol == ProtocolType.STOMP_WS)
            {
               pipeline = new DefaultChannelPipeline();
               for (Entry<String, ChannelHandler> handler : handlers.entrySet())
               {
                  pipeline.addLast(handler.getKey(), handler.getValue());
               }
            }

View Full Code Here

             * Other protocols can use a faster static channel pipeline directly.
             */
            ChannelPipeline pipeline;
            if (protocol == ProtocolType.STOMP_WS)
            {
               pipeline = new DefaultChannelPipeline();
               for (Entry<String, ChannelHandler> handler : handlers.entrySet())
               {
                  pipeline.addLast(handler.getKey(), handler.getValue());
               }
            }

View Full Code Here

             * Other protocols can use a faster static channel pipeline directly.
             */
            ChannelPipeline pipeline;
            if (protocol == ProtocolType.STOMP_WS)
            {
               pipeline = new DefaultChannelPipeline();
               for (Entry<String, ChannelHandler> handler : handlers.entrySet())
               {
                  pipeline.addLast(handler.getKey(), handler.getValue());
               }
            }

View Full Code Here

             * Other protocols can use a faster static channel pipeline directly.
             */
            ChannelPipeline pipeline;
            if (protocol == ProtocolType.STOMP_WS)
            {
               pipeline = new DefaultChannelPipeline();
               for (Entry<String, ChannelHandler> handler : handlers.entrySet())
               {
                  pipeline.addLast(handler.getKey(), handler.getValue());
               }
            }

View Full Code Here

            ChannelSink sink, ClientSocketChannelFactory clientSocketChannelFactory) {


        super(null, factory, pipeline, sink);
        this.clientSocketChannelFactory = clientSocketChannelFactory;


        DefaultChannelPipeline channelPipeline = new DefaultChannelPipeline();
        channelPipeline.addLast("DelimiterBasedFrameDecoder", handler);
        channelPipeline.addLast("servletHandler", servletHandler);
        channel = clientSocketChannelFactory.newChannel(channelPipeline);


        fireChannelOpen(this);
    }

View Full Code Here


    void connectAndSendHeaders(boolean reconnect, HttpTunnelAddress remoteAddress) {
        this.remoteAddress = remoteAddress;
        URI url = remoteAddress.getUri();
        if (reconnect) {
            DefaultChannelPipeline channelPipeline = new DefaultChannelPipeline();
            channelPipeline.addLast("DelimiterBasedFrameDecoder", handler);
            channelPipeline.addLast("servletHandler", servletHandler);
            channel = clientSocketChannelFactory.newChannel(channelPipeline);
        }
        SocketAddress connectAddress = new InetSocketAddress(url.getHost(), url.getPort());
        channel.connect(connectAddress);
        StringBuilder builder = new StringBuilder();

View Full Code Here

0 1 2 3 4 5

TOP

Related Classes of org.jboss.netty.channel.DefaultChannelPipeline$DiscardingChannelSink

asia.stampy.common.netty.AbstractStampyNettyMessageGateway

com.linkedin.databus.client.netty.TestClientChannelClose$FakeRelay$HttpServerPipelineFactory

com.linkedin.databus2.relay.TestDatabusRelayMain$HttpClientPipelineFactory

net.opentsdb.tsd.NettyMocks

org.hornetq.core.remoting.impl.netty.NettyAcceptor

org.infinispan.client.hotrod.impl.transport.netty.HotrodClientPipelaneFactory

org.infinispan.client.hotrod.impl.transport.netty.HotRodClientPipelaneFactory

org.jboss.netty.channel.ChannelPipelineCoverage

org.jboss.netty.channel.socket.http.HttpTunnelingClientSocketChannel

org.springframework.integration.x.http.NettyHttpInboundChannelAdapter$PipelineFactory

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.