MQSeries.net :: View topic

samsam007 · Posted: Wed Nov 26, 2008 3:17 pm Post subject:

Dear MQ Development Gurus,

I have WMQ v6.0 installed in Windows. Created Qmgr, channel and an input/output queue. I downloaded a MQWrite.java file and compiled it in another windows with MQ client installed.

When I executed the java client connect to the Qmgr, the java client program showns the Qmgr is closed the connection. Then I looked thru the log file produced by the channel exits code for this Qmgr, it said that the user ID is blank, therefore refused the connection from the java client.

Here is the java client code I refered to:

import com.ibm.mq.*;
import java.io.IOException;
import java.util.Hashtable;
import java.io.*;

public class MQWrite {
private MQQueueManager _queueManager = null;
private Hashtable params = null;
public int port = 1414;
public String hostname = "127.0.0.1";
public String channel = "CLIENT.TO.MQA1";
public String qManager = "MQA1";
public String outputQName = "SYSTEM.DEFAULT.LOCAL.QUEUE";

public MQWrite()
{
super();
}
private boolean allParamsPresent()
{
boolean b = params.containsKey("-h") &&
params.containsKey("-p") &&
params.containsKey("-c") &&
params.containsKey("-m") &&
params.containsKey("-q");
if (b)
{
try
{
port = Integer.parseInt((String) params.get("-p"));
}
catch (NumberFormatException e)
{
b = false;
}
// Set up MQ environment
hostname = (String) params.get("-h");
channel = (String) params.get("-c");
qManager = (String) params.get("-m");
outputQName = (String) params.get("-q");

}
return b;
}
private void init(String[] args) throws IllegalArgumentException
{
params = new Hashtable(5);
if (args.length > 0 && (args.length % 2) == 0)
{
for (int i = 0; i < args.length; i+=2)
{
params.put(args[i], args[i+1]);
}
}
else
{
throw new IllegalArgumentException();
}

if (allParamsPresent())
{
// Set up MQ environment
MQEnvironment.hostname = hostname;
MQEnvironment.channel = channel;
MQEnvironment.port = port;

}
else
{
throw new IllegalArgumentException();
}
}
public static void main(String[] args)
{

MQWrite write = new MQWrite();

try
{
write.init(args);
write.selectQMgr();
write.write();
}
catch (IllegalArgumentException e)
{
System.out.println("Usage: java MQWrite <-h host> <-p port> <-c channel> <-m QueueManagerName> <-q QueueName>");
System.exit(1);
}
catch (MQException e)
{
System.out.println(e);
System.exit(1);
}
}
private void selectQMgr() throws MQException
{
_queueManager = new MQQueueManager(qManager);
}
private void write() throws MQException
{
String line;
int lineNum=0;
int openOptions = MQC.MQOO_OUTPUT + MQC.MQOO_FAIL_IF_QUIESCING;
try
{
MQQueue queue = _queueManager.accessQueue( outputQName,
openOptions,
null, // default q manager
null, // no dynamic q name
null ); // no alternate user id

DataInputStream input = new DataInputStream(System.in);

System.out.println("MQWrite v1.0 connected");
System.out.println("and ready for input, terminate with ^Z\n\n");

// Define a simple MQ message, and write some text in UTF format..
MQMessage sendmsg = new MQMessage();
sendmsg.format = MQC.MQFMT_STRING;
sendmsg.feedback = MQC.MQFB_NONE;
sendmsg.messageType = MQC.MQMT_DATAGRAM;
sendmsg.replyToQueueName = "ROGER.QUEUE";
sendmsg.replyToQueueManagerName = qManager;

MQPutMessageOptions pmo = new MQPutMessageOptions(); // accept the defaults, same
// as MQPMO_DEFAULT constant
while ((line = input.readLine()) != null)
{
sendmsg.clearMessage();
sendmsg.messageId = MQC.MQMI_NONE;
sendmsg.correlationId = MQC.MQCI_NONE;
sendmsg.writeString(line);

// put the message on the queue

queue.put(sendmsg, pmo);
System.out.println(++lineNum + ": " + line);
}

queue.close();
_queueManager.disconnect();

}
catch (com.ibm.mq.MQException mqex)
{
System.out.println(mqex);
}
catch (java.io.IOException ioex)
{
System.out.println("An MQ IO error occurred : " + ioex);
}

}
}

The log messages produced by the EXIT code at the Qmgr is shown below:
2008-11-27|09:33:55|ConName is now [149.1.2.3]
2008-11-27|09:33:55|Starting on BlockIP2.ini processing
2008-11-27|09:33:55|BlockIP2.ini [\BlockIP2.ini] to look for.
2008-11-27|09:33:55|Info: BlockIP2.ini [\BlockIP2.ini] was not found.
2008-11-27|09:33:55|BlockIP2.ini processing ended with rc 0.
2008-11-27|09:33:55|Finished BlockIP2.ini processing
2008-11-27|09:33:55|Check for cycle files started.
2008-11-27|09:33:55|File size of C:\\BlockIP2001.log is 2692 (limit 204800)
2008-11-27|09:33:55|======= INIT ======
2008-11-27|09:33:55|lMaxChannelActive is now -1 (before channel check)
2008-11-27|09:33:55|Return status Exitresponse=0
2008-11-27|09:33:55|LoadRegistry RegOpenKeyEx failed
2008-11-27|09:33:55|Check for cycle files started.
2008-11-27|09:33:55|File size of C:\\BlockIP2001.log is 3039 (limit 204800)
2008-11-27|09:33:55|======= Start INIT_SEC ======
2008-11-27|09:33:55|ver=2.64 env=non-MVS ExitId=MQXT_CHANNEL_SEC_EXIT ExitReason=MQXR_INIT_SEC ChannelType=MQCHT_SVRCONN
2008-11-27|09:33:55|BlockExit QMgr=[QM.MQT2] ChannelName=[TQM2.TCP.MQT1] ConnName=[149.1.2.3] Uid=[] pDataLength=0
2008-11-27|09:33:55|CheckConnectionPattern()
2008-11-27|09:33:55|Pattern [149.1.*;] ip[149.1.*] j 9
2008-11-27|09:33:55|pattern [149.1.*], ConName [149.1.2.3] passed test..
2008-11-27|09:33:55|Users: [] len [0] 0
2008-11-27|09:33:55|CheckCONList()
2008-11-27|09:33:55|CheckSSLList()
2008-11-27|09:33:55|CheckBlankUser()
2008-11-27|09:33:55|Connection refused for blank user identifier
2008-11-27|09:33:55|Connection refused, Channel [TQM2.TCP.MQT1] ConName [149.1.2.3] User []
2008-11-27|09:33:55|LoadRegistry RegOpenKeyEx failed
2008-11-27|09:33:55|======= TERM ======
2008-11-27|09:33:55|Channel closed [TQM2.TCP.MQT1] Connection Name [149.1.2.3]
2008-11-27|09:33:55|Before Free
2008-11-27|09:33:55|Free success

Thanks