AnsweredAssumed Answered

Anyone received the error "java.lang.IllegalStateException: Could not add message to batch queue due to interruption"

Question asked by RakheshGopalakrishnan6111 on Jun 24, 2013
Latest reply on Jun 25, 2013 by James Ahlborn
We have a process that creates/updates worker records in Taleo. In prod, for the initial full run we have around 5493 records.
But the scheduled run failed with following error:

java.lang.IllegalStateException: Could not add message to batch queue due to interruption
at com.boomi.queue.SimpleMessageQueueStorer$BatchTaskGenerator.generateTasks(SimpleMessageQueueStorer.java:305)
at com.boomi.queue.SimpleMessageQueueStorer.queueMessagesImpl(SimpleMessageQueueStorer.java:166)
at com.boomi.queue.SimpleMessageQueueStorer.queueMessages(SimpleMessageQueueStorer.java:153)
at com.boomi.queue.SimpleMessageQueueStorer.queueMessages(SimpleMessageQueueStorer.java:134)
at com.boomi.queue.SimpleMessageQueue.queueMessages(SimpleMessageQueue.java:115)
at com.boomi.process.util.NormalProcessMessenger.sendConnectorTrackMessages(NormalProcessMessenger.java:95)
at com.boomi.process.shape.BaseConnectorTracker.flushPending(BaseConnectorTracker.java:364)
at com.boomi.process.shape.ConnectorShapeHandler.flushPending(ConnectorShapeHandler.java:241)
at com.boomi.process.shape.StartShape.flushPending(StartShape.java:59)
at com.boomi.process.graph.ProcessGraph.flushDocStatuses(ProcessGraph.java:634)
at com.boomi.process.graph.ProcessGraph.handleRecentlyBlacklistedDocs(ProcessGraph.java:617)
at com.boomi.process.graph.ProcessGraph.executeNextShapes(ProcessGraph.java:514)
at com.boomi.process.graph.ProcessGraph.executeShape(ProcessGraph.java:497)
at com.boomi.process.graph.ProcessGraph.executeNextShapes(ProcessGraph.java:560)
at com.boomi.process.graph.ProcessGraph.executeShape(ProcessGraph.java:497)
at com.boomi.process.graph.ProcessGraph.executeNextShapes(ProcessGraph.java:560)
at com.boomi.process.graph.ProcessGraph.execute(ProcessGraph.java:306)
at com.boomi.process.ProcessExecution.call(ProcessExecution.java:768)
at com.boomi.execution.ExecutionTask.call(ExecutionTask.java:886)
at com.boomi.execution.ExecutionTask.call(ExecutionTask.java:60)
at com.boomi.util.concurrent.CancellableFutureTask.run(CancellableFutureTask.java:163)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
at java.lang.Thread.run(Thread.java:662)
Caused by: java.lang.InterruptedException
at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireInterruptibly(AbstractQueuedSynchronizer.java:1199)
at java.util.concurrent.locks.ReentrantLock.lockInterruptibly(ReentrantLock.java:312)
at java.util.concurrent.LinkedBlockingQueue.offer(LinkedBlockingQueue.java:336)
at com.boomi.queue.SimpleMessageQueueStorer$BatchTaskGenerator$PartialBatch.offer(SimpleMessageQueueStorer.java:417)
at com.boomi.queue.SimpleMessageQueueStorer$BatchTaskGenerator.generateTasks(SimpleMessageQueueStorer.java:281)
... 23 more


     I suspect if this is due to the huge number of records and going to try splitting into small chunks. But before doing that, want to check if anyone received this error before and has a better idea in mind. 

     Thanks
     Rakhesh

Outcomes