Package org.jboss.netty.channel

Examples of org.jboss.netty.channel.ChannelHandler

29
30
31
32
33
34
35
36
37
38
39
            return pipeline;
        }      
       
        // Create the play Handler (always the last one)
        String handler = handlers[handlers.length - 1];
        ChannelHandler instance = getInstance(handler);
        PlayHandler playHandler = (PlayHandler) instance;
        if (playHandler == null) {
            Logger.error("The last handler must be the playHandler in \"play.netty.pipeline\"");
            return pipeline;
        }
View Full Code Here
33
34
35
36
37
38
39
40
41
class NettyChannelPipeline {
    private static ChannelHandler getFrameDecoder() {
        /* Frame decoder. Splits stream by \r\n terminated lines */
        ChannelBuffer delimiterBuffer = ChannelBuffers.wrappedBuffer(new byte[] { '\r', '\n' });
        ChannelHandler frameDecoder = new DelimiterBasedFrameDecoder(1024, delimiterBuffer);

        return frameDecoder;
    }
View Full Code Here
86
87
88
89
90
91
92
93
94
95
96
                    "handlers should contain at least one " +
                    ChannelHandler.class.getSimpleName() + '.');
        }

        for (int i = 0; i < handlers.length; i ++) {
            ChannelHandler h = handlers[i];
            if (h == null) {
                throw new NullPointerException("handlers[" + i + "]");
            }
            pipeline.addLast(String.valueOf(i), handlers[i]);
        }
View Full Code Here
263
264
265
266
267
268
269
270
271
272
273
274
        }

        final BlockingQueue<ChannelFuture> futureQueue =
            new LinkedBlockingQueue<ChannelFuture>();

        ChannelHandler binder = new Binder(localAddress, futureQueue);
        ChannelHandler parentHandler = getParentHandler();

        ChannelPipeline bossPipeline = pipeline();
        bossPipeline.addLast("binder", binder);
        if (parentHandler != null) {
            bossPipeline.addLast("userHandler", parentHandler);
View Full Code Here
275
276
277
278
279
280
281
282
283
284
285
286
        final BlockingQueue<ChannelFuture> futureQueue =
            new LinkedBlockingQueue<ChannelFuture>();

        ChannelPipeline bossPipeline;
        ChannelHandler binder = new Binder(localAddress, futureQueue);
        ChannelHandler parentHandler = getParentHandler();

    //如果用户自己指定了一个Handler，则使用DefaultChannelPipeline
    //否则使用StaticChannelPipeline
    DEBUG.P("parentHandler="+parentHandler);
        if (parentHandler != null) {
View Full Code Here
90
91
92
93
94
95
96
97
98
99
100
                    "handlers should contain at least one " +
                    ChannelHandler.class.getSimpleName() + '.');
        }

        for (int i = 0; i < handlers.length; i ++) {
            ChannelHandler h = handlers[i];
            if (h == null) {
                throw new NullPointerException("handlers[" + i + "]");
            }
            pipeline.addLast(String.valueOf(i), handlers[i]);
        }
View Full Code Here
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
        String[] handlers = pipelineConfig.split(",");
        for (int i = 0; i < handlers.length - 1; i++) {
            String handler = handlers[i];
            try {
                String name = getName(handler.trim());
                ChannelHandler instance = getInstance(handler);
                if (instance != null) {
                    pipeline.addLast(name, instance);
                    Server.pipelines.put("Ssl" + name, instance);
                }
            } catch (Throwable e) {
                Logger.error(" error adding " + handler, e);
            }

        }

        // The last one is always the yalp handler
        String handler = handlers[handlers.length - 1];
        ChannelHandler instance = getInstance(handler);
        if (instance != null) {
            pipeline.addLast("handler", instance);
            Server.pipelines.put("SslHandler", instance);
        }
View Full Code Here
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
        String[] handlers = pipelineConfig.split(",");
        for (int i = 0; i < handlers.length - 1; i++) {
            String handler = handlers[i];
            try {
                String name = getName(handler.trim());
                ChannelHandler instance = getInstance(handler);
                if (instance != null) {
                    pipeline.addLast(name, instance);
                    Server.pipelines.put(name, instance);
                }
            } catch (Throwable e) {
                Logger.error(" error adding " + handler, e);
            }

        }

        // The last one is always the yalp handler
        String handler = handlers[handlers.length - 1];
        ChannelHandler instance = getInstance(handler);
        if (instance != null) {
            pipeline.addLast("handler", instance);
            Server.pipelines.put("handler", instance);
        }
View Full Code Here
316
317
318
319
320
321
322
323
324
325
326
    public ChannelFuture bindAsync(final SocketAddress localAddress) {
        if (localAddress == null) {
            throw new NullPointerException("localAddress");
        }
        Binder binder = new Binder(localAddress);
        ChannelHandler parentHandler = getParentHandler();

        ChannelPipeline bossPipeline = pipeline();
        bossPipeline.addLast("binder", binder);
        if (parentHandler != null) {
            bossPipeline.addLast("userHandler", parentHandler);
View Full Code Here
87
88
89
90
91
92
93
94
95
96
97
                    "handlers should contain at least one " +
                    ChannelHandler.class.getSimpleName() + '.');
        }

        for (int i = 0; i < handlers.length; i ++) {
            ChannelHandler h = handlers[i];
            if (h == null) {
                throw new NullPointerException("handlers[" + i + ']');
            }
            pipeline.addLast(String.valueOf(i), handlers[i]);
        }
View Full Code Here
TOP

Related Classes of org.jboss.netty.channel.ChannelHandler

  • com.biasedbit.nettytutorials.handshake.server.Server
  • com.brewtab.irc.impl.NettyChannelPipeline
  • com.linkedin.databus.client.netty.TestGenericHttpResponseHandler
  • org.apache.camel.component.netty.DefaultClientPipelineFactory
  • org.apache.camel.component.netty.DefaultServerPipelineFactory
  • org.apache.camel.component.netty.handlers.ClientChannelHandler
  • org.apache.camel.component.netty.http.HttpClientPipelineFactory
  • org.apache.camel.component.netty.http.HttpServerPipelineFactory
  • org.helios.netty.ajax.ProtocolSwitch
  • org.helios.netty.examples.state.CustomServerBootstrap
    • Copyright © 2018 www.massapicom. All rights reserved.
    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.