X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;ds=sidebyside;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=0000000000000000000000000000000000000000;hb=d6c7e80b4372f994640863af3066039527c8d3e9;hp=9e50059972cd96a477f926465c6dc53754a9e578;hpb=8baeda4ab8d240f847cd530ef6af7c7c1c2d4d13;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 deleted file mode 100644 index 9e50059972..0000000000 --- a/opendaylight/md-sal/sal-dom-demo/src/main/java/org/opendaylight/controller/sal/demo/SALDemo.java +++ /dev/null @@ -1,159 +0,0 @@ -/* - * 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); - } -}