MQSeries.net :: View topic

kishan · Posted: Fri Nov 15, 2002 2:03 am Post subject:

Hi,

I am putting a msg in Queue and waiting upto 2 minutes and trying to get the reply msg back using MQ with PTP. The same is working when I am running as a stand alone program successfully.

I am executing the same class in WebSphere3.5 env using EJB's experiencing a prolbem while reading the msg with 2033 and javax.transaction.TransactionRolledback .

Statless Session Bean with trans_attr=TRANS_NOT_SUPP, wait interval on reply msg is 2 minutes, msg expiry limit while putting is 1 min.

Hoping the suggestions at the earliest and Thanking you inadvance.

*** FYI - Used Methods ***

public void sendRequest(String newMQMessage) {
try {
MQMessage mqMessage = new MQMessage();
mqMessage.messageType = MQC.MQMT_REQUEST;
mqMessage.putApplicationType = MQC.MQAT_JAVA;
mqMessage.expiry = messageExpiryInterval;
mqMessage.format = MQC.MQFMT_STRING;
mqMessage.replyToQueueManagerName = amiServerQueueManager;
mqMessage.replyToQueueName = responseAMIQueueName;
mqMessage.writeString(newMQMessage);
requestQueue.put(mqMessage);
msgId = mqMessage.messageId;
}catch (MQException mqException) {}
}

public String retrieveResponse() {
String serverResponse = null;
try {
MQMessage replyMessage = new MQMessage();
MQMessage recivedMessage = new MQMessage();
int messageLength = 0;
MQGetMessageOptions getMessageOptions=new MQGetMessageOptions();
getMessageOptions.options = MQC.MQGMO_WAIT;
getMessageOptions.waitInterval = messageTimeOutInterval;
getMessageOptions.matchOptions = MQC.MQMO_MATCH_CORREL_ID;
replyMessage.correlationId = msgId;
responseQueue.get(replyMessage, getMessageOptions);
messageLength = replyMessage.getTotalMessageLength();
serverResponse = replyMessage.readString(messageLength);
} catch (Exception Exception) {}
return serverResponse;
}

regards,
Kishan