MQSeries.net :: View topic

santhosh_fischer · Posted: Wed Aug 11, 2004 8:15 pm Post subject:

i tried creating a meeage listener for a particular queue. but the code never calls the OnMessage ..
..this is working fine in synchronous way using the recieve function..
can anyone give me suggestions....
..
is there anything extra to do for putting a listener for a queue..
.
code is listed below..

-----------------------------------------------------------------------
import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.*;
import javax.naming.*;
import com.ibm.mq.jms.*;
import com.ibm.mq.*;
/*
* Created on Aug 9, 2004
*
* To change the template for this generated file go to
* Window>Preferences>Java>Code Generation>Code and Comments
*/

/**
* @author Administrator
*
* To change the template for this generated type comment go to
* Window>Preferences>Java>Code Generation>Code and Comments
*/
public class fiscQueueReciever {

String queueName = null;
Context jndiContext = null;
QueueConnectionFactory queueConnectionFactory = null;
QueueConnection queueConnection = null;
QueueSession queueSession = null;
Queue queue = null;
QueueSender queueSender = null;
QueueReceiver queueReceiver = null;
MQQueueManager queueManager=null;
TextMessage message=null;

final int NUM_MSGS=0;
public fiscQueueReciever()
{
try {

queueConnectionFactory= new MQQueueConnectionFactory();
queueConnection = queueConnectionFactory.createQueueConnection();
queueSession = queueConnection.createQueueSession(false,Session.AUTO_ACKNOWLEDGE);
queue=queueSession.createQueue( "testqueue1");

queueReceiver = queueSession.createReceiver(queue);
fiscListener fl=new fiscListener();
queueReceiver.setMessageListener(fl);
queueConnection.start();

//--------------------------------------------added listener and started
//connection---starting sending message-----------------------

queueSender = queueSession.createSender(queue);
message = queueSession.createTextMessage();
for (int i = 0; i < 1; i++) {
message.setText("This is sample message " + (i + 1));
System.out.println("Sending message: " + message.getText());
queueSender.send(message);
}

} catch (JMSException e) {
System.out.println("Exception occurred: " +
e.toString());
} catch (Exception se){
System.out.println(" last Exception occurred: " +
se.toString());

} finally {
// if (queueConnection != null) {
// try {
// queueConnection.close();
// } catch (JMSException e) {}
// }
}
}

*/

public static void main (String[] args)
{
fiscQueueReciever fqr=new fiscQueueReciever();

}

}//class

class fiscListener implements MessageListener
{
public void onMessage(Message arg0) {
TextMessage message = null;
Message m=null;
m=arg0;

try
{
System.out.println("entered");
if (m != null) {
if (m instanceof TextMessage)
{
message = (TextMessage) m;
System.out.println("Reading message: " +message.getText());
}
}

} catch (JMSException e) {
System.out.println("Exception occurred: " + e.toString());
} catch (Exception se){
System.out.println(" last Exception occurred: " + se.toString());
}

}//onMessage
}
----------------------------------------------------------------
pls give me soem suggestions..or point out my mistake.....
thanks in advance
Santhosh