package com.wcsadmin.utilities.mq;

import com.ibm.mq.*;
import java.io.*;

public class PutMessage
{
    private String qManager;
    private String qName;
    private String qmessageFile;

    public PutMessage()
    {
        qManager = "";
        qName = "";
        qmessageFile = "";
    }

    public static void main(String args[])
    {
        PutMessage pM = new PutMessage();
        pM.qManager = args[0];
        pM.qName = args[1];
        pM.qmessageFile = args[2];
        pM.runNow();
    }

    public void runNow()
    {
        try
        {
            System.out.println("Connecting to queue manager: " + qManager);
            MQQueueManager qMgr = new MQQueueManager(qManager);
            int openOptions = 17;
            System.out.println("Accessing queue: " + qName);
            MQQueue queue = qMgr.accessQueue(qName, openOptions);
            File file = new File(qmessageFile);
            String qmessage = getContents(file);
            MQMessage msg = new MQMessage();
            msg.writeString(qmessage);
            MQPutMessageOptions pmo = new MQPutMessageOptions();
            System.out.println("Sending message: " + qmessage);
            queue.put(msg, pmo);
            System.out.println("Closing the queue");
            queue.close();
            System.out.println("Disconnecting from the Queue Manager");
            qMgr.disconnect();
            System.out.println("Done!");
        }
        catch(MQException ex)
        {
            System.out.println("A WebSphere MQ Error occured : Completion Code " + ex.completionCode + " Reason Code " + ex.reasonCode);
        }
        catch(IOException ex)
        {
            System.out.println("An IOException occured whilst writing to the message buffer: " + ex);
        }
    }

    private String getContents(File aFile)
    {
        StringBuffer contents;
        contents = new StringBuffer();
        BufferedReader input = null;
        try
        {
            input = new BufferedReader(new FileReader(aFile));
            for(String line = null; (line = input.readLine()) != null;)
            {
                contents.append(line);
                contents.append(System.getProperty("line.separator"));
            }

        }
        catch(FileNotFoundException ex)
        {
            ex.printStackTrace();
        }
        catch(IOException ex)
        {
            ex.printStackTrace();
        }
        finally
        {
            try
            {
                if(input != null)
                    input.close();
            }
            catch(IOException ex)
            {
                ex.printStackTrace();
            }
        }
        return contents.toString();
    }

}