ovsdb/src/main/java/org/opendaylight/ovsdb/plugin/ChannelConnectionHandler.java

   1 package org.opendaylight.ovsdb.plugin;
   2
   3 import org.opendaylight.controller.sal.core.Node;
   4
   5 import io.netty.channel.ChannelFuture;
   6 import io.netty.channel.ChannelFutureListener;
   7
   8 public class ChannelConnectionHandler implements ChannelFutureListener {
   9     Node node;
  10     ConnectionService connectionService;
  11     public Node getNode() {
  12         return node;
  13     }
  14     public void setNode(Node node) {
  15         this.node = node;
  16     }
  17     public ConnectionService getConnectionService() {
  18         return connectionService;
  19     }
  20     public void setConnectionService(ConnectionService connectionService) {
  21         this.connectionService = connectionService;
  22     }
  23     @Override
  24     public void operationComplete(ChannelFuture arg0) throws Exception {
  25         connectionService.channelClosed(node);
  26     }
  27 }