utils/mq/MqFilesSender.java

package com.traiana.utils.mq;

import com.ibm.mq.MQException;
import java.io.ByteArrayOutputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;


public class MqFilesSender
{
        public static void main(String[] args)
        {
                if (args.length < 6) {
                        System.out.println("usage: java com.traiana.utils.mq.MqFilesSender [qmgr] [port] [mqServerName] [channelName] [queueName] [file or directory] {optional ccsid} {debug}");
                        return;
                }
                MQ sender = null;
                try {
                        int ccsid = args.length >= 7 ? Integer.parseInt(args[6]) : 0;
                        boolean debug = args.length == 8 ? Boolean.valueOf(args[7]).booleanValue() : false;
                        sender = new MQ(args[0], Integer.parseInt(args[1]), args[2], args[3], ccsid, debug);
                        sender.InitQueue(args[4]);
                        File source = new File(args[5]);
                        if (source.isDirectory()) {
                                File[] files = source.listFiles();
                                for (File file : files) {
                                        sendFileToQueue(file, sender);
                                }
                        } else {
                                sendFileToQueue(source, sender);
                        }
                } catch (MQException e) {
                        e.printStackTrace();
                } catch (Exception e) {
                        e.printStackTrace();
                } finally {
                        if (sender != null)
                                try {
                                        sender.close();
                                } catch (MQException e) {
                                        e.printStackTrace();
                                }
                }
        }

        private static void sendFileToQueue(File file, MQ sender) throws IOException, MQException {
                if (file.isFile()) {
                        System.out.println("writting file: " + file.getName() + " to queue.");
                        FileInputStream in = new FileInputStream(file);
                        ByteArrayOutputStream byteOut = new ByteArrayOutputStream(in.available());
                        byte[] buff = new byte[10000];
                        int length;
                        while ((length = in.read(buff)) != -1) {
                                byteOut.write(buff, 0, length);
                        }
                        byteOut.flush();
                        sender.sendToQueue(byteOut.toByteArray());
                }
        }
}

/* Location:           C:\Users\thn\workspace\mq-utils.jar
 * Qualified Name:     com.traiana.utils.mq.MqFilesSender
 * JD-Core Version:    0.6.2
 */
1	package com.traiana.utils.mq;
2
3	import com.ibm.mq.MQException;
4	import java.io.ByteArrayOutputStream;
5	import java.io.File;
6	import java.io.FileInputStream;
7	import java.io.IOException;
8
9
10	public class MqFilesSender
11	{
12	public static void main(String[] args)
13	{
14	if (args.length < 6) {
15	System.out.println("usage: java com.traiana.utils.mq.MqFilesSender [qmgr] [port] [mqServerName] [channelName] [queueName] [file or directory] {optional ccsid} {debug}");
16	return;
17	}
18	MQ sender = null;
19	try {
20	int ccsid = args.length >= 7 ? Integer.parseInt(args[6]) : 0;
21	boolean debug = args.length == 8 ? Boolean.valueOf(args[7]).booleanValue() : false;
22	sender = new MQ(args[0], Integer.parseInt(args[1]), args[2], args[3], ccsid, debug);
23	sender.InitQueue(args[4]);
24	File source = new File(args[5]);
25	if (source.isDirectory()) {
26	File[] files = source.listFiles();
27	for (File file : files) {
28	sendFileToQueue(file, sender);
29	}
30	} else {
31	sendFileToQueue(source, sender);
32	}
33	} catch (MQException e) {
34	e.printStackTrace();
35	} catch (Exception e) {
36	e.printStackTrace();
37	} finally {
38	if (sender != null)
39	try {
40	sender.close();
41	} catch (MQException e) {
42	e.printStackTrace();
43	}
44	}
45	}
46
47	private static void sendFileToQueue(File file, MQ sender) throws IOException, MQException {
48	if (file.isFile()) {
49	System.out.println("writting file: " + file.getName() + " to queue.");
50	FileInputStream in = new FileInputStream(file);
51	ByteArrayOutputStream byteOut = new ByteArrayOutputStream(in.available());
52	byte[] buff = new byte[10000];
53	int length;
54	while ((length = in.read(buff)) != -1) {
55	byteOut.write(buff, 0, length);
56	}
57	byteOut.flush();
58	sender.sendToQueue(byteOut.toByteArray());
59	}
60	}
61	}
62
63	/* Location: C:\Users\thn\workspace\mq-utils.jar
64	* Qualified Name: com.traiana.utils.mq.MqFilesSender
65	* JD-Core Version: 0.6.2
66	*/