// --------------------------------------------------------------------------------
//
//   Program name     : MBSgett5.class
//
//   Description      : Sample Java program that gets message from a queue
//                      in the transaction mode
//
//   (C) Copyright SAISON INFORMATION SYSTEMS CO.,LTD. 2004 All Rights Reserved.
//
// --------------------------------------------------------------------------------
// --------------------------------------------------------------------------------
//
//   Function : 
//
//      "MBSgett5" is a sample Java program to get message from a queue in the
//   transaction mode. This program gets a message with "TRANS" as UserDefineID
//   from specified queue, and writes this to StdOut. 
//
//      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 MBSgett5 {
    public static void main(String args[]) {
        String usage = "Usage : MBSgett5 [-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);

            MBStreamMessage stream = new MBStreamMessage();
            MBMessageGetRequester mbgetrq = new MBMessageGetRequester(stream);
            mbgetrq.setUserDefineId("TRANS");           // user define ID
            // Transaction mode
            mbgetrq.setTransactionMode(MBMessageRequester.TRANSACTION_TRANS);

            // Start of transaction
            boolean inTransaction = true;
            try {
                do {
                    stream = new MBStreamMessage();
                    mbgetrq.setStreamMessage(stream);
                    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));

                } while (true);
            } catch (MBNotFoundException e) {
                // No message available: end of transaction
                inTransaction = false;
            } catch (MBException e) {
                // HULFT-Message Server error occured.
                System.out.println("HULFT-Message error occured.");
            } catch (Exception e) {
                e.printStackTrace();
            }
            // End of transaction

            if (inTransaction) {
                //-----------------------------------------------------------------
                // Rollback messages when error ocuured in transaction
                //-----------------------------------------------------------------
                mbqs.rollback();
            } else {
                //-----------------------------------------------------------------
                // Commit messages
                //-----------------------------------------------------------------
                mbqs.commit();
            }

            //---------------------------------------------------------------------
            // 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();
                    }
                }
            }
        }
    }
}