Hi, It worked thanks.
On Tue, Jan 20, 2015 at 2:13 PM, Sinthuja Ragendran <[email protected]> wrote: > 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 > > > -- *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
