MQSeries.net :: View topic

mpalmer · Posted: Fri Sep 24, 2004 9:45 am Post subject:

Below I have copied my sample Java Get program. It appears to me that the get with wait option is not working, based on the displays that I have in the program. Can you tell me what is wrong? Much appreciate your help.

/*
* Created on Sep 17, 2004
*/

/**
* @author MI299D
*/

import java.io.*;
import java.util.*;
import com.ibm.mq.*; // Include the WebSphere MQ classes for Java package
import java.text.*;

public class MQGet2
{
private String qManager = "TST_QM_PALMER";
private MQQueueManager qMgr;

public static void main(String[] args)
{
new MQGet2();
}
public MQGet2()
{
try
{
// Create a connection to the queue manager
qMgr = new MQQueueManager(qManager);

// 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 & the open options
MQQueue system_default_local_queue =
qMgr.accessQueue("SYSTEM.DEFAULT.LOCAL.QUEUE",openOptions);

// Define a simple message & write text in UTF format
MQMessage hello_world = new MQMessage();
hello_world.writeUTF("Hello World!");

// specify the msg options
MQPutMessageOptions pmo = new MQPutMessageOptions(); // accept the defaults

// put the msg on the queue
system_default_local_queue.put(hello_world,pmo);

// get the msg back again
// first define a MQ message buffer to receive the msg into
MQMessage retrievedMessage = new MQMessage();
retrievedMessage.messageId = hello_world.messageId;

// Set the get message options
MQGetMessageOptions gmo = new MQGetMessageOptions(); // accept defaults
gmo.options = MQC.MQGMO_WAIT;
gmo.waitInterval = 90000;

// get the date/timestamp & display it
Date today3;
today3 = new Date();
System.out.println("*** Maria - about to get msg off q " + today3);

// get the msg off the queue
system_default_local_queue.get(retrievedMessage, gmo);

// get the date/timestamp & display it
Date today;
today = new Date();
System.out.println("*** Maria - got msg " + today);

// And prove we have the message by displaying the UTF message text
String msgText = retrievedMessage.readUTF();
System.out.println("The message is: " + msgText);

// close the queue
system_default_local_queue.close();

// get the date/timestamp & display it
Date today2;
today2 = new Date();
System.out.println("*** Maria - close q " + today2);

// Disconnect from the qmgr
qMgr.disconnect();
}

// If an error occurred in the above, try to identify what went wrong.
catch (MQException ex)
{
System.out.println("A WebSphere 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);
}
} // end of start
} // end of program