MQSeries.net :: View topic

rakent · Posted: Wed Jul 15, 2009 6:13 am Post subject:

I wrote a Java code to publish the message to the MQ V7.0. I am getting the error while executiong.

Error:
#########################################################################
Is connected true
***Publishing ***
MQJE001: Completion Code '2', Reason '2051'.
MQ Exception in the publish :com.ibm.mq.MQException: MQJE001: Completion Code '2', Reason '2051'.
#########################################################################
Script ended : Tue Jul 14 15:21:49 CDT 2009. Can anyone help me on this.

Code is copied below. I am exporting /usr/mqm/java/lib/com.ibm.mq.jmqi.jar:/usr/mqm/java/lib/com.ibm.mq.jar:

import com.ibm.mq.*;
import com.ibm.mq.constants.CMQC;
import com.ibm.mq.jmqi.*;

import java.util.*;
import java.io.*;

public class pub {
private Properties prop;
private String sHostName;
private String sSvrConName;
private String sPort;
private String sQueueManagerName;
private String sourceQueueName;
private int sourceQOpenOptions;
private FileInputStream fis;
private String topicObject;
private MQQueueManager sQmgr;
private MQQueue sourceQ;
private MQMessage mesg;
private MQPutMessageOptions pmo;
private MQGetMessageOptions gmo;

private void readConfigFile() {
try{
prop = new Properties();
fis = new FileInputStream(new File(
"/home/mqm/pubTest/PubSubConfig.txt"));
prop.load(fis);
sHostName = prop.getProperty("S_HOSTNAME");
sSvrConName = prop.getProperty("S_SERV_CHANNEL");
sPort = prop.getProperty("S_PORT");
sQueueManagerName = prop.getProperty("S_QUEUE_MANAGER_NAME");
sourceQueueName = prop.getProperty("S_QNAME");
topicObject = "MONEY";

}catch(IOException IOE){
System.out.println(" Exception Occured in the readConfigFile Function : " + IOE);
}
}
private void publish(){
MQEnvironment.hostname = sHostName;
MQEnvironment.channel = sSvrConName;
MQEnvironment.port = Integer.parseInt(sPort);
int destinationType = CMQC.MQOT_TOPIC;

try{
MQQueueManager queueManager = new MQQueueManager(sQueueManagerName);
MQMessage messageForPut = new MQMessage();
System.out.println(" Is connected " + queueManager.isConnected());
System.out.println("***Publishing ***");
messageForPut.writeString("Hello world!");
queueManager.put(destinationType, topicObject, messageForPut);
queueManager.disconnect();
}catch(MQException mqe){
System.out.println(" MQ Exception in the publish :" +mqe);
}catch(IOException ioe){
System.out.println(" IO Exception in the publish :" + ioe);
}
}

public static void main(String arg[]){
pub pubo = new pub();
pubo.readConfigFile();
pubo.publish();
}

}