Hi, Are you calling stop() in the data publisher? Looks like data publisher is stopped and then you are trying to publish. To narrow down the issue, can you please remove the stop() method and retry ? Also please share your source code as well to check further.
Thanks, Sinthuja On Tue, Jan 20, 2015 at 1:26 PM, Yashira Perera <[email protected]> wrote: > 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 > -- *Sinthuja Rajendran* Senior Software Engineer <http://wso2.com/> WSO2, Inc.:http://wso2.com Blog: http://sinthu-rajan.blogspot.com/ Mobile: +94774273955
_______________________________________________ Dev mailing list [email protected] http://wso2.org/cgi-bin/mailman/listinfo/dev
