Rx3/mqsload
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Compare commits

base: Rx3:mqsload-1_1_1
Branches Tags
Rx3:master
Rx3:mqsload-2_0_0 Rx3:mqsload-1_3_2 Rx3:mqsload-1_3_1 Rx3:mqsload-1_3_0 Rx3:mqsload-1_2_0 Rx3:mqsload-1_1_3 Rx3:mqsload-1_1_2 Rx3:mqsload-1_1_1 Rx3:mqsload-1_1_0 Rx3:mqsload-1_0_0
..
compare: Rx3:mqsload-1_2_0
Branches Tags
Rx3:master
Rx3:mqsload-2_0_0 Rx3:mqsload-1_3_2 Rx3:mqsload-1_3_1 Rx3:mqsload-1_3_0 Rx3:mqsload-1_2_0 Rx3:mqsload-1_1_3 Rx3:mqsload-1_1_2 Rx3:mqsload-1_1_1 Rx3:mqsload-1_1_0 Rx3:mqsload-1_0_0

11 Commits
mqsload-1_ ... mqsload-1_

Author SHA1 Message Date
agibert
d882d2a6a1 Add queue manager name option "-qm". 2007-06-05 09:22:43 +00:00
agibert
2c55f4ac61 Add in 1.2.0 entry: 
Add queue manager name option "-qm".
 2007-06-05 09:21:44 +00:00
giberta1
d327c3e4e9 Add in 1.1.3 entry: 
Add version, date and author print out.
 2002-05-21 15:55:17 +00:00
giberta1
15b8cece80 Add version, date and author print out. 2002-05-21 15:48:09 +00:00
giberta1
20cc7fc471 Add message tail option "-mt" explanations and example. 2002-05-21 15:22:00 +00:00
giberta1
402f904383 Add 1.1.3 entry: 
Add message tail option "-mt",
    Add MQQueueManager() auto retry.
 2002-05-21 15:08:37 +00:00
giberta1
f3b64d8cc5 Add message tail option "-mt", 
Add MQQueueManager() auto retry.
 2002-05-21 15:06:27 +00:00
giberta1
c03202827e Replace SWIFTABORT by SWIFTERROR. 2002-05-21 15:00:45 +00:00
giberta1
5bd41e53ef Add 1.1.2 entry: 
Add return code handling.
 2002-05-06 09:57:19 +00:00
giberta1
0ffc88e129 Add System.exit() handling. 2002-05-06 09:52:24 +00:00
giberta1
7187b8e088 Initial creation. 2002-05-03 17:26:19 +00:00
6 changed files with 5644 additions and 25 deletions
Expand all files Collapse all files

90
MQSLoad.java
View File

@@ -1,14 +1,14 @@
// $RCSfile: MQSLoad.java,v $
// $Revision: 1.5 $
// $Revision: 1.9 $
// $Name: $
// $Date: 2002/05/02 17:09:35 $
// $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,14 @@ 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);
}
else
{
@@ -517,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();
@@ -563,6 +609,8 @@ public class MQSLoad
MQSDeInit();
System.out.println( "MQS Load Completed !");
System.exit( 0);
}
}
@@ -570,6 +618,8 @@ public class MQSLoad
{
System.out.println("Exception: (" + Expt + ") !");
Expt.printStackTrace();
System.exit( 1);
}
}
}

7
ReadMe.txt
View File

@@ -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

32
ReleaseNotes.txt
View File

@@ -1,13 +1,39 @@
# $RCSfile: ReleaseNotes.txt,v $
# $Revision: 1.3 $
# $Revision: 1.7 $
# $Name: $
# $Date: 2002/05/02 17:17:28 $
# $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
--------------------------------------------------------------------------------
Add return code handling.
--------------------------------------------------------------------------------
MQSLoad V 1.1.1 - A. Gibert - 02/05/02
--------------------------------------------------------------------------------

5411
test-swift-batch-big1.txt Normal file
View File

File diff suppressed because it is too large Load Diff

49
test-swift-batch-big2.txt Normal file
View File

@@ -0,0 +1,49 @@
SWIFTOUT
{1:F01BCMAMAMCAXXX0857229951}{2:O1001511000801CICPFRPPAXXX65003436280008011611N}{4:
:20:CIC0001
:32A:000918EUR25062,66
:50:SOCIETE S.A.
PARIS
FRANCE
:57A:BCMAMAMCXXX
:59:I.A.M.
FES
MAROC
:70:/RFB/SOC01901
:71A:BEN
-}{5:{MAC:BCED2F18}{CHK:075B64FB4533}}
---MESSAGE-BREAK---
SWIFTOUT
{1:F01BCMAMAMC1XXX0000000000}{2:I730BNPAFRPPXXXXN}{4:
:20:ELC00001007
:21:TESTS-DL-003
:30:010629
-}
---MESSAGE-BREAK---
SWIFTOUT
{1:F01BCMAMAMC1XXX0000000000}{2:I710BCPCMACCXXXXN}{4:
:27:1/1
:40B:IRREVOCABLE TRANSFERABLE
ADDING OUR CONFIRMATION
:20:ELC00001002
:21:POB00001001
:31C:010328
:31D:010528PARIS
:52A:BARCGB22XXX
:50:SOCIETE ABC
AVENUE DES ALPES
CASABLANCA
:59:HUSUM PLASTIC
:32B:MAD100000,00
:41A:BARCGB22XXX
BY PAYMENT
:43P:NOT ALLOWED
:43T:NOT ALLOWED
:44A:GERMANY
:44B:CASABLANCA
:71B:ALL FOREIGN BANK CHARGES ARE FOR
THE ACCOUNT OF THE BENEFICIARY
:49:WITHOUT
-}
---MESSAGE-BREAK---
SWIFTEND

80
test-swift-batch.txt Normal file
View File

@@ -0,0 +1,80 @@
SWIFTBEGIN
---MESSAGE-BREAK---
SWIFTOUT
{1:F01BCMAMAMCAXXX0857229951}{2:O1001511000801CICPFRPPAXXX65003436280008011611N}{4:
:20:CIC0001
:32A:000918EUR25062,66
:50:SOCIETE S.A.
PARIS
FRANCE
---MESSAGE-BREAK---
SWIFTBEGIN
---MESSAGE-BREAK---
SWIFTOUT
{1:F01BCMAMAMCAXXX0857229951}{2:O1001511000801CICPFRPPAXXX65003436280008011611N}{4:
:20:CIC0001
:32A:000918EUR25062,66
:50:SOCIETE S.A.
PARIS
FRANCE
:57A:BCMAMAMCXXX
:59:I.A.M.
FES
MAROC
:70:/RFB/SOC01901
:71A:BEN
-}{5:{MAC:BCED2F18}{CHK:075B64FB4533}}
---MESSAGE-BREAK---
SWIFTABORT
---MESSAGE-BREAK---
SWIFTBEGIN
---MESSAGE-BREAK---
SWIFTOUT
{1:F01BCMAMAMCAXXX0857229951}{2:O1001511000801CICPFRPPAXXX65003436280008011611N}{4:
:20:CIC0001
:32A:000918EUR25062,66
:50:SOCIETE S.A.
PARIS
FRANCE
:57A:BCMAMAMCXXX
:59:I.A.M.
FES
MAROC
:70:/RFB/SOC01901
:71A:BEN
-}{5:{MAC:BCED2F18}{CHK:075B64FB4533}}
---MESSAGE-BREAK---
SWIFTOUT
{1:F01BCMAMAMC1XXX0000000000}{2:I730BNPAFRPPXXXXN}{4:
:20:ELC00001007
:21:TESTS-DL-003
:30:010629
-}
---MESSAGE-BREAK---
SWIFTOUT
{1:F01BCMAMAMC1XXX0000000000}{2:I710BCPCMACCXXXXN}{4:
:27:1/1
:40B:IRREVOCABLE TRANSFERABLE
ADDING OUR CONFIRMATION
:20:ELC00001002
:21:POB00001001
:31C:010328
:31D:010528PARIS
:52A:BARCGB22XXX
:50:SOCIETE ABC
AVENUE DES ALPES
CASABLANCA
:59:HUSUM PLASTIC
:32B:MAD100000,00
:41A:BARCGB22XXX
BY PAYMENT
:43P:NOT ALLOWED
:43T:NOT ALLOWED
:44A:GERMANY
:44B:CASABLANCA
:71B:ALL FOREIGN BANK CHARGES ARE FOR
THE ACCOUNT OF THE BENEFICIARY
:49:WITHOUT
-}
---MESSAGE-BREAK---
SWIFTEND