UDP support implementation

[openflowjava.git] / simple-client / src / main / java / org / opendaylight / openflowjava / protocol / impl / clients / UdpSimpleClientInitializer.java

diff --git a/simple-client/src/main/java/org/opendaylight/openflowjava/protocol/impl/clients/UdpSimpleClientInitializer.java b/simple-client/src/main/java/org/opendaylight/openflowjava/protocol/impl/clients/UdpSimpleClientInitializer.java
new file mode 100644 (file)
index 0000000..cd7a8a8
--- /dev/null
+++ b/simple-client/src/main/java/org/opendaylight/openflowjava/protocol/impl/clients/UdpSimpleClientInitializer.java
@@ -0,0 +1,50 @@
+/*
+ * Copyright (c) 2014 Pantheon Technologies s.r.o. and others. All rights reserved.
+ *
+ * This program and the accompanying materials are made available under the
+ * terms of the Eclipse Public License v1.0 which accompanies this distribution,
+ * and is available at http://www.eclipse.org/legal/epl-v10.html
+ */
+
+
+package org.opendaylight.openflowjava.protocol.impl.clients;
+
+import io.netty.channel.ChannelInitializer;
+import io.netty.channel.ChannelPipeline;
+import io.netty.channel.socket.nio.NioDatagramChannel;
+
+import com.google.common.util.concurrent.SettableFuture;
+
+/** Initializes udp pipeline
+ * 
+ * @author michal.polkorab
+ */
+public class UdpSimpleClientInitializer extends ChannelInitializer<NioDatagramChannel> {
+    
+    private SettableFuture<Boolean> isOnlineFuture;
+    private ScenarioHandler scenarioHandler;
+
+    /**
+     * @param isOnlineFuture future notifier of connected channel
+     */
+    public UdpSimpleClientInitializer(SettableFuture<Boolean> isOnlineFuture) {
+        this.isOnlineFuture = isOnlineFuture;
+    }
+
+    @Override
+    public void initChannel(NioDatagramChannel ch) throws Exception {
+        ChannelPipeline pipeline = ch.pipeline();
+        SimpleClientHandler simpleClientHandler = new SimpleClientHandler(isOnlineFuture, scenarioHandler);
+        simpleClientHandler.setScenario(scenarioHandler);
+        pipeline.addLast("framer", new UdpSimpleClientFramer());
+        pipeline.addLast("handler", simpleClientHandler);
+        isOnlineFuture = null;
+    }
+
+    /**
+     * @param scenarioHandler handler of scenario events
+     */
+    public void setScenario(ScenarioHandler scenarioHandler) {
+        this.scenarioHandler = scenarioHandler;
+    }
+}
\ No newline at end of file