6 Commits

Author SHA1 Message Date
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
4 changed files with 64 additions and 19 deletions

View File

@@ -1,7 +1,7 @@
// $RCSfile: MQSLoad.java,v $
// $Revision: 1.6 $
// $Revision: 1.8 $
// $Name: $
// $Date: 2002/05/06 09:52:24 $
// $Date: 2002/05/21 15:48:09 $
// $Author: giberta1 $
/*
@@ -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.8 $";
private String MQSLoad_Tag = "$Name: $";
private String MQSLoad_Date = "$Date: 2002/05/21 15:48:09 $";
private String MQSLoad_Author = "$Author: giberta1 $";
@@ -222,6 +227,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 +275,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 +473,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 +536,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 [-fb \"field_break\"] [-mb \"message_break\"] [-mt \"message_tail\"] [-kmb] <Output_MsgQueue_Name> <Input_File_Name>");
System.out.println( " Default: 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);
}
@@ -520,7 +552,7 @@ 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( "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();

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

View File

@@ -1,13 +1,23 @@
# $RCSfile: ReleaseNotes.txt,v $
# $Revision: 1.4 $
# $Revision: 1.6 $
# $Name: $
# $Date: 2002/05/06 09:57:19 $
# $Date: 2002/05/21 15:55:17 $
# $Author: giberta1 $
--------------------------------------------------------------------------------
MQSLoad V 1.1.3 - 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
--------------------------------------------------------------------------------

View File

@@ -70,7 +70,7 @@ MAROC
:71A:BEN
-}{5:{MAC:BCED2F18}{CHK:075B64FB4533}}
---MESSAGE-BREAK---
SWIFTABORT
SWIFTERROR
---MESSAGE-BREAK---
SWIFTBEGIN
---MESSAGE-BREAK---