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