// --------------------------------------------------------------------------------
//
//   Program name     : MBSgetg5.class
//
//   Description      : Sample Java program that gets group-message from a queue
//
//   (C) Copyright SAISON INFORMATION SYSTEMS CO.,LTD. 2004 All Rights Reserved.
//
// --------------------------------------------------------------------------------
// --------------------------------------------------------------------------------
//
//   Function : 
//
//      "MBSgetg5" is a sample Java program to get group-message from a queue. This
//   program gets a message with "GRP" as UserDefineID from specified queue,
//   and writes this to StdOut. If "get()" method failed before the group-end
//   message is read, all messages after the group-start message are rollbacked.
//
//      This program has the following parameters. If the optional parameters
//   are omitted, the parameters in System-Environment file( mbcenv.properties )
//   will be used.
//
//     required :
//
//     optional :
//        (1) -s Server     : The name of HULFT-Message Server
//        (2) -p Port       : The port of HULFT-Message Server
//        (3) -q Queue      : The name of the queue
//
// --------------------------------------------------------------------------------
import jp.co.saison.sis.hulft.msg.*;

class MBSgetg5 {
    public static void main(String args[]) {
        String usage = "Usage : MBSgetg5 [-s Server -p Port] [-q Queue]";

        // ------------------------------------------------------------------------
        // Check the arguments
        // ------------------------------------------------------------------------
        if (args.length > 6) {
            System.out.println(usage);
            return;
        }
        boolean arg_s = false, arg_p = false, arg_q = false;
        String server = "";     // user define server name
        int    port   = 0;      // user define server port
        String queue  = "";     // user define queue name
        for (int i = 0; i < args.length; i++) {
            if (args[i].equals("-s")) { 
                // server name
                if ((args.length - i) <= 1) {
                    System.out.println(usage);
                    return;
                }
                i++;
                server = args[i];
                arg_s = true;
            } else if (args[i].equals("-p")) {
                // server port
                if ((args.length - i) <= 1) {
                    System.out.println(usage);
                    return;
                }
                i++;
                port = Integer.parseInt(args[i]);
                arg_p = true;
            } else if (args[i].equals("-q")) {
                // queue name
                if ((args.length - i) <= 1) {
                    System.out.println(usage);
                    return;
                }
                i++;
                queue = args[i];
                arg_q = true;
            } else {
                System.out.println(usage);
                return;
            }
        }
        if ((arg_s && !arg_p) || (!arg_s && arg_p)) {
            // server name and server port are mutually required.
            System.out.println(usage);
            return;
        }

        MBServer mbs = null;
        try {
            //---------------------------------------------------------------------
            // Connect to HULFT-Message Server
            //---------------------------------------------------------------------
            if (server.equals("")) {
                // read server name & server port from <mbcenv.properties>.
                mbs = new MBServer();
            } else {
                // specify server name & server port.
                mbs = new MBServer(server, port);
            }
            mbs.connect();

            //---------------------------------------------------------------------
            // Open the queue
            //---------------------------------------------------------------------
            MBQueueRequester mbqrq = null;
            if (queue.equals("")) {
                // read queue name from <mbcenv.properties>.
                mbqrq = new MBQueueRequester();
            } else {
                // specify queue name.
                mbqrq = new MBQueueRequester(queue);
            }
            MBQueueSession mbqs = mbs.openQueue(mbqrq);

            //---------------------------------------------------------------------
            // Get the message from the queue
            //---------------------------------------------------------------------
            MBMessage msg = new MBMessage(mbs);

            do {
                MBStreamMessage stream = new MBStreamMessage();
                MBMessageGetRequester mbgetrq = new MBMessageGetRequester(stream);
                mbgetrq.setUserDefineId("GRP");         // user define ID
                MBMessageGetRequester result = msg.get(mbqs, mbgetrq);

                // Print message body
                byte[] message = new byte[(int)result.getMessageSize()];
                stream.read(message);
                System.out.println(">> " + new String(message));

                // Get group-type
                String group = result.getGroupType();

                // Read group-messages until GROUP_END messaage appears
                if (group.equals(MBMessageRequester.GROUPTYPE_GROUP_END)) {
                    break;
                }
            } while (true);

            //---------------------------------------------------------------------
            // Close the queue
            //---------------------------------------------------------------------
            mbs.closeQueue(mbqs);

            System.out.println("Normal termination");

        } catch (MBException e) {
            System.out.println("HULFT-Message error occured.");
            System.out.println("Exception class : " + e.getClass());
            System.out.println("Error Code      : " + e.getErrorCode());
            System.out.println("Detail Code     : " + e.getDetailCode());
            System.out.println("System Code     : " + e.getSystemCode());
            System.out.println("Error Message   : " + e.getDetailMessage());
            e.printStackTrace();
        } catch (Exception e) {
            System.out.println("Exception class   : " + e.getClass());
            System.out.println("Exception message : " + e.getMessage());
            e.printStackTrace();
        } finally {
            //---------------------------------------------------------------------
            // Disconnect from HULFT-Message Server if already connected.
            //---------------------------------------------------------------------
            if (mbs != null) {
                if (mbs.isSession()) {
                    try {
                        mbs.disconnect();
                    } catch (Exception e) {
                        e.printStackTrace();
                    }
                }
            }
        }
    }
}