Examples of ChannelHandlerContext

com.facebook.presto.jdbc.internal.netty.channel.ChannelHandlerContext
handler will receive a sequence of increasing integers starting // from 1. {@code @Override}public void messageReceived( {@link ChannelHandlerContext} ctx, {@link MessageEvent} evt) {Integer a = (Integer) ctx.getAttachment(); Integer b = (Integer) evt.getMessage(); if (a == null) { a = 1; } ctx.setAttachment(Integer.valueOf(a * b)); } } // Different context objects are given to "f1", "f2", "f3", and "f4" even if // they refer to the same handler instance. Because the FactorialHandler // stores its state in a context object (as an attachment), the factorial is // calculated correctly 4 times once the two pipelines (p1 and p2) are active. FactorialHandler fh = new FactorialHandler(); {@link ChannelPipeline} p1 = {@link Channels}.pipeline(); p1.addLast("f1", fh); p1.addLast("f2", fh); {@link ChannelPipeline} p2 = {@link Channels}.pipeline(); p2.addLast("f3", fh); p2.addLast("f4", fh);
Additional resources worth reading

Please refer to the {@link ChannelHandler}, {@link ChannelEvent}, and {@link ChannelPipeline} to find out what a upstream event and a downstreamevent are, what fundamental differences they have, how they flow in a pipeline, and how to handle the event in your application. @apiviz.owns com.facebook.presto.jdbc.internal.netty.channel.ChannelHandler
io.netty.channel.ChannelHandlerContext
handler will receive a sequence of increasing integers starting // from 1. {@code @Override}public void messageReceived( {@link ChannelHandlerContext} ctx, {@link Integer} integer) {{@link Attribute}< {@link Integer}> attr = ctx.getAttr(counter); Integer a = ctx.getAttr(counter).get(); if (a == null) { a = 1; } attr.set(a * integer)); } } // Different context objects are given to "f1", "f2", "f3", and "f4" even if // they refer to the same handler instance. Because the FactorialHandler // stores its state in a context object (as an attachment), the factorial is // calculated correctly 4 times once the two pipelines (p1 and p2) are active. FactorialHandler fh = new FactorialHandler(); {@link ChannelPipeline} p1 = {@link Channels}.pipeline(); p1.addLast("f1", fh); p1.addLast("f2", fh); {@link ChannelPipeline} p2 = {@link Channels}.pipeline(); p2.addLast("f3", fh); p2.addLast("f4", fh);
Additional resources worth reading

Please refer to the {@link ChannelHandler}, and {@link ChannelPipeline} to find out more about inbound and outbound operations,what fundamental differences they have, how they flow in a pipeline, and how to handle the operation in your application.
net.gleamynode.netty.channel.ChannelHandlerContext
@author The Netty Project (netty@googlegroups.com) @author Trustin Lee (trustin@gmail.com) @version $Rev: 479 $, $Date: 2008-07-04 16:04:47 +0900 (Fri, 04 Jul 2008) $ @apiviz.hidden @apiviz.owns net.gleamynode.netty.channel.ChannelHandler
org.jboss.netty.channel.ChannelHandlerContext
Provides the properties and operations which are specific to the {@link ChannelHandler} and the {@link ChannelPipeline} it belongs to.Via a {@link ChannelHandlerContext}, a {@link ChannelHandler} can sendan upstream or downstream {@link ChannelEvent} to the next or previous{@link ChannelHandler} in the {@link ChannelPipeline}.
```
 +---------+ 1 .. 1 +----------------+ 1 .. n +----------+ 1 .. 1 +---------+ | Handler |------->| HandlerContext |------->| Pipeline |------->| Channel | +---------+        +----------------+        +----------+        +---------+ 
```
@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) $ @apiviz.owns org.jboss.netty.channel.ChannelHandler

Examples of io.netty.channel.ChannelHandlerContext

            return;
        }
        eventsSubject.onEvent(WebSocketClientMetricsEvent.HANDSHAKE_SUCCESS, Clock.onEndMillis(handshakeStartTime));


        ChannelPipeline p = ctx.pipeline();
        ChannelHandlerContext nettyDecoderCtx = p.context(WebSocketFrameDecoder.class);
        p.addAfter(nettyDecoderCtx.name(), "websocket-read-metrics", new ClientReadMetricsHandler(eventsSubject));
        ChannelHandlerContext nettyEncoderCtx = p.context(WebSocketFrameEncoder.class);
        p.addAfter(nettyEncoderCtx.name(), "websocket-write-metrics", new ClientWriteMetricsHandler(eventsSubject));
        if (messageAggregation) {
            p.addAfter("websocket-read-metrics", "websocket-frame-aggregator", new WebSocketFrameAggregator(maxFramePayloadLength));
        }
        p.remove(HttpObjectAggregator.class);
        p.remove(this);

View Full Code Here

Examples of net.gleamynode.netty.channel.ChannelHandlerContext

                handshakeFuture = this.handshakeFuture = future(channel);
                handshaking = true;
            }
        }


        ChannelHandlerContext ctx = context(channel);
        engine.beginHandshake();
        wrapNonAppData(ctx, channel);
        return handshakeFuture;
    }

View Full Code Here

Examples of net.gleamynode.netty.channel.ChannelHandlerContext

        wrapNonAppData(ctx, channel);
        return handshakeFuture;
    }


    public ChannelFuture close(Channel channel) throws SSLException {
        ChannelHandlerContext ctx = context(channel);
        engine.closeOutbound();
        return wrapNonAppData(ctx, channel);
    }

View Full Code Here

Examples of org.jboss.netty.channel.ChannelHandlerContext

   * 
   * @return the session
   */
  public static Session getSession(ChannelHandlerContext ctx)
  {
    ChannelHandlerContext handler = ctx.getPipeline().getContext(ServerSessionFilter.class);
    if (handler == null)
      return null;
    return (Session) handler.getAttachment();
  }

View Full Code Here

Examples of org.jboss.netty.channel.ChannelHandlerContext

    /**
     * Sends an SSL {@code close_notify} message to the specified channel and
     * destroys the underlying {@link SSLEngine}.
     */
    public ChannelFuture close(Channel channel) throws SSLException {
        ChannelHandlerContext ctx = context(channel);
        engine.closeOutbound();
        return wrapNonAppData(ctx, channel);
    }

View Full Code Here

Examples of org.jboss.netty.channel.ChannelHandlerContext

            long channelCounter = getChannelCounter(channel).addAndGet(increment);
            //System.out.println("IC: " + channelCounter + ", " + increment);
            if (maxChannelMemorySize != 0 && channelCounter >= maxChannelMemorySize && channel.isOpen()) {
                if (channel.isReadable()) {
                    //System.out.println("UNREADABLE");
                    ChannelHandlerContext ctx = eventTask.getContext();
                    if (ctx.getHandler() instanceof ExecutionHandler) {
                        // readSuspended = true;
                        ctx.setAttachment(Boolean.TRUE);
                    }
                    channel.setReadable(false);
                }
            }
        } else {

View Full Code Here

Examples of org.jboss.netty.channel.ChannelHandlerContext

            long channelCounter = getChannelCounter(channel).addAndGet(-increment);
            //System.out.println("DC: " + channelCounter + ", " + increment);
            if (maxChannelMemorySize != 0 && channelCounter < maxChannelMemorySize && channel.isOpen()) {
                if (!channel.isReadable()) {
                    //System.out.println("READABLE");
                    ChannelHandlerContext ctx = eventTask.getContext();
                    if (ctx.getHandler() instanceof ExecutionHandler) {
                        // readSuspended = false;
                        ctx.setAttachment(null);
                    }
                    channel.setReadable(true);
                }
            }
        }

View Full Code Here

Examples of org.jboss.netty.channel.ChannelHandlerContext

    /**
     * Sends an SSL {@code close_notify} message to the specified channel and
     * destroys the underlying {@link SSLEngine}.
     */
    public ChannelFuture close(Channel channel) throws SSLException {
        ChannelHandlerContext ctx = context(channel);
        engine.closeOutbound();
        return wrapNonAppData(ctx, channel);
    }

View Full Code Here

Examples of org.jboss.netty.channel.ChannelHandlerContext

                handshakeFuture = this.handshakeFuture = newHandshakeFuture(channel);
                handshaking = true;
            }
        }


        ChannelHandlerContext ctx = context(channel);
        engine.beginHandshake();
        wrapNonAppData(ctx, channel);
        return handshakeFuture;
    }

View Full Code Here

Examples of org.jboss.netty.channel.ChannelHandlerContext

    /**
     * Sends an SSL {@code close_notify} message to the specified channel and
     * destroys the underlying {@link SSLEngine}.
     */
    public ChannelFuture close(Channel channel) throws SSLException {
        ChannelHandlerContext ctx = context(channel);
        engine.closeOutbound();
        return wrapNonAppData(ctx, channel);
    }

View Full Code Here

0 1 2 3 4 5

TOP

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.

Examples of ChannelHandlerContext

Additional resources worth reading

Additional resources worth reading

Examples of io.netty.channel.ChannelHandlerContext

Examples of net.gleamynode.netty.channel.ChannelHandlerContext

Examples of net.gleamynode.netty.channel.ChannelHandlerContext

Examples of org.jboss.netty.channel.ChannelHandlerContext

Examples of org.jboss.netty.channel.ChannelHandlerContext

Examples of org.jboss.netty.channel.ChannelHandlerContext

Examples of org.jboss.netty.channel.ChannelHandlerContext

Examples of org.jboss.netty.channel.ChannelHandlerContext

Examples of org.jboss.netty.channel.ChannelHandlerContext

Examples of org.jboss.netty.channel.ChannelHandlerContext