CommandSource.java

/*
 * Created on Mar 5, 2004
 */
package org.nees.rbnb;

import java.io.IOException;
import java.io.InputStreamReader;
import java.io.BufferedReader;

import com.rbnb.sapi.*;
import com.rbnb.utility.ArgHandler; //for argument parsing
import com.rbnb.utility.RBNBProcess; //alternative to System.exit, so
                                       //don't bring down servlet engine
//import COM.Creare.Utility.ArgHandler; //for argument parsing
//import COM.Creare.Utility.RBNBProcess; //alternative to System.exit, so
                                     //don't bring down servlet engine

public class CommandSource {

    private static final String SERVER = "localhost:3333";
    private static final String SOURCE_NAME = "Command";
    private static final String CHANNEL_NAME = "CommandData";
    
    private String server = SERVER;
    private String sourceName = SOURCE_NAME;
    private String channelName = CHANNEL_NAME;
     
    Source source = null;
    ChannelMap sMap;
    int index;
    boolean connected = false;
    
    Thread commandThread;
    boolean runit = false;
    
    public static void main(String[] args) {
        CommandSource w = new CommandSource(args);
        w.exec();
        w.startThread();
    }
    
    private void printUsage() {
        System.out.println("CommandSource: usage is...");       
        System.out.print("CommandSource ");
        System.out.print("[-s server_hostname *" + SERVER + "] ");
        System.out.print("[-n source_name *" + SOURCE_NAME + "] ");
        System.out.print("[-c channel_name *" + CHANNEL_NAME + "] ");
        System.out.println();
    }
    
    public CommandSource(String[] args) {
        //parse args
        try {
            ArgHandler ah=new ArgHandler(args);
            if (ah.checkFlag('h')) {
                printUsage();
                RBNBProcess.exit(0);                
            }
            if (ah.checkFlag('s')) {
                String a=ah.getOption('s');
                if (a!=null) server=a;
            }
            if (ah.checkFlag('n')) {
                String a=ah.getOption('n');
                if (a!=null) sourceName=a;
            }
            if (ah.checkFlag('c')) {
                String a=ah.getOption('c');
                if (a!=null) channelName=a;
            }
        } catch (Exception e) {
            System.err.println("CommandSource argument exception "+e.getMessage());
            e.printStackTrace();
            RBNBProcess.exit(0);
        }
        
        System.out.println("Starting CommandSource on " + server + " as " + sourceName);
        System.out.println("  Channel name = " + channelName);
        System.out.println("  Use CommandSource -h to see optional parameters");
    }
    
    public CommandSource(String server_host, String source_name, 
            String channel_name)
    {
        server = server_host;
        sourceName = source_name;
        channelName = channel_name;

        System.out.println("Starting CommandSource on " + server + " as " + sourceName);
        System.out.println("  Channel name = " + channelName);
        System.out.println("  Use CommandSource -h to see optional parameters");
    }
    
    public CommandSource()
    {
        this(SERVER,SOURCE_NAME,CHANNEL_NAME);
    }
    
    public void exec()
    {
        try {
            // Create a source and connect:
            source=new Source();
            source.OpenRBNBConnection(server,sourceName);
            sMap = new ChannelMap();
            index = sMap.Add(channelName);
            sMap.PutTimeAuto("timeofday");
            connected = true;
            System.out.println("CommandSource: Connection made to server = "
                + server + " as " + sourceName + " with " + channelName + ".");
        } catch (SAPIException se) { se.printStackTrace(); }
    }
    
    public void startThread()
    {
        
        if (!connected) return;
        
        // Use this inner class to hide the public run method
        Runnable r = new Runnable() {
            public void run() {
              runWork();
            }
        };
        runit = true;
        commandThread = new Thread(r, "Command");
        commandThread.start();
        System.out.println("CommandSource: Started thread.");
    }

    public void stopThread()
    {
        runit = false;
        commandThread.interrupt();
        System.out.println("CommandSource: Stopped thread.");
    }
    
    private void runWork ()
    {
        BufferedReader in = new BufferedReader(new InputStreamReader(System.in));
        try {
            while(isRunning())
            {
                // get command
                System.out.println("ENTER COMMAND:");
                String commandString = in.readLine();
                
                System.out.println("Command is: " + commandString);
                
                // send command
                sMap.PutDataAsString(index,commandString);
                
                source.Flush(sMap);
            }
        } catch (SAPIException se) {
            se.printStackTrace(); 
        } catch (IOException e) {
            e.printStackTrace();
        }
        commandThread = null;
    }
    
    public boolean isRunning()
    {
        return (connected && runit);
    }
        
}

---