Package org.jboss.netty.channel

Examples of org.jboss.netty.channel.SimpleChannelUpstreamHandler

74
75
76
77
78
79
80
81
82
83
84
      public ChannelPipeline getPipeline() throws Exception {
        return Channels.pipeline(
            new ExecutionHandler(executor),
            new ZMTP20Codec(new ZMTPSession(ZMTPConnectionType.Addressed, 1024, identity.getBytes(),
                                            ZMTPSocketType.REQ), false),
            new SimpleChannelUpstreamHandler() {

              @Override
              public void channelConnected(final ChannelHandlerContext ctx,
                                           final ChannelStateEvent e) throws Exception {
                super.channelConnected(ctx, e);
View Full Code Here
48
49
50
51
52
53
54
          }

          @Override
          public void onMsg(Map<String, String> msg) {
          }},
            new SimpleChannelUpstreamHandler());
    }
View Full Code Here
56
57
58
59
60
61
62
          }

          @Override
          public void onMsg(Map<String, String> msg) {
          }},
          new SimpleChannelUpstreamHandler());
    }
View Full Code Here
108
109
110
111
112
113
114
115
116
117
118
    /**
     * Send the WebSocketFrame and call the FrameListener once a frame was received as response or
     * when an Exception was caught.
     */
    public WebSocketTestClient send(WebSocketFrame frame, final FrameListener listener) {
        ch.getPipeline().addLast("responseHandler" + count.incrementAndGet(), new SimpleChannelUpstreamHandler() {
            @Override
            public void messageReceived(ChannelHandlerContext ctx, MessageEvent e) throws Exception {
                if (e.getMessage() instanceof CloseWebSocketFrame) {
                    closed = true;
                }
View Full Code Here
55
56
57
58
59
60
61
62
63
64
65
        DatagramChannel cc = null;
        try {
            MulticastTestHandler mhandler = new MulticastTestHandler();

            cb.getPipeline().addFirst("handler", mhandler);
            sb.getPipeline().addFirst("handler", new SimpleChannelUpstreamHandler());

            int port = TestUtil.getFreePort();

            NetworkInterface loopbackIf;
            try {
View Full Code Here
83
84
85
86
87
88
89
90
91
92
93
        sb.setPipelineFactory(new ChannelPipelineFactory() {
            public ChannelPipeline getPipeline() throws Exception {
                ChannelPipeline cp = Channels.pipeline();

                cp.addFirst("counter", new SimpleChannelUpstreamHandler() {
                    @Override
                    public void channelConnected(ChannelHandlerContext ctx, ChannelStateEvent e) throws Exception {
                        ctx.getPipeline().get(SslHandler.class).handshake().addListener(new ChannelFutureListener() {
                            public void operationComplete(ChannelFuture future) throws Exception {
                                if (!future.isSuccess()) {
View Full Code Here
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
                newServerSocketChannelFactory(Executors.newCachedThreadPool()));
        ConnectionlessBootstrap cb = new ConnectionlessBootstrap(
                newClientSocketChannelFactory(Executors.newCachedThreadPool()));

        final CountDownLatch latch = new CountDownLatch(1);
        sb.getPipeline().addFirst("handler", new SimpleChannelUpstreamHandler() {

            @Override
            public void messageReceived(ChannelHandlerContext ctx, MessageEvent e) throws Exception {
                super.messageReceived(ctx, e);
                assertEquals(1, ((ChannelBuffer) e.getMessage()).readInt());

                latch.countDown();
            }

        });
        cb.getPipeline().addFirst("handler", new SimpleChannelUpstreamHandler());

        Channel sc = sb.bind(new InetSocketAddress("127.0.0.1",0));

        Channel cc = cb.bind(new InetSocketAddress("127.0.0.1", 0));
        ChannelBuffer buf = ChannelBuffers.dynamicBuffer();
View Full Code Here
45
46
47
48
49
50
51
52
53
54
55
        SSLEngine sse = SecureChatSslContextFactory.getServerContext().createSSLEngine();
        sse.setUseClientMode(false);

        sb.getPipeline().addFirst("ssl", new SslHandler(sse));
        sb.getPipeline().addLast("handler", new SimpleChannelUpstreamHandler() {

            @Override
            public void exceptionCaught(ChannelHandlerContext ctx, ExceptionEvent e) throws Exception {
                e.getCause().printStackTrace();
                System.out.println("Close channel");
View Full Code Here
221
222
223
224
225
226
227
228
229
230
231
                                                                      workerExecutor, workerThreadPoolSize));
    bootstrap.setOptions(channelConfigs);

    resourceHandler.init(handlerContext);

    final ChannelUpstreamHandler connectionTracker = new SimpleChannelUpstreamHandler() {
      @Override
      public void handleUpstream(ChannelHandlerContext ctx, ChannelEvent e) throws Exception {
        channelGroup.add(e.getChannel());
        super.handleUpstream(ctx, e);
      }
View Full Code Here
62
63
64
65
66
67
68
69
70
71
72
            pipeline.addLast("executor", new ExecutionHandler(executor));
        pipeline.addLast("logging", new LoggingHandler(logger));
        // a node resolver must be added before the mesage codec
        pipeline.addLast("messageCodec", new MessageCodec());
        pipeline.addLast("nodeResolver", nodeResolver);
        pipeline.addLast("common", new SimpleChannelUpstreamHandler() {

            @Override
            public void channelConnected(ChannelHandlerContext ctx, ChannelStateEvent e) throws Exception {
                if (channelGroup != null)
                    channelGroup.add(e.getChannel());
View Full Code Here
TOP

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

  • asia.stampy.examples.system.server.netty.SystemNettyServerInitializer
  • asia.stampy.server.netty.connect.NettyConnectStateListener
  • asia.stampy.server.netty.login.NettyLoginMessageListener
  • asia.stampy.server.netty.subscription.NettyAcknowledgementListenerAndInterceptor
  • asia.stampy.server.netty.transaction.NettyTransactionListener
  • co.cask.cdap.gateway.router.NettyRouter
  • co.cask.cdap.internal.app.runtime.procedure.ProcedurePipelineFactory
  • co.cask.http.NettyHttpService
  • co.paralleluniverse.galaxy.netty.AbstractTcpClient
  • co.paralleluniverse.galaxy.netty.TcpMessagePipelineFactory
    • 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.