View Javadoc

1   /*
2    * Copyright 2012 The Netty Project
3    *
4    * The Netty Project licenses this file to you under the Apache License,
5    * version 2.0 (the "License"); you may not use this file except in compliance
6    * with the License. You may obtain a copy of the License at:
7    *
8    *   http://www.apache.org/licenses/LICENSE-2.0
9    *
10   * Unless required by applicable law or agreed to in writing, software
11   * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
12   * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
13   * License for the specific language governing permissions and limitations
14   * under the License.
15   */
16  package org.jboss.netty.example.securechat;
17  
18  import java.util.logging.Level;
19  import java.util.logging.Logger;
20  
21  import org.jboss.netty.channel.ChannelEvent;
22  import org.jboss.netty.channel.ChannelHandlerContext;
23  import org.jboss.netty.channel.ChannelStateEvent;
24  import org.jboss.netty.channel.ExceptionEvent;
25  import org.jboss.netty.channel.MessageEvent;
26  import org.jboss.netty.channel.SimpleChannelUpstreamHandler;
27  import org.jboss.netty.handler.ssl.SslHandler;
28  
29  /**
30   * Handles a client-side channel.
31   */
32  public class SecureChatClientHandler extends SimpleChannelUpstreamHandler {
33  
34      private static final Logger logger = Logger.getLogger(
35              SecureChatClientHandler.class.getName());
36  
37      @Override
38      public void handleUpstream(
39              ChannelHandlerContext ctx, ChannelEvent e) throws Exception {
40          if (e instanceof ChannelStateEvent) {
41              logger.info(e.toString());
42          }
43          super.handleUpstream(ctx, e);
44      }
45  
46      @Override
47      public void channelConnected(
48              ChannelHandlerContext ctx, ChannelStateEvent e) throws Exception {
49          // Get the SslHandler from the pipeline
50          // which were added in SecureChatPipelineFactory.
51          SslHandler sslHandler = ctx.getPipeline().get(SslHandler.class);
52  
53          // Begin handshake.
54          sslHandler.handshake();
55      }
56  
57      @Override
58      public void messageReceived(
59              ChannelHandlerContext ctx, MessageEvent e) {
60          System.err.println(e.getMessage());
61      }
62  
63      @Override
64      public void exceptionCaught(
65              ChannelHandlerContext ctx, ExceptionEvent e) {
66          logger.log(
67                  Level.WARNING,
68                  "Unexpected exception from downstream.",
69                  e.getCause());
70          e.getChannel().close();
71      }
72  }