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

- Add MQV7 support (Thanks to Yves MOYROUD !)

Browse Source
This commit is contained in:
agibert 2013-11-08 17:15:45 +00:00
parent b7fcd00035
commit bf1d811041
1 changed files with 9 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
MQSLoad.java
View File

@ -1,7 +1,7 @@
// $RCSfile: MQSLoad.java,v $ // $RCSfile: MQSLoad.java,v $
// $Revision: 1.21 $ // $Revision: 1.22 $
// $Name: $ // $Name: $
// $Date: 2009/01/05 17:47:15 $ // $Date: 2013/11/08 17:15:45 $
// $Author: agibert $ // $Author: agibert $
/* /*
@ -28,25 +28,23 @@
import java.io.*; import java.io.*;
import java.text.*; import java.text.*;
import com.ibm.mq.*; import com.ibm.mq.*;
import com.ibm.mq.constants.*;
public class MQSLoad public class MQSLoad
{ {
private String MQSLoad_Revision = "$Revision: 1.21 $"; private String MQSLoad_Revision = "$Revision: 1.22 $";
private String MQSLoad_Tag = "$Name: $"; private String MQSLoad_Tag = "$Name: $";
private String MQSLoad_Date = "$Date: 2009/01/05 17:47:15 $"; private String MQSLoad_Date = "$Date: 2013/11/08 17:15:45 $";
private String MQSLoad_Author = "$Author: agibert $"; private String MQSLoad_Author = "$Author: agibert $";
private MQQueueManager QMng = null; private MQQueueManager QMng = null;
private String QMng_Name = ""; private String QMng_Name = "";
private MQQueue MsgQ; private MQQueue MsgQ;
private String MsgQ_Name; private String MsgQ_Name;
private int MsgQ_Open_Options = MQC.MQOO_OUTPUT | MQC.MQOO_FAIL_IF_QUIESCING; private int MsgQ_Open_Options = CMQC.MQOO_OUTPUT | CMQC.MQOO_FAIL_IF_QUIESCING;
private boolean Character_Convert = false; private boolean Character_Convert = false;
private int Character_Set = 1208; private int Character_Set = 1208;
private int Message_Priority = MQC.MQPRI_PRIORITY_AS_Q_DEF; private int Message_Priority = CMQC.MQPRI_PRIORITY_AS_Q_DEF;
private int Sleep_Time = 0; private int Sleep_Time = 0;
private String Field_Break = ""; private String Field_Break = "";
private String Message_Break = "\r\n"; private String Message_Break = "\r\n";
@ -617,7 +615,7 @@ public class MQSLoad
} }
else else
{ {
Output_Msg.messageId = MQC.MQMI_NONE; Output_Msg.messageId = CMQC.MQMI_NONE;
MQSPut_Msg( Output_Msg); MQSPut_Msg( Output_Msg);
Output_Msg.clearMessage(); Output_Msg.clearMessage();
@ -666,7 +664,7 @@ public class MQSLoad
{ {
if( Character_Convert) if( Character_Convert)
{ {
output_msg.format = MQC.MQFMT_STRING; output_msg.format = CMQC.MQFMT_STRING;
} }
output_msg.characterSet = Character_Set; output_msg.characterSet = Character_Set;