MQSeries.net :: View topic

gigya74 · Posted: Mon Jul 10, 2006 11:26 pm Post subject:

Hi,
I have written a small pgm to put and get messages. This uses SVRCONN channel. My problem is i have to start the channel before putting a message to the queue. This happens if i try to put a message after a long period of inactivity. Sending you the java code i use to put messages.
The object names are read from a property file.
Please send me any solutions. Can i start the channel programatically before putting the message-if yes what is the syntax.

thanks n regards
venkatB
-------------------------------------------------------------------------------------
private void sendMessage(String message) throws MQException, IOException {

// Set up connection to the MQ Server
MQEnvironment.hostname = props.getProperty("send.queue.host");
MQEnvironment.port = Integer.parseInt(props.getProperty("send.queue.port"));
MQEnvironment.channel = props.getProperty("send.queue.channel");
MQEnvironment.properties.put(MQC.TRANSPORT_PROPERTY, MQC.TRANSPORT_MQSERIES);

openOptions = MQC.MQOO_INPUT_AS_Q_DEF + MQC.MQOO_OUTPUT;
reqQueueManager = new MQQueueManager(props.getProperty("send.queue.mgr"));
reqQueue = reqQueueManager.accessQueue(props.getProperty("send.queue"), openOptions, null, null, null);

// Prepare message
MQMessage msg = new MQMessage();
msg.writeString(message);
msg.format = MQC.MQFMT_STRING;

// Prepare message writing options
MQPutMessageOptions pmo = new MQPutMessageOptions();

// Write a message to the queue
reqQueue.put(msg, pmo);

// Commit the Queue manager
reqQueueManager.commit();
reqQueue.close();
reqQueueManager.disconnect();

System.out.println("Message \"" + message + " \"sent successfully at " + System.currentTimeMillis());
}