Rx3/mqssave
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:17:12 +00:00
parent 89c00936c2
commit e461670367
1 changed files with 13 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
MQSSave.java
View File

@ -1,7 +1,7 @@
// $RCSfile: MQSSave.java,v $
// $Revision: 1.20 $
// $Revision: 1.21 $
// $Name: $
// $Date: 2009/01/05 17:32:49 $
// $Date: 2013/11/08 17:17:12 $
// $Author: agibert $
/*
@ -26,24 +26,24 @@
*/
import com.ibm.mq.*;
import com.ibm.mq.constants.*;
import java.io.*;
import java.text.*;
public class MQSSave
{
private String MQSSave_Revision = "$Revision: 1.20 $";
private String MQSSave_Revision = "$Revision: 1.21 $";
private String MQSSave_Tag = "$Name: $";
private String MQSSave_Date = "$Date: 2009/01/05 17:32:49 $";
private String MQSSave_Date = "$Date: 2013/11/08 17:17:12 $";
private String MQSSave_Author = "$Author: agibert $";
private MQQueueManager QMng = null;
private String QMng_Name = "";
private MQQueue MsgQ;
private String MsgQ_Name;
private int MsgQ_Open_Options = MQC.MQOO_INPUT_AS_Q_DEF | MQC.MQOO_FAIL_IF_QUIESCING | MQC.MQOO_BROWSE | MQC.MQOO_INQUIRE;
private int MsgQ_Open_Options = CMQC.MQOO_INPUT_AS_Q_DEF | CMQC.MQOO_FAIL_IF_QUIESCING | CMQC.MQOO_BROWSE | CMQC.MQOO_INQUIRE;
private boolean Character_Convert = false;
private int Character_Set = 1208;
private int Sleep_Time = 0;
@ -432,19 +432,19 @@ public class MQSSave
{
if( First)
{
gmo.options = MQC.MQGMO_NO_WAIT | MQC.MQGMO_BROWSE_FIRST;
gmo.options = CMQC.MQGMO_NO_WAIT | CMQC.MQGMO_BROWSE_FIRST;
}
else
{
gmo.options = MQC.MQGMO_NO_WAIT | MQC.MQGMO_BROWSE_NEXT;
gmo.options = CMQC.MQGMO_NO_WAIT | CMQC.MQGMO_BROWSE_NEXT;
}
if( Character_Convert)
{
gmo.options = gmo.options | MQC.MQGMO_CONVERT;
gmo.options = gmo.options | CMQC.MQGMO_CONVERT;
}
gmo.matchOptions = MQC.MQMO_NONE;
gmo.matchOptions = CMQC.MQMO_NONE;
MsgQ.get( Msg, gmo);
@ -492,8 +492,8 @@ public class MQSSave
try
{
gmo.options = MQC.MQGMO_NO_WAIT | MQC.MQGMO_CONVERT;
gmo.matchOptions = MQC.MQMO_MATCH_MSG_ID;
gmo.options = CMQC.MQGMO_NO_WAIT | CMQC.MQGMO_CONVERT;
gmo.matchOptions = CMQC.MQMO_MATCH_MSG_ID;
MsgQ.get( Msg, gmo);
}
@ -625,7 +625,7 @@ public class MQSSave
try
{
// input_msg.format = MQC.MQFMT_STRING;
// input_msg.format = CMQC.MQFMT_STRING;
input_msg.characterSet = Character_Set;
/* Loop while Msg_Count not reatch */