X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-dom-demo%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fsal%2Fdemo%2FSALDemo.java;fp=opendaylight%2Fmd-sal%2Fsal-dom-demo%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fsal%2Fdemo%2FSALDemo.java;h=9e50059972cd96a477f926465c6dc53754a9e578;hb=fe024ad74b8656c3ee61b9ddff6009a779aa2189;hp=0000000000000000000000000000000000000000;hpb=437c1bdb967072319e81774bdcf570b2fb0f7b89;p=controller.git

diff --git a/opendaylight/md-sal/sal-dom-demo/src/main/java/org/opendaylight/controller/sal/demo/SALDemo.java b/opendaylight/md-sal/sal-dom-demo/src/main/java/org/opendaylight/controller/sal/demo/SALDemo.java
new file mode 100644
index 0000000000..9e50059972
--- /dev/null
+++ b/opendaylight/md-sal/sal-dom-demo/src/main/java/org/opendaylight/controller/sal/demo/SALDemo.java
@@ -0,0 +1,159 @@
+/*
+ * Copyright (c) 2013 Cisco Systems, Inc. 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.controller.sal.demo;
+
+import java.io.BufferedReader;
+import java.io.IOException;
+import java.io.InputStreamReader;
+
+import org.opendaylight.controller.sal.core.impl.BrokerImpl;
+import org.opendaylight.controller.sal.core.impl.NotificationModule;
+
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+public class SALDemo {
+    protected static final Logger logger = LoggerFactory
+        .getLogger(SALDemo.class);
+
+    static BrokerImpl broker;
+    static DemoProviderImpl provider;
+    static DemoConsumerImpl consumer1;
+    static DemoConsumerImpl consumer2;
+
+    public static void main(String[] args) {
+
+        initialize();
+        initializeProvider();
+        displayHelp();
+
+        BufferedReader in = new BufferedReader(new InputStreamReader(System.in));
+        String s;
+        try {
+            while (true) {
+
+                System.out.print("\nEnter your choice (0 - list): ");
+                s = in.readLine();
+                int choice = Integer.parseInt(s.trim());
+                try {
+                    switch (choice) {
+                    case 0:
+                        displayHelp();
+                        break;
+                    case 1:
+                        registerProvider();
+                        break;
+                    case 2:
+                        registerConsumer1();
+                        break;
+                    case 3:
+                        registerConsumer2();
+                        break;
+                    case 4:
+                        sendAlert(in);
+                        break;
+                    case 5:
+                        sendChange(in);
+                        break;
+                    case 6:
+                        unregisterConsumer1();
+                        break;
+                    case 7:
+                        unregisterConsumer2();
+                        break;
+                    case 8:
+                        unregisterProvider();
+                        break;
+                    case 9:
+                        return;
+                    default:
+                        System.out.println("Please enter valid input.");
+                        break;
+                    }
+                } catch (Exception e) {
+                    System.out
+                            .println("Operation failed. Reason exception raised: "
+                                    + e.getClass().getSimpleName());
+                    System.out.println("   Message: " + e.getMessage());
+                }
+
+            }
+        } catch (IOException e) {
+
+            logger.error("",e);
+        }
+    }
+
+    private static void registerConsumer1() {
+        broker.registerConsumer(consumer1);
+    }
+
+    private static void registerConsumer2() {
+        broker.registerConsumer(consumer2);
+    }
+
+    private static void sendAlert(BufferedReader in) throws IOException {
+        System.out.print("Please enter notification content:");
+        String content = in.readLine();
+        provider.sendAlertNotification(content);
+    }
+
+    private static void sendChange(BufferedReader in) throws IOException {
+        System.out.print("Please enter notification content:");
+        String content = in.readLine();
+        provider.sendChangeNotification(content);
+    }
+
+    private static void unregisterConsumer1() {
+        consumer1.closeSession();
+    }
+
+    private static void unregisterConsumer2() {
+        consumer2.closeSession();
+    }
+
+    private static void unregisterProvider() {
+        provider.closeSession();
+    }
+
+    private static void displayHelp() {
+        System.out.println("Usage: ");
+        System.out.println("  0) Display Help");
+        System.out.println("  1) Register Provider");
+        System.out.println("  2) Register Consumer 1 (listening on alert)");
+        System.out
+                .println("  3) Register Consumer 2 (listening on alert,change)");
+        System.out.println("  4) Send Alert Notification");
+        System.out.println("  5) Send Change Notification");
+        System.out.println("  6) Unregister Consumer 1");
+        System.out.println("  7) Unregister Consumer 2");
+        System.out.println("  8) Unregister Provider");
+        System.out.println("  9) Exit");
+
+    }
+
+    private static void initializeProvider() {
+        provider = new DemoProviderImpl();
+    }
+
+    private static void initialize() {
+        System.out.println("Initializing broker");
+        broker = new BrokerImpl();
+        NotificationModule notifyModule = new NotificationModule();
+        broker.addModule(notifyModule);
+
+        consumer1 = new DemoConsumerImpl("Consumer 1");
+        consumer2 = new DemoConsumerImpl("Consumer 2");
+        consumer2.setChangeAware(true);
+    }
+
+    private static void registerProvider() {
+        broker.registerProvider(provider);
+    }
+}