ChannelList.java

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

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 ChannelList {
    private static final String SERVER = "localhost:3333";
    
    private String server = SERVER;
     
    Sink sink = null;
    ChannelMap sMap;
    boolean connected = false;
    
    public static void main(String[] args) {
        ChannelList cl = new ChannelList(args);
        cl.exec();
        cl.printChannelList();
    }
    
    private void printUsage() {
        System.out.println("ChannelList: usage is...");     
        System.out.print("ChannelList ");
        System.out.print("[-s server_hostname *" + SERVER + "] ");
        System.out.println();
    }
    
    public ChannelList(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;
            }
        } catch (Exception e) {
            System.err.println("ChannelList argument exception "+e.getMessage());
            e.printStackTrace();
            RBNBProcess.exit(0);
        }
        
        System.out.println("Starting ChannelList on " + server);
        System.out.println("  Use ChannelList -h to see optional parameters");
    }
    
    public ChannelList(String server_host)
    {
        server = server_host;

        System.out.println("Starting ChannelList on " + server);
        System.out.println("  Use ChannelList -h to see optional parameters");
    }
    
    public ChannelList()
    {
        this(SERVER);
    }
    
    public void exec()
    {
        try {
            // Create a sink and connect:
            sink=new Sink();
            sink.OpenRBNBConnection(server,"ChannelListRequest");
            connected = true;
            System.out.println("ChannelList: Connection made to server = "
                + server + " requesting channel list.");
        } catch (SAPIException se) { se.printStackTrace(); }
    }

    private void printChannelList() {
        try {
            sMap = new ChannelMap();
            sink.RequestRegistration();     
            sMap = sink.Fetch(-1,sMap);
            ChannelTree tr = ChannelTree.createFromChannelMap(sMap);
            System.out.println(tr);
        } catch (SAPIException se) { se.printStackTrace(); }
    }

    
}

---