Compare commits
8 Commits
mqsload-1_
...
mqsload-1_
| Author | SHA1 | Date | |
|---|---|---|---|
|
d882d2a6a1 | ||
|
|
2c55f4ac61 | ||
|
d327c3e4e9 | ||
|
|
15b8cece80 | ||
|
|
20cc7fc471 | ||
|
|
402f904383 | ||
|
|
f3b64d8cc5 | ||
|
|
c03202827e |
84
MQSLoad.java
84
MQSLoad.java
@@ -1,14 +1,14 @@
|
||||
// $RCSfile: MQSLoad.java,v $
|
||||
// $Revision: 1.6 $
|
||||
// $Revision: 1.9 $
|
||||
// $Name: $
|
||||
// $Date: 2002/05/06 09:52:24 $
|
||||
// $Author: giberta1 $
|
||||
// $Date: 2007/06/05 09:22:43 $
|
||||
// $Author: agibert $
|
||||
|
||||
/*
|
||||
* MQSLoad.java - Data file to MQ/Series queue loader
|
||||
* Copyright (C) 2001-2002 Arnaud G. Gibert
|
||||
* arnaud.gibert@misys.com
|
||||
* www.miys-ibs.fr
|
||||
* Copyright (C) 2001-2006 Arnaud G. Gibert
|
||||
* mailto:arnaud@rx3.net
|
||||
* http://www.rx3.org/dvp/MQSLoad
|
||||
*
|
||||
* This program is free software; you can redistribute it and/or
|
||||
* modify it under the terms of the GNU General Public License
|
||||
@@ -35,7 +35,7 @@ import java.text.*;
|
||||
|
||||
public class MQSLoad
|
||||
{
|
||||
private MQQueueManager QMng;
|
||||
private MQQueueManager QMng = null;
|
||||
private String QMng_Name = "";
|
||||
private MQQueue MsgQ;
|
||||
private String MsgQ_Name;
|
||||
@@ -43,7 +43,12 @@ public class MQSLoad
|
||||
private String File_Name;
|
||||
private String Field_Break = "";
|
||||
private String Message_Break = "\r\n";
|
||||
private String Message_Tail = "";
|
||||
private boolean Keep_Message_Break = false;
|
||||
private String MQSLoad_Revision = "$Revision: 1.9 $";
|
||||
private String MQSLoad_Tag = "$Name: $";
|
||||
private String MQSLoad_Date = "$Date: 2007/06/05 09:22:43 $";
|
||||
private String MQSLoad_Author = "$Author: agibert $";
|
||||
|
||||
|
||||
|
||||
@@ -198,7 +203,19 @@ public class MQSLoad
|
||||
{
|
||||
while( argc < args.length)
|
||||
{
|
||||
if( args[argc].equals( "-fb"))
|
||||
if( args[argc].equals( "-qm"))
|
||||
{
|
||||
if( argc < ( args.length + 1))
|
||||
{
|
||||
QMng_Name = Str_Format( args[++argc]);
|
||||
}
|
||||
else
|
||||
{
|
||||
System.out.println( "Invalid number of command line options...");
|
||||
throw new Exception();
|
||||
}
|
||||
}
|
||||
else if( args[argc].equals( "-fb"))
|
||||
{
|
||||
if( argc < ( args.length + 1))
|
||||
{
|
||||
@@ -222,6 +239,18 @@ public class MQSLoad
|
||||
throw new Exception();
|
||||
}
|
||||
}
|
||||
else if ( args[argc].equals( "-mt"))
|
||||
{
|
||||
if( argc < ( args.length + 1))
|
||||
{
|
||||
Message_Tail = Str_Format( args[++argc]);
|
||||
}
|
||||
else
|
||||
{
|
||||
System.out.println( "Invalid number of command line options...");
|
||||
throw new Exception();
|
||||
}
|
||||
}
|
||||
else if ( args[argc].equals( "-kmb"))
|
||||
{
|
||||
Keep_Message_Break = true;
|
||||
@@ -258,15 +287,27 @@ public class MQSLoad
|
||||
|
||||
private void MQSInit() throws Exception
|
||||
{
|
||||
try
|
||||
{
|
||||
QMng = new MQQueueManager( QMng_Name);
|
||||
// System.out.println( "QManager Open: (" + QMng + ") !");
|
||||
}
|
||||
short retry = 0;
|
||||
final short RETRY_MAX = 10;
|
||||
|
||||
|
||||
while( QMng == null)
|
||||
{
|
||||
try
|
||||
{
|
||||
QMng = new MQQueueManager( QMng_Name);
|
||||
// System.out.println( "QManager Open: (" + QMng + ") !");
|
||||
}
|
||||
|
||||
catch( Exception Expt)
|
||||
{
|
||||
throw Expt;
|
||||
catch( Exception Expt)
|
||||
{
|
||||
System.out.print("!");
|
||||
|
||||
if( retry++ > RETRY_MAX)
|
||||
{
|
||||
throw Expt;
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
try
|
||||
@@ -444,6 +485,8 @@ public class MQSLoad
|
||||
if( next_message <= cur_window_size)
|
||||
{
|
||||
// System.out.println( "* Write Msg CurPos: (" + cur_pos + ")");
|
||||
output_msg.writeString( Message_Tail);
|
||||
|
||||
if( Keep_Message_Break)
|
||||
{
|
||||
output_msg.writeString( Message_Break);
|
||||
@@ -505,11 +548,12 @@ public class MQSLoad
|
||||
|
||||
try
|
||||
{
|
||||
System.out.println("MQSLoad: " + MQSLoad_Tag + " / " + MQSLoad_Date + " / " + MQSLoad_Author);
|
||||
|
||||
if( ( args.length < 2) || ( args.length > 6))
|
||||
{
|
||||
System.out.println( "Usage: MQSLoad [-fb \"field_break\"] [-mb \"message_break\"] [-kmb] <Output_MsgQueue_Name> <Input_File_Name>");
|
||||
System.out.println( " Default: Field Break: (" + Str_UnFormat( Field_Break) + ") Message Break: (" + Str_UnFormat( Message_Break) + ") Keep Message Break: (" + Keep_Message_Break + ")");
|
||||
System.out.println( "Usage: MQSLoad [-qm \"Output_QueueMng_Name\"] [-fb \"field_break\"] [-mb \"message_break\"] [-mt \"message_tail\"] [-kmb] <Output_MsgQueue_Name> <Input_File_Name>");
|
||||
System.out.println( " Default: Output QueueMng Name: (" + QMng_Name + ") Field Break: (" + Str_UnFormat( Field_Break) + ") Message Break: (" + Str_UnFormat( Message_Break) + ") Message Tail: (" + Str_UnFormat( Message_Tail) + ") Keep Message Break: (" + Keep_Message_Break + ")");
|
||||
|
||||
System.exit( 1);
|
||||
}
|
||||
@@ -519,8 +563,8 @@ public class MQSLoad
|
||||
|
||||
Arg_Parse( args);
|
||||
|
||||
System.out.println( "Output MsgQueue Name: (" + MsgQ_Name + ") Input File Name: (" + File_Name + ")");
|
||||
System.out.println( "Field Break: (" + Str_UnFormat( Field_Break) + ") Message Break: (" + Str_UnFormat( Message_Break) + ") Keep Message Break: (" + Keep_Message_Break + ")");
|
||||
System.out.println( "Output QueueMng Name: (" + QMng_Name + ") Output MsgQueue Name: (" + MsgQ_Name + ") Input File Name: (" + File_Name + ")");
|
||||
System.out.println( "Field Break: (" + Str_UnFormat( Field_Break) + ") Message Break: (" + Str_UnFormat( Message_Break) + ") Message Tail: (" + Str_UnFormat( Message_Tail) + ") Keep Message Break: (" + Keep_Message_Break + ")");
|
||||
|
||||
MQSInit();
|
||||
|
||||
|
||||
@@ -1,7 +1,7 @@
|
||||
# $RCSfile: ReadMe.txt,v $
|
||||
# $Revision: 1.6 $
|
||||
# $Revision: 1.7 $
|
||||
# $Name: $
|
||||
# $Date: 2002/05/02 17:24:15 $
|
||||
# $Date: 2002/05/21 15:22:00 $
|
||||
# $Author: giberta1 $
|
||||
|
||||
|
||||
@@ -34,6 +34,7 @@ Notes:
|
||||
|
||||
- Message breaks are used for message separation in the batch file,
|
||||
- Message breaks are striped from the sended message if "-kmb" (keep message break) is not set,
|
||||
- Message tail specified after "-mt" option is inserted between message and message break,
|
||||
- Field breaks are striped from the sended message.
|
||||
|
||||
- Windows text files: newline is specified as "\r\n",
|
||||
@@ -55,5 +56,7 @@ Usage Examples:
|
||||
java MQSLoad -mb "---MESSAGE-BREAK---\r\n" SWIFT-QUEUE swift-batch.txt
|
||||
- To load a raw swift batch file "swift-batch-raw.txt" with "}\r\n" message break into the MQ/Series "SWIFT-QUEUE" and by keeping message break separator use:
|
||||
java MQSLoad -mb "}\r\n" -kmb SWIFT-QUEUE swift-batch-raw.txt
|
||||
- To load a raw swift batch file "swift-batch-raw.txt" with "}\r\n" message break into the MQ/Series "SWIFT-QUEUE" and by keeping only "}" as end of message use:
|
||||
java MQSLoad -mb "}\r\n" -mt "}" SWIFT-QUEUE swift-batch-raw.txt
|
||||
- To load a csv batch file "batch.csv" with ";" field separator into the MQ/Series "DATA-QUEUE" use:
|
||||
java MQSLoad -fb ";" DATA-QUEUE csv-batch.csv
|
||||
|
||||
@@ -1,13 +1,31 @@
|
||||
# $RCSfile: ReleaseNotes.txt,v $
|
||||
# $Revision: 1.4 $
|
||||
# $Revision: 1.7 $
|
||||
# $Name: $
|
||||
# $Date: 2002/05/06 09:57:19 $
|
||||
# $Author: giberta1 $
|
||||
# $Date: 2007/06/05 09:21:44 $
|
||||
# $Author: agibert $
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
--------------------------------------------------------------------------------
|
||||
MQSLoad V 1.2.0 - A. Gibert - 05/06/07
|
||||
--------------------------------------------------------------------------------
|
||||
|
||||
Add queue manager name option "-qm".
|
||||
|
||||
|
||||
|
||||
--------------------------------------------------------------------------------
|
||||
MQSLoad V 1.1.4 - A. Gibert - 21/05/02
|
||||
--------------------------------------------------------------------------------
|
||||
|
||||
Add message tail option "-mt",
|
||||
Add MQQueueManager() auto retry,
|
||||
Add version, date and author print out.
|
||||
|
||||
|
||||
|
||||
--------------------------------------------------------------------------------
|
||||
MQSLoad V 1.1.2 - A. Gibert - 06/05/02
|
||||
--------------------------------------------------------------------------------
|
||||
|
||||
@@ -70,7 +70,7 @@ MAROC
|
||||
:71A:BEN
|
||||
-}{5:{MAC:BCED2F18}{CHK:075B64FB4533}}
|
||||
---MESSAGE-BREAK---
|
||||
SWIFTABORT
|
||||
SWIFTERROR
|
||||
---MESSAGE-BREAK---
|
||||
SWIFTBEGIN
|
||||
---MESSAGE-BREAK---
|
||||
|
||||
Reference in New Issue
Block a user