[jboss-user] [JBossMQ] - Socket closed exception in JBossMQ

Hi, I am using jboss 4.2.0 and i have couple of MDBs in my application which is bound to queues Every now and then i am seeing following exception in my server.log I am running Jboss in cluster mode and we have 2 nodes in cluster. What could be the problem in JBoss MQ or in my MsgSender code | 2009-05-29 23:00:01,166 DEBUG [org.jboss.mq.il.uil2.ServerSocketManagerHandler] Exiting on IOE | java.net.SocketException: Socket closed | at java.net.SocketInputStream.read(SocketInputStream.java:162) | at java.io.BufferedInputStream.fill(BufferedInputStream.java:218) | at java.io.BufferedInputStream.read(BufferedInputStream.java:235) | at org.jboss.util.stream.NotifyingBufferedInputStream.read(NotifyingBuff eredInputStream.java:79) | at java.io.ObjectInputStream$PeekInputStream.peek(ObjectInputStream.java :2196) | at java.io.ObjectInputStream$BlockDataInputStream.readBlockHeader(Object InputStream.java:2376) | at java.io.ObjectInputStream$BlockDataInputStream.refill(ObjectInputStre am.java:2443) | at java.io.ObjectInputStream$BlockDataInputStream.read(ObjectInputStream .java:2515) | at java.io.ObjectInputStream$BlockDataInputStream.readByte(ObjectInputSt ream.java:2664) | at java.io.ObjectInputStream.readByte(ObjectInputStream.java:875) | at org.jboss.mq.il.uil2.SocketManager$ReadTask.run(SocketManager.java:31 6) | at java.lang.Thread.run(Thread.java:595) | 2009-05-29 23:00:01,166 DEBUG [org.jboss.mq.il.uil2.SocketManager] End ReadTask. run | 2009-05-29 23:00:01,166 DEBUG [org.jboss.mq.il.uil2.SocketManager] End WriteTask .run | | Here is my MsgSender which post message in queue for MDB | public void send(String jndiQueueName, String message)throws NamingException, JMSException, Exception | { | logger.info("MsgSender Using jndiQueueName:"+jndiQueueName); | logger.info("Sening string object:" + message); | QueueConnection conn = getQueueConncetion(); | QueueSession session = conn.createQueueSession(false,QueueSession.AUTO_ACKNOWLEDGE); | Queue que = (Queue) getContext().lookup(jndiQueueName); | QueueSender sender = session.createSender(que); | TextMessage txtMsg = session.createTextMessage(); | txtMsg.setText(message); | sender.send(txtMsg); | //free all created objects | if(sender != null) { | sender.close(); | } | if(session != null) { | session.close(); | } | if(conn != null) { | conn.close(); | } | logger.info("Msg sent successfully"); | } | View the original post : http://www.jboss.org/index.html?module=bb&op=viewtopic&p=4234278#... Reply to the post : http://www.jboss.org/index.html?module=bb&op=posting&mode=reply&a...