2 * Copyright (c) 2013 Pantheon Technologies s.r.o. and others. All rights reserved.
4 * This program and the accompanying materials are made available under the
5 * terms of the Eclipse Public License v1.0 which accompanies this distribution,
6 * and is available at http://www.eclipse.org/legal/epl-v10.html
9 package org.opendaylight.openflowjava.protocol.impl.core;
11 import io.netty.channel.ChannelHandlerContext;
12 import io.netty.channel.ChannelInboundHandlerAdapter;
14 import org.opendaylight.openflowjava.protocol.impl.connection.ConnectionAdapterImpl;
15 import org.opendaylight.openflowjava.protocol.impl.connection.MessageConsumer;
16 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.system.rev130927.DisconnectEventBuilder;
17 import org.opendaylight.yangtools.yang.binding.DataObject;
18 import org.slf4j.Logger;
19 import org.slf4j.LoggerFactory;
22 * Holds reference to {@link ConnectionAdapterImpl} and passes messages for further processing.
23 * Also informs on switch disconnection.
24 * @author michal.polkorab
26 public class DelegatingInboundHandler extends ChannelInboundHandlerAdapter {
28 private static final Logger LOGGER = LoggerFactory.getLogger(DelegatingInboundHandler.class);
30 protected MessageConsumer consumer;
31 private boolean inactiveMessageSent = false;
34 * Constructs class + creates and sets MessageConsumer
35 * @param connectionAdapter reference for adapter communicating with upper layers outside library
37 public DelegatingInboundHandler(MessageConsumer connectionAdapter) {
38 LOGGER.debug("Creating DelegatingInboundHandler");
39 consumer = connectionAdapter;
43 public void channelRead(ChannelHandlerContext ctx, final Object msg)
45 LOGGER.debug("Reading");
46 consumer.consume((DataObject) msg);
50 public void channelInactive(ChannelHandlerContext ctx) throws Exception {
51 LOGGER.info("Channel inactive");
52 if (!inactiveMessageSent) {
53 DisconnectEventBuilder builder = new DisconnectEventBuilder();
54 builder.setInfo("Channel inactive");
55 consumer.consume(builder.build());
56 inactiveMessageSent = true;
61 public void channelUnregistered(ChannelHandlerContext ctx) throws Exception {
62 LOGGER.info("Channel unregistered");
63 if (!inactiveMessageSent) {
64 DisconnectEventBuilder builder = new DisconnectEventBuilder();
65 builder.setInfo("Channel unregistered");
66 consumer.consume(builder.build());
67 inactiveMessageSent = true;