MQSeries.net :: View topic

prk · Posted: Mon Jun 05, 2006 9:46 am Post subject:

Here is my environment..
Windows 2003, MQ 5.3 CSD 09, Message Broker Toolkit 6.0

I am working on coding in Java within the EJBClient file generated using wsdl. I want to create a program which can Put and Get messages from queue parameters specified by the user and here is the code.
I am getting an error on the line ( qMgr = new MQQueueManager(qManager) ; ). When I change it to qMgr = new MQQueueManager(qManager, channel) ; I get the following error.
The constructor MQQueueManager(String, String) is undefined

Please help me, any help is greatly appreciated. Whats the correct way to resolve these errors.
----------------------------------------------------------------------------
I am importing import com.ibm.mq.*;

String hostName = "MYHOST" ;
String channel = "JAVA.CHANNEL" ;
String qManager = "MYQMGR" ;
String qName = "d_in" ;
//String connectionName = "localhost";

// Set up the MQEnvironment properties for Client Connections
MQEnvironment.hostname = hostName ;
MQEnvironment.channel = channel ;
MQEnvironment.port = 1414 ;

String connectionName="SYSTEM.DEF.SVRCONN/TCP/localhost(1414)";

MQEnvironment.properties.put(MQC.TRANSPORT_PROPERTY,MQC.TRANSPORT_MQSERIES);

// Connection To the Queue Manager
final MQQueueManager qMgr;
qMgr = new MQQueueManager(qManager) ;
//MQQueueManager qMgr=new MQQueueManager();

/* Set up the open options to open the queue for out put and
additionally we have set the option to fail if the queue manager is
quiescing.
*/
int openOptions = MQC.MQOO_OUTPUT | MQC.MQOO_FAIL_IF_QUIESCING ;

// Open the queue
//MQQueue queue = qMgr.accessQueue(qName, openOptions,null,null,null);
MQQueue queue = qMgr.accessQueue(qName, openOptions);

// Set the put message options , we will use the default setting.
MQPutMessageOptions pmo = new MQPutMessageOptions();

/* Next we Build a message The MQMessage class encapsulates the data buffer
that contains the actual message data, together with all the MQMD
parameters
that describe the message.
To Build a new message, create a new instance of MQMessage class and use
writxxx (we will be using writeString method). The put() method of
MQQueue also
takes an instance of the MQPutMessageOptions class as a parameter.
*/
MQMessage outMsg = new MQMessage(); //Create The message buffer
outMsg.format = MQC.MQFMT_STRING ; // Set the MQMD format field.

// Prepare message with user data
String msgString = "Test Message Using MQ Java API ";
outMsg.writeString(msgString);

// Now we put The message on the Queue
queue.put(outMsg, pmo);

// Commit the transaction.
qMgr.commit();
System.out.println(" The message has been Sussesfully put\n\n#########");

// Close the the Queue and Queue manager objects.
queue.close();
qMgr.disconnect();