MQSeries.net :: View topic

_Angus_ · Posted: Tue Oct 10, 2006 4:52 am Post subject:

Hi there,

A team I'm helping have a problem where channels remain open on the Queue Manager after they have (seemingly) been closed properly by the client.

I don't know enough about JMS to spot this one but know something isn't tidying up properly. We are using MQ 5.3 CSD11 and the offending code is as follows:

----------------------------------------------------------------

private String sendMessage(String message, String jmsType) throws NamingException, JMSException
{
log.info("Encrypted Request: " + removeRestrictedLoggingElements(message));
//log.info("Request: " + message);
if(message.indexOf("<name>validateAndPriceOrder") != -1) {
log.debug("validateAndPriceOrder message.");
validateAndPriceOrderMessage = true;
}

InitialContext ic = new InitialContext();

QueueConnectionFactory queueConnectionFactory = (QueueConnectionFactory)ic.lookup(ApiConstants.QUEUE_FACTORY);
Queue queue = (Queue)ic.lookup(ApiConstants.SEND_QUEUE);
Queue receiveQueue = (Queue)ic.lookup(ApiConstants.RECEIVE_QUEUE);

QueueConnection connection = queueConnectionFactory.createQueueConnection();

try
{
connection.start();
//Create a queue session
QueueSession session = connection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);

try{
//Send the message
QueueSender sender = session.createSender(queue);
try
{
TextMessage textMessage = session.createTextMessage(message);

// Default: Set the priority of message to 5
textMessage.setJMSPriority(5);
// Set the reply to queue
textMessage.setJMSReplyTo(receiveQueue);
// Set the domain to 'xml' and the type to jmsType
textMessage.setJMSType("mcd://xml//" + jmsType);
// Set a usr property
textMessage.setStringProperty("ErrorCode", "00000000");
//Send the message
sender.send(textMessage);

//Get the message id, this is used to filter the
//subsequent read of the reply to queue
String messageId = textMessage.getJMSMessageID();

return messageId;
}finally{
sender.close();
}
}finally{
session.close();
}
}
finally
{
connection.close();
}

}

---------------------------------------------------

Any help or pointers would be appreciated!

Angus
_________________
*-*-*-*-*-*-*-*-*-*-*-*-*-*-*-*-*
Angus Cooke ~ AngusSoft

Integration Development Tools
*-*-*-*-*-*-*-*-*-*-*-*-*-*-*-*-*