3 Replies Latest reply on Mar 21, 2006 1:45 PM by adrian.brock

java.lang.InterruptedException when sending messages

vasu_suku Mar 17, 2006 6:45 PM

Hi

While sending messages I get a java.lang.InterruptedException. Write task was interrupted. The org.jboss.mq trace is below. SOme of the messages are processed and some messages get this exception and this happens frequently.

Any Pointers

=========== org.jboss.mq TRACE =================

2006-03-17 15:01:50,081 TRACE [org.jboss.mq.security.SecurityManager] Checking authorize on subjectInfo: SubjectInfo {subject=Subject:
Principal: guest
Principal: Roles(members:j2ee,guest,john)
;principal=null;roles=Roles(members:j2ee,guest,john) for rolePrincipals [guest]
2006-03-17 15:01:50,081 TRACE [org.jboss.mq.SpySession] Setting current tx xid=XidImpl[FormatId=257, GlobalId=qa002.xactlycorporation.local/19, BranchQual=1, localId=19] previous: -9223372036854775807 SpySession@71422899[tx=true txid=-9223372036854775807 XA RUNNING connection=Connection@71415237[token=ConnectionToken:ID:1/e4e91529d5b749c3775aef1d33f85ce0 rcvstate=STARTED]]
2006-03-17 15:01:50,081 TRACE [org.jboss.mq.server.BasicQueue] receive Subscription[subId=-2147483648connection=ConnectionToken:ID:1/e4e91529d5b749c3775aef1d33f85ce0 destination=QUEUE.XICMInbound messageSelector=null Local Create] wait=true org.jboss.mq.server.PersistentQueue@41628d9{id=QUEUE.XICMInbound}
2006-03-17 15:01:50,081 TRACE [org.jboss.jms.asf.StdServerSession] XAResource 'SpyXAResource[session=SpySession@71422899[tx=true txid=XidImpl[FormatId=257, GlobalId=qa002.xactlycorporation.local/19, BranchQual=1, localId=19] XA RUNNING connection=Connection@71415237[token=ConnectionToken:ID:1/e4e91529d5b749c3775aef1d33f85ce0 rcvstate=STARTED]]]' enlisted.
2006-03-17 15:01:50,081 TRACE [org.jboss.mq.server.BasicQueue] addReceiver Subscription[subId=-2147483648connection=ConnectionToken:ID:1/e4e91529d5b749c3775aef1d33f85ce0 destination=QUEUE.XICMInbound messageSelector=null Local Create] org.jboss.mq.server.PersistentQueue@41628d9{id=QUEUE.XICMInbound}
2006-03-17 15:01:50,081 TRACE [org.jboss.mq.server.TracingInterceptor] RETURN : receive
2006-03-17 15:01:50,081 TRACE [org.jboss.ejb.plugins.jms.JMSContainerInvoker] processing message: org.jboss.mq.SpyMapMessage {
Header {
jmsDestination : QUEUE.XICMInbound
jmsDeliveryMode : 2
jmsExpiration : 0
jmsPriority : 4
jmsMessageID : ID:6-11426365100761
jmsTimeStamp : 1142636510076
jmsCorrelationID: null
jmsReplyTo : null
jmsType : null
jmsRedelivered : false
jmsProperties : {}
jmsPropReadWrite: false
msgReadOnly : true
producerClientId: ID:6
}
}
2006-03-17 15:01:50,081 TRACE [org.jboss.mq.SpyConnectionConsumer] run() waiting for message SpyConnectionConsumer[sub=Subscription[subId=-2147483648connection=ConnectionToken:ID:1/e4e91529d5b749c3775aef1d33f85ce0 destination=QUEUE.XICMInbound messageSelector=null Local Create] messages=0 waitingForMessage=true internalThread=Thread[Connection Consumer for dest Subscription[subId=-2147483648connection=ConnectionToken:ID:1/e4e91529d5b749c3775aef1d33f85ce0 destination=QUEUE.XICMInbound messageSelector=null Local Create] id=1,5,jboss] sessionPool=org.jboss.jms.asf.StdServerSessionPool@43f435d connection=Connection@71415237[token=ConnectionToken:ID:1/e4e91529d5b749c3775aef1d33f85ce0 rcvstate=STARTED]]
2006-03-17 15:01:50,081 TRACE [org.jboss.mq.il.uil2.ServerSocketManagerHandler] Begin handleMsg, msgType: 14
2006-03-17 15:01:50,081 TRACE [org.jboss.mq.server.TracingInterceptor] CALLED : setEnabled
2006-03-17 15:01:50,081 TRACE [org.jboss.mq.server.TracingInterceptor] ARG : false
2006-03-17 15:01:50,081 TRACE [org.jboss.mq.server.ClientConsumer] ClientConsumer:ID:6->setEnabled(enabled=false)
2006-03-17 15:01:50,081 TRACE [org.jboss.mq.server.TracingInterceptor] RETURN : setEnabled
2006-03-17 15:01:50,081 TRACE [org.jboss.mq.il.uil2.SocketManager] Begin internalSendMessage, one-way msg=org.jboss.mq.il.uil2.msgs.EnableConnectionMsg67959739[msgType: m_setEnabled, msgID: -2147483633, error: null]
2006-03-17 15:01:50,081 TRACE [org.jboss.mq.il.uil2.SocketManager] End internalSendMessage, msg=org.jboss.mq.il.uil2.msgs.EnableConnectionMsg67959739[msgType: m_setEnabled, msgID: -2147483633, error: null]
2006-03-17 15:01:50,081 TRACE [org.jboss.mq.il.uil2.ServerSocketManagerHandler] End handleMsg, msgType: 14
2006-03-17 15:01:50,081 TRACE [org.jboss.mq.il.uil2.SocketManager] Write msg: org.jboss.mq.il.uil2.msgs.EnableConnectionMsg67959739[msgType: m_setEnabled, msgID: -2147483633, error: null]
2006-03-17 15:01:50,082 TRACE [org.jboss.mq.il.uil2.SocketManager] Read msgType: m_connectionClosing, msgID: -2147483632
2006-03-17 15:01:50,082 TRACE [org.jboss.mq.il.uil2.SocketManager] Read new msg: org.jboss.mq.il.uil2.msgs.CloseMsg67960225[msgType: m_connectionClosing, msgID: -2147483632, error: null]
2006-03-17 15:01:50,082 TRACE [org.jboss.mq.il.uil2.ServerSocketManagerHandler] Begin handleMsg, msgType: 5
2006-03-17 15:01:50,082 TRACE [org.jboss.mq.server.TracingInterceptor] CALLED : connectionClosing
2006-03-17 15:01:50,082 TRACE [org.jboss.mq.server.ClientConsumer] ClientConsumer:ID:6->close()
2006-03-17 15:01:50,082 TRACE [org.jboss.mq.sm.jdbc.JDBCStateManager] Client id 'ID:6' is logged out.
2006-03-17 15:01:50,082 TRACE [org.jboss.mq.server.TracingInterceptor] RETURN : connectionClosing
2006-03-17 15:01:50,082 TRACE [org.jboss.mq.il.uil2.SocketManager] Begin internalSendMessage, one-way msg=org.jboss.mq.il.uil2.msgs.CloseMsg67960225[msgType: m_connectionClosing, msgID: -2147483632, error: null]
2006-03-17 15:01:50,082 TRACE [org.jboss.mq.il.uil2.SocketManager] End internalSendMessage, msg=org.jboss.mq.il.uil2.msgs.CloseMsg67960225[msgType: m_connectionClosing, msgID: -2147483632, error: null]
2006-03-17 15:01:50,082 TRACE [org.jboss.mq.il.uil2.SocketManager] Write msg: org.jboss.mq.il.uil2.msgs.CloseMsg67960225[msgType: m_connectionClosing, msgID: -2147483632, error: null]
2006-03-17 15:01:50,082 TRACE [org.jboss.mq.il.uil2.ServerSocketManagerHandler] End handleMsg, msgType: 5
2006-03-17 15:01:50,082 TRACE [org.jboss.mq.il.uil2.SocketManager] WriteTask was interrupted
java.lang.InterruptedException
at EDU.oswego.cs.dl.util.concurrent.LinkedQueue.take(LinkedQueue.java:106)
at org.jboss.mq.il.uil2.SocketManager$WriteTask.run(SocketManager.java:492)
at java.lang.Thread.run()V(Unknown Source)
2006-03-17 15:01:50,082 DEBUG [org.jboss.mq.il.uil2.SocketManager] End WriteTask.run
2006-03-17 15:01:50,082 TRACE [org.jboss.mq.il.uil2.SocketManager] Exiting on IOE
java.net.SocketException: Socket closed
at jrockit.net.SocketNativeIO.read(Ljava.io.FileDescriptor;III)I(Unknown Source)
at java.net.AbstractSocketImpl$1.read(II)I(Unknown Source)
at jrockit.io.NativeIOInputStream.read(I[BI)I(Unknown Source)
at jrockit.io.NativeIOInputStream.read([BII)I(Unknown Source)
at java.io.BufferedInputStream.fill(BufferedInputStream.java:218)
at java.io.BufferedInputStream.read(BufferedInputStream.java:235)
at org.jboss.util.stream.NotifyingBufferedInputStream.read(NotifyingBufferedInputStream.java:67)
at java.io.ObjectInputStream$PeekInputStream.peek()I(Unknown Source)
at java.io.ObjectInputStream$BlockDataInputStream.readBlockHeader(Z)I(Unknown Source)
at java.io.ObjectInputStream$BlockDataInputStream.refill()V(Unknown Source)
at java.io.ObjectInputStream$BlockDataInputStream.read()I(Unknown Source)
at java.io.ObjectInputStream$BlockDataInputStream.readByte()B(Unknown Source)
at java.io.ObjectInputStream.readByte()B(Unknown Source)
at org.jboss.mq.il.uil2.SocketManager$ReadTask.run(SocketManager.java:290)
at java.lang.Thread.run()V(Unknown Source)
2006-03-17 15:01:50,082 DEBUG [org.jboss.mq.il.uil2.ServerSocketManagerHandler] Exiting on IOE
java.net.SocketException: Socket closed
at jrockit.net.SocketNativeIO.read(Ljava.io.FileDescriptor;III)I(Unknown Source)
at java.net.AbstractSocketImpl$1.read(II)I(Unknown Source)
at jrockit.io.NativeIOInputStream.read(I[BI)I(Unknown Source)
at jrockit.io.NativeIOInputStream.read([BII)I(Unknown Source)
at java.io.BufferedInputStream.fill(BufferedInputStream.java:218)
at java.io.BufferedInputStream.read(BufferedInputStream.java:235)
at org.jboss.util.stream.NotifyingBufferedInputStream.read(NotifyingBufferedInputStream.java:67)
at java.io.ObjectInputStream$PeekInputStream.peek()I(Unknown Source)
at java.io.ObjectInputStream$BlockDataInputStream.readBlockHeader(Z)I(Unknown Source)
at java.io.ObjectInputStream$BlockDataInputStream.refill()V(Unknown Source)
at java.io.ObjectInputStream$BlockDataInputStream.read()I(Unknown Source)
at java.io.ObjectInputStream$BlockDataInputStream.readByte()B(Unknown Source)
at java.io.ObjectInputStream.readByte()B(Unknown Source)
at org.jboss.mq.il.uil2.SocketManager$ReadTask.run(SocketManager.java:290)
at java.lang.Thread.run()V(Unknown Source)
2006-03-17 15:01:50,083 DEBUG [org.jboss.mq.il.uil2.SocketManager] End ReadTask.run
2006-03-17 15:01:50,084 DEBUG [org.jboss.mq.referenceable.SpyConnectionFactoryObjectFactory] Extracting SpyConnectionFactory from reference
2006-03-17 15:01:50,084 DEBUG [org.jboss.mq.referenceable.SpyConnectionFactoryObjectFactory] The GenericConnectionFactory is: GenericConnectionFactory[server=org.jboss.mq.il.uil2.UILServerIL@40f531e connectionProperties={UIL_PORT_KEY=8293, ClientILService=org.jboss.mq.il.uil2.UILClientILService, UIL_ADDRESS_KEY=192.168.1.118, UIL_TCPNODELAY_KEY=yes, PingPeriod=60000, UIL_CHUNKSIZE_KEY=1000000, UIL_RECEIVE_REPLIES_KEY=No, UIL_BUFFERSIZE_KEY=2048}]
2006-03-17 15:01:50,084 DEBUG [org.jboss.mq.referenceable.SpyDestinationObjectFactory] SpyDestinationObjectFactory->getObjectInstance()
2006-03-17 15:01:50,084 TRACE [org.jboss.mq.Connection] Connection Initializing userName=null Connection@67889021[clientID=null rcvstate=STOPPED]
2006-03-17 15:01:50,084 TRACE [org.jboss.mq.Connection] Getting the serverIL Connection@67889021[clientID=null rcvstate=STOPPED]
2006-03-17 15:01:50,084 TRACE [org.jboss.mq.Connection] serverIL=org.jboss.mq.il.uil2.UILServerIL@40e4686 Connection@67889021[clientID=null rcvstate=STOPPED]
2006-03-17 15:01:50,085 TRACE [org.jboss.mq.Connection] Authenticating user null Connection@67889021[clientID=null rcvstate=STOPPED]
2006-03-17 15:01:50,085 TRACE [org.jboss.mq.il.uil2.UILServerIL] Connecting to : qa002.xactlycorporation.local/192.168.1.118:8293
2006-03-17 15:01:50,085 TRACE [org.jboss.mq.il.uil2.UILServerIL] Connecting with addr=192.168.1.118, port=8293, localAddr=null, localPort=0, socketFactory=javax.net.DefaultSocketFactory@4107b69, enableTcpNoDelay=true, bufferSize=2048, chunkSize=1000000
2006-03-17 15:01:50,085 TRACE [org.jboss.mq.il.uil2.UILServerIL] Begin connect loop, maxRetries=10, delay=0
2006-03-17 15:01:50,085 TRACE [org.jboss.mq.il.uil2.SocketManager] start called
java.lang.Exception: Start stack trace
at org.jboss.mq.il.uil2.SocketManager.start(SocketManager.java:96)
at org.jboss.mq.il.uil2.UILServerIL.createConnection(UILServerIL.java:666)
at org.jboss.mq.il.uil2.UILServerIL.getSocketMgr(UILServerIL.java:532)
at org.jboss.mq.il.uil2.UILServerIL.authenticate(UILServerIL.java:334)
at org.jboss.mq.Connection.authenticate(Connection.java:1114)
at org.jboss.mq.Connection.(Connection.java:267)
at org.jboss.mq.Connection.(Connection.java:338)
at org.jboss.mq.SpyConnection.(SpyConnection.java:68)
at org.jboss.mq.SpyConnectionFactory.createConnection(SpyConnectionFactory.java:87)
at org.jboss.mq.SpyConnectionFactory.createQueueConnection(SpyConnectionFactory.java:124)
at com.xactly.xmsgbus.properties.XMsgBusPropertyManager.sendICMOrderMessage(XMsgBusPropertyManager.java:118)

1. Re: java.lang.InterruptedException when sending messages

genman Mar 17, 2006 11:07 PM (in response to vasu_suku)

You don't think it's one of your own threads doing Thread.interrupt()?
Actions
2. Re: java.lang.InterruptedException when sending messages

vasu_suku Mar 18, 2006 4:09 PM (in response to vasu_suku)

Nope. I use JBOSS-4.0.2 and run in Jrockit JDK 1.5_03 on a Linux Box. The same code runs fine in some of the boxes and in some m/c I always seem to get this error. I rebooted those m/c and still it happens. What is the recommended kernel parameters to be set.
Actions
3. Re: java.lang.InterruptedException when sending messages

adrian.brock Mar 21, 2006 1:45 PM (in response to vasu_suku)

Frequent misunderstanding.
Where does it say ERROR?

The interruption is due to the close() to break out of socket I/O
Actions

Go to original post