Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- package net.bounceme.dur.client.netty;
- import io.netty.channel.ChannelHandlerContext;
- import io.netty.channel.ChannelInboundHandlerAdapter;
- import java.util.logging.Logger;
- import net.bounceme.dur.client.jdbc.Title;
- public class ClientHandler extends ChannelInboundHandlerAdapter {
- private static final Logger log = Logger.getLogger(ClientHandler.class.getName());
- public ClientHandler() {
- }
- @Override
- public void channelActive(ChannelHandlerContext ctx) {
- Title title = new Title();
- log.info(title.toString());
- ctx.write(title);
- }
- @Override
- public void channelRead(ChannelHandlerContext ctx, Object msg) {
- try {
- Title t = (Title) msg;
- log.info(msg.toString());
- ctx.write(t);
- } catch (ClassCastException cce) { //????
- log.warning(cce.toString());
- }
- }
- @Override
- public void channelReadComplete(ChannelHandlerContext ctx
- ) {
- ctx.flush();
- }
- @Override
- public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause
- ) {
- log.severe(cause.toString());
- ctx.close();
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment