For every 10 seconds my code calls the below method to poll for new messages,
but the problem is, JBoss messaging implementation is internally creating a new
thread whenever it executes the session.createConsumer(queue) statement. And
thread count grows continuously as it polls, after some time it ends up with
Out of Memory error.
Is it a bug in the JBM implementation or I am not doing it correctly? Please
advice.
| public String pollForNewMsg() throws Exception
| {
| InitialContext ic = new InitialContext();
| ConnectionFactory cf =
(ConnectionFactory)ic.lookup("/ConnectionFactory");
| Connection _jmsConn =
cf.createConnection();
| Session session = conn.createSession(false,
Session.AUTO_ACKNOWLEDGE);
| Queue queue = (Queue)ic.lookup(queueName);
| javax.jms.MessageConsumer consumer =
session.createConsumer(queue);
| conn.start();
| TextMessage msg = (TextMessage)consumer.receive(10);
| String text = msg.getText();
|
| consumer.close();
| conn.close();
|
| return text;
| }
|
-APK.
View the original post :
http://www.jboss.com/index.html?module=bb&op=viewtopic&p=4049739#4049739
Reply to the post :
http://www.jboss.com/index.html?module=bb&op=posting&mode=reply&p=4049739
_______________________________________________
jboss-user mailing list
jboss-user@lists.jboss.org
https://lists.jboss.org/mailman/listinfo/jboss-user
