MQSeries.net :: View topic - problem setting the MQEnvironment Variables

Rohitash · Posted: Mon Oct 03, 2005 7:15 am Post subject:

Subject:-problem setting the MQEnvironment Variables using a non default Queue Manager.

I am facing a very basic problem with MQ Series. Can you please help me with this?

When I try to connect to default Queue Manager and put a message on a queue in it, I am able to set the following variables in MQEnvironment. With these parameters, I was able to connect to another host also, accessing its default Queue Manager.

// Define the name of your host to connect to
private static String hostname = "172.21.5.184";

// Define name of channel for client to use - this name is the server connection channel name
private static String channel = "QM3_Ch1";

// Define name of queue manager object to connect to( This is not the default Queue Manager)
private static String qManager = "test_qm_3";

// Define name of queue manager object to connect to
private static String queue = "QM3_Q1";

MQEnvironment.hostname = hostname; // hostname
MQEnvironment.channel = channel; // channel string
//MQEnvironment.properties.put(MQC.TRANSPORT_PROPERTY,
// MQC.TRANSPORT_MQSERIES);
//MQEnvironment.port = 1416;

PROBLEM:-
When I create my own queue manager and a queue, I am able to put the message and get it from the queue, if I donâ€™t specify the MQEnvironment variables. It somehow takes the default value as the localhost. The channel I had created is similar to the channel in the default Queue Manager, ie Server Connection type. But the problem comes when I specify these MQEnvironment variable values with my Queue Manager. I also created similar Client connections as present in the default Queue Manager. It gives the following error:-

Inside initialize
MQEnvironment.hostname =blrkec38229d
MQEnvironment.channel:ServConn_QM3_Ch1
Inside initialize end
MQJE001: An MQException occurred: Completion Code 2, Reason 2009
MQJE016: MQ queue manager closed channel immediately during connect
Closure reason = 2009
MQJE001: Completion Code 2, Reason 2009
An MQ error occurred : Completion code 2 Reason code 2009

Can you please explain me the how to correct it.

The following is the program:-
// a sample prog by Rohitash to put and receive messages from MQ series
// queues.
package src;
//import java.io.File;

import com.ibm.mq.*;
// Include the MQ package
public class MQSampleTest {
// Define the name of your host to connect to
private static String hostname = "172.21.5.184";
// Define name of channel for client to use - this name is the server connection channel name
//private static String channel = "SERV_CH_test_qm_1";
private static String channel = "QM4_Ch1";
// Define name of queue manager object to connect to
private static String qManager = "QM4"; //test_qm_3
// Define name of queue manager object to connect to
private static String queue = "QM4_Q1";
// define a queue manager object
private static MQQueueManager qMgr;

static boolean bIsConnect = false;

// When the class is called, this initialisation is done first.
public static void main(String args[])
{
// Set up MQ environment
try
{
MQEnvironment.hostname = hostname; // Could have put the hostname and
MQEnvironment.channel = channel; // channel string directly here!
MQEnvironment.properties.put(MQC.TRANSPORT_PROPERTY, MQC.TRANSPORT_MQSERIES);
MQEnvironment.port = 1416;

start();
}
catch(Exception e )
{
e.printStackTrace();
}
} // end of init

public static void start() {
try {
// ****************************
// * CONNECT *
// ****************************
// Create a connection to the queue manager
qMgr = new MQQueueManager(qManager);
System.out.println("qmgr in MQSampleTest:" +qMgr);

// ****************************
// * OPEN *
// ****************************
// Set up the options on the queue we wish to open...
int openOptions = MQC.MQOO_INPUT_AS_Q_DEF + MQC.MQOO_OUTPUT;

// Now specify the queue that we wish to open, and the open options...
MQQueue system_default_local_queue = qMgr.accessQueue( queue, openOptions);// queue name
//null, // default queue manager
//null, // no dynamic queue name
//null); // no alternate user ID

// * MESSAGE *
MQMessage hello_world1 = new MQMessage();

hello_world1.writeString("Bye");

// * PUT *
MQPutMessageOptions pmo1 = new MQPutMessageOptions();

// Put the message on the queue
system_default_local_queue.put(hello_world1, pmo1);

int Key;
System.out.println("Press Enter !!!");
Key = System.in.read();

// ****************************
// * GET *
// ****************************
MQMessage retrievedMessage1 = new MQMessage();

MQGetMessageOptions gmo1 = new MQGetMessageOptions();
// get the message off the queue...
system_default_local_queue.get(retrievedMessage1, gmo1);

// ****************************
// * DISPLAY *
// ****************************
String msgText1 = retrievedMessage1.readLine();
System.out.println("The message is: " + msgText1);

// Close the queue
system_default_local_queue.close();

// Disconnect from the queue manager
qMgr.disconnect();
}

catch (MQException ex) {
System.out.println("An MQ error occurred : Completion code "+ ex.completionCode + " Reason code " + ex.reasonCode);
}
// Was it a Java buffer space error?
catch (java.io.IOException ex) {
System.out.println("An error occurred "+
"while writing to the message buffer: "+ ex);
ex.printStackTrace();
}
} // end of start
} // end of sample
[color=darkred][/color]
_________________
Thanks and regards
Rohitash Laul