I have started a connection using the following :
private void getMessageQueueConnection()
throws
JMSException
{
/*
* Get the message queue connection
*/
//Get the connection factory
UnicastConnectionFactory
l_connectionFactory = new UnicastConnectionFactory
("127.0.0.1", 3999);//"192.168.5.90", 3999);
//Get a connection
m_mqConnection =
l_connectionFactory.createConnection();
//Get a session from the connection
m_mqSession =
m_mqConnection.createSession(false,
Session.AUTO_ACKNOWLEDGE);
/*
* Use the session to create a queue
reference that will be
* used to connect to the mq
manager
*/
m_Queue =
m_mqSession.createQueue("QUEUE");
/*
* Connect to the queue on the
message server
*/
m_mqConsumer =
m_mqSession.createConsumer(m_consentQueue);
//Start the connection
m_mqConnection.start();
}
When I try to shut the connection down :
m_mqConsumer.close();
m_mqSession.close();
m_mqConnection.close();
nothing happens.
What else needs to be done in order to explicitly shut
the client thread down?