Hi,
I got an exception when i try to publish data via
LoadBalancingDataPublisher.
[2015-01-20 13:22:55,948] INFO
{org.wso2.carbon.databridge.agent.thrift.lb.ReceiverGroup} - Resending the
failed published data...
[2015-01-20 13:22:55,948] ERROR
{org.wso2.carbon.databridge.agent.thrift.AsyncDataPublisher} -
java.util.concurrent.RejectedExecutionException
at
java.util.concurrent.ThreadPoolExecutor$AbortPolicy.rejectedExecution(ThreadPoolExecutor.java:1768)
at
java.util.concurrent.ThreadPoolExecutor.reject(ThreadPoolExecutor.java:767)
at
java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:658)
at
java.util.concurrent.AbstractExecutorService.submit(AbstractExecutorService.java:78)
at
java.util.concurrent.Executors$DelegatedExecutorService.submit(Executors.java:600)
at
org.wso2.carbon.databridge.agent.thrift.AsyncDataPublisher.publish(AsyncDataPublisher.java:476)
at
org.wso2.carbon.databridge.agent.thrift.lb.ReceiverGroup.publish(ReceiverGroup.java:151)
at
org.wso2.carbon.databridge.agent.thrift.lb.ReceiverGroup.resendPublishedData(ReceiverGroup.java:255)
at
org.wso2.carbon.databridge.agent.thrift.lb.ReceiverGroup.notifyConnectionSuccess(ReceiverGroup.java:271)
at
org.wso2.carbon.databridge.agent.thrift.AsyncDataPublisher$ReceiverConnectionWorker.run(AsyncDataPublisher.java:794)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:441)
at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
at java.util.concurrent.FutureTask.run(FutureTask.java:138)
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)
Note that i followed this[1]
<https://mohanadarshan.wordpress.com/2013/05/04/load-balancing-data-publisher-to-bamcep-example-code/>
blog as a sample and developed in a jaggery application.
Thanks
[1]
https://mohanadarshan.wordpress.com/2013/05/04/load-balancing-data-publisher-to-bamcep-example-code/
--
*Yashira Perera*
*Software Engineer *
*WSO2, Inc : * http://wso2.com
lean.enterprise.middleware
Mobile: +9471 716 6797
_______________________________________________
Dev mailing list
[email protected]
http://wso2.org/cgi-bin/mailman/listinfo/dev
