@ Dilini please provide the adaptor that uses tomcat websocket Suho
On Thu, Jul 17, 2014 at 10:56 AM, Sriskandarajah Suhothayan <[email protected]> wrote: > Moving to dev@ > > Suho > On Jul 17, 2014 9:27 AM, "Senduran Balasubramaniyam" <[email protected]> > wrote: > >> Hi Dilini, >> When we use the new jar you us we are getting the following exception but >> still the message is received at the client side >> >> ERROR - {EventJunction} Error while dispatching events >> java.lang.NullPointerException >> at >> org.wso2.carbon.event.output.adaptor.websocket.WebsocketEventAdaptor.publish(WebsocketEventAdaptor.java:85) >> at >> org.wso2.carbon.event.output.adaptor.core.AbstractOutputEventAdaptor.publishCall(AbstractOutputEventAdaptor.java:123) >> at >> org.wso2.carbon.event.output.adaptor.core.internal.CarbonOutputEventAdaptorService.publish(CarbonOutputEventAdaptorService.java:89) >> at >> org.wso2.carbon.event.formatter.core.config.EventFormatter.sendEventData(EventFormatter.java:160) >> at >> org.wso2.carbon.event.formatter.core.config.EventFormatter.consumeEventData(EventFormatter.java:210) >> at >> org.wso2.carbon.event.stream.manager.core.internal.stream.EventJunction.sendEvents(EventJunction.java:225) >> at >> org.wso2.carbon.event.processor.core.internal.listener.SiddhiOutputStreamListener.receive(SiddhiOutputStreamListener.java:78) >> at >> org.wso2.siddhi.core.stream.output.StreamCallback.send(StreamCallback.java:83) >> at >> org.wso2.siddhi.core.stream.output.StreamCallback.receive(StreamCallback.java:56) >> at >> org.wso2.siddhi.core.stream.StreamJunction.send(StreamJunction.java:45) >> at >> org.wso2.siddhi.core.query.output.callback.InsertIntoStreamCallback.send(InsertIntoStreamCallback.java:35) >> at >> org.wso2.siddhi.core.query.output.ratelimit.OutputRateManager.sendToCallBacks(OutputRateManager.java:38) >> at >> org.wso2.siddhi.core.query.output.ratelimit.PassThroughOutputRateManager.send(PassThroughOutputRateManager.java:26) >> at >> org.wso2.siddhi.core.query.selector.QuerySelector.process(QuerySelector.java:221) >> at >> org.wso2.siddhi.core.query.processor.window.TimeWindowProcessor.processEvent(TimeWindowProcessor.java:62) >> at >> org.wso2.siddhi.core.query.processor.window.WindowProcessor.process(WindowProcessor.java:71) >> at >> org.wso2.siddhi.core.query.processor.handler.SimpleHandlerProcessor.processHandler(SimpleHandlerProcessor.java:149) >> at >> org.wso2.siddhi.core.query.processor.handler.SimpleHandlerProcessor.receive(SimpleHandlerProcessor.java:77) >> at org.wso2.siddhi.core.stream.StreamJunction.send(StreamJunction.java:45) >> at >> org.wso2.siddhi.core.stream.input.InputHandler.send(InputHandler.java:41) >> at >> org.wso2.carbon.event.processor.core.internal.listener.SiddhiInputEventDispatcher.sendEvent(SiddhiInputEventDispatcher.java:107) >> at >> org.wso2.carbon.event.processor.core.internal.listener.SiddhiInputEventDispatcher.consumeEvents(SiddhiInputEventDispatcher.java:78) >> at >> org.wso2.carbon.event.stream.manager.core.internal.stream.EventJunction.sendEvents(EventJunction.java:214) >> at >> org.wso2.carbon.event.processor.core.internal.listener.SiddhiOutputStreamListener.receive(SiddhiOutputStreamListener.java:78) >> at >> org.wso2.siddhi.core.stream.output.StreamCallback.send(StreamCallback.java:83) >> at >> org.wso2.siddhi.core.stream.output.StreamCallback.receive(StreamCallback.java:56) >> at org.wso2.siddhi.core.stream.StreamJunction.send(StreamJunction.java:45) >> at >> org.wso2.siddhi.core.query.output.callback.InsertIntoStreamCallback.send(InsertIntoStreamCallback.java:35) >> at >> org.wso2.siddhi.core.query.output.ratelimit.OutputRateManager.sendToCallBacks(OutputRateManager.java:38) >> at >> org.wso2.siddhi.core.query.output.ratelimit.PassThroughOutputRateManager.send(PassThroughOutputRateManager.java:26) >> at >> org.wso2.siddhi.core.query.selector.QuerySelector.process(QuerySelector.java:221) >> at >> org.wso2.siddhi.core.query.processor.handler.SimpleHandlerProcessor.processHandler(SimpleHandlerProcessor.java:149) >> at >> org.wso2.siddhi.core.query.processor.handler.SimpleHandlerProcessor.receive(SimpleHandlerProcessor.java:77) >> at >> org.wso2.siddhi.core.stream.StreamJunction.send(StreamJunction.java:45) >> at >> org.wso2.siddhi.core.stream.input.InputHandler.send(InputHandler.java:41) >> at >> org.wso2.carbon.event.processor.core.internal.listener.SiddhiInputEventDispatcher.sendEvent(SiddhiInputEventDispatcher.java:107) >> at >> org.wso2.carbon.event.processor.core.internal.listener.SiddhiInputEventDispatcher.consumeEventData(SiddhiInputEventDispatcher.java:95) >> at >> org.wso2.carbon.event.stream.manager.core.internal.stream.EventJunction.sendEventData(EventJunction.java:139) >> at >> org.wso2.carbon.event.builder.core.internal.EventBuilder.sendEvent(EventBuilder.java:247) >> at >> org.wso2.carbon.event.builder.core.internal.EventBuilder.processTypedEvent(EventBuilder.java:233) >> at >> org.wso2.carbon.event.builder.core.internal.EventBuilder$TypedEventListenerImpl.onEvent(EventBuilder.java:320) >> at >> org.wso2.carbon.event.input.adaptor.core.InputEventAdaptorListener.onEventCall(InputEventAdaptorListener.java:98) >> at >> org.wso2.carbon.event.input.adaptor.wso2event.WSO2EventEventAdaptorType$AgentTransportCallback.receive(WSO2EventEventAdaptorType.java:266) >> at >> org.wso2.carbon.databridge.core.internal.queue.QueueWorker.run(QueueWorker.java:81) >> at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471) >> at java.util.concurrent.FutureTask.run(FutureTask.java:262) >> at >> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145) >> at >> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) >> at java.lang.Thread.run(Thread.java:745) >> >> Can you please check when you get time >> >> Thanks >> Senduran >> >> >> >> >> >> On Mon, Jul 14, 2014 at 4:42 PM, Senduran Balasubramaniyam < >> [email protected]> wrote: >> >>> Thanks you Dilini >>> we'll try this and let you know >>> >>> >>> >>> On Mon, Jul 14, 2014 at 4:05 PM, Dilini Muthumala <[email protected]> >>> wrote: >>> >>>> Hi Senduran, >>>> >>>> Suggesting a fix to error-1: >>>> >>>> Can you replace the >>>> *org.wso2.carbon.event.output.adaptor.websocket-2.0.0-SNAPSHOT.jar* >>>> I've sent before with the attached one, pls? >>>> >>>> I've put a non-blocking send instead of a blocking send, when sending >>>> events to the clients. We'll see if this would work. >>>> >>>> Thanks, >>>> Dilini >>>> >>>> >>>> On Mon, Jul 14, 2014 at 3:44 PM, Senduran Balasubramaniyam < >>>> [email protected]> wrote: >>>> >>>>> Hi Dilini, >>>>> This is not very urgent, but will be helpful if we can find a fix. >>>>> In the both cases client is getting messages (so can proceed) >>>>> >>>>> Regards >>>>> Senduran >>>>> >>>>> >>>>> On Mon, Jul 14, 2014 at 3:38 PM, Dilini Muthumala <[email protected]> >>>>> wrote: >>>>> >>>>>> Hi Senduran, >>>>>> >>>>>> Thanks for letting me know these. I'll check this ASAP. Please let me >>>>>> know how urgent this is to you two. >>>>>> >>>>>> What happens after you get first error? Client(s) does not get any >>>>>> messages there onward? >>>>>> >>>>>> Thanks, >>>>>> Dilini >>>>>> >>>>>> >>>>>> On Mon, Jul 14, 2014 at 3:26 PM, Senduran Balasubramaniyam < >>>>>> [email protected]> wrote: >>>>>> >>>>>>> Hi Dilini, >>>>>>> >>>>>>> While we are using the websocket we are getting two errors >>>>>>> 1. random error >>>>>>> [2014-07-14 15:03:41,191] ERROR - {EventJunction} Error while >>>>>>> dispatching events >>>>>>> java.lang.IllegalStateException: Blocking message pending 10000 for >>>>>>> BLOCKING >>>>>>> at >>>>>>> org.eclipse.jetty.websocket.common.WebSocketRemoteEndpoint.lockMsg(WebSocketRemoteEndpoint.java:130) >>>>>>> at >>>>>>> org.eclipse.jetty.websocket.common.WebSocketRemoteEndpoint.sendString(WebSocketRemoteEndpoint.java:379) >>>>>>> at >>>>>>> org.wso2.carbon.event.output.adaptor.websocket.WebsocketEventAdaptor.publish(WebsocketEventAdaptor.java:87) >>>>>>> at >>>>>>> org.wso2.carbon.event.output.adaptor.core.AbstractOutputEventAdaptor.publishCall(AbstractOutputEventAdaptor.java:123) >>>>>>> at >>>>>>> org.wso2.carbon.event.output.adaptor.core.internal.CarbonOutputEventAdaptorService.publish(CarbonOutputEventAdaptorService.java:89) >>>>>>> at >>>>>>> org.wso2.carbon.event.formatter.core.config.EventFormatter.sendEventData(EventFormatter.java:160) >>>>>>> at >>>>>>> org.wso2.carbon.event.formatter.core.config.EventFormatter.consumeEventData(EventFormatter.java:210) >>>>>>> at >>>>>>> org.wso2.carbon.event.stream.manager.core.internal.stream.EventJunction.sendEvents(EventJunction.java:225) >>>>>>> at >>>>>>> org.wso2.carbon.event.processor.core.internal.listener.SiddhiOutputStreamListener.receive(SiddhiOutputStreamListener.java:78) >>>>>>> at >>>>>>> org.wso2.siddhi.core.stream.output.StreamCallback.send(StreamCallback.java:83) >>>>>>> at >>>>>>> org.wso2.siddhi.core.stream.output.StreamCallback.receive(StreamCallback.java:56) >>>>>>> at >>>>>>> org.wso2.siddhi.core.stream.StreamJunction.send(StreamJunction.java:45) >>>>>>> at >>>>>>> org.wso2.siddhi.core.query.output.callback.InsertIntoStreamCallback.send(InsertIntoStreamCallback.java:35) >>>>>>> at >>>>>>> org.wso2.siddhi.core.query.output.ratelimit.OutputRateManager.sendToCallBacks(OutputRateManager.java:38) >>>>>>> at >>>>>>> org.wso2.siddhi.core.query.output.ratelimit.PassThroughOutputRateManager.send(PassThroughOutputRateManager.java:26) >>>>>>> at >>>>>>> org.wso2.siddhi.core.query.selector.QuerySelector.process(QuerySelector.java:221) >>>>>>> at >>>>>>> org.wso2.siddhi.core.query.processor.handler.SimpleHandlerProcessor.processHandler(SimpleHandlerProcessor.java:149) >>>>>>> at >>>>>>> org.wso2.siddhi.core.query.processor.handler.SimpleHandlerProcessor.receive(SimpleHandlerProcessor.java:77) >>>>>>> at >>>>>>> org.wso2.siddhi.core.stream.StreamJunction.send(StreamJunction.java:45) >>>>>>> at >>>>>>> org.wso2.siddhi.core.stream.input.InputHandler.send(InputHandler.java:41) >>>>>>> at >>>>>>> org.wso2.carbon.event.processor.core.internal.listener.SiddhiInputEventDispatcher.sendEvent(SiddhiInputEventDispatcher.java:107) >>>>>>> at >>>>>>> org.wso2.carbon.event.processor.core.internal.listener.SiddhiInputEventDispatcher.consumeEventData(SiddhiInputEventDispatcher.java:95) >>>>>>> at >>>>>>> org.wso2.carbon.event.stream.manager.core.internal.stream.EventJunction.sendEventData(EventJunction.java:139) >>>>>>> at >>>>>>> org.wso2.carbon.event.builder.core.internal.EventBuilder.sendEvent(EventBuilder.java:247) >>>>>>> at >>>>>>> org.wso2.carbon.event.builder.core.internal.EventBuilder.processTypedEvent(EventBuilder.java:233) >>>>>>> at >>>>>>> org.wso2.carbon.event.builder.core.internal.EventBuilder$TypedEventListenerImpl.onEvent(EventBuilder.java:320) >>>>>>> at >>>>>>> org.wso2.carbon.event.input.adaptor.core.InputEventAdaptorListener.onEventCall(InputEventAdaptorListener.java:98) >>>>>>> at >>>>>>> org.wso2.carbon.event.input.adaptor.wso2event.WSO2EventEventAdaptorType$AgentTransportCallback.receive(WSO2EventEventAdaptorType.java:266) >>>>>>> at >>>>>>> org.wso2.carbon.databridge.core.internal.queue.QueueWorker.run(QueueWorker.java:81) >>>>>>> at >>>>>>> java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471) >>>>>>> at java.util.concurrent.FutureTask.run(FutureTask.java:262) >>>>>>> at >>>>>>> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145) >>>>>>> at >>>>>>> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) >>>>>>> at java.lang.Thread.run(Thread.java:745) >>>>>>> >>>>>>> >>>>>>> 2. occurs when the client connection closed. >>>>>>> >>>>>>> ----------------------------------------------------------------------------------------- >>>>>>> java.io.IOException: Connection output is closed >>>>>>> at >>>>>>> org.eclipse.jetty.websocket.common.io.IOState.assertOutputOpen(IOState.java:133) >>>>>>> at >>>>>>> org.eclipse.jetty.websocket.common.WebSocketRemoteEndpoint.uncheckedSendFrame(WebSocketRemoteEndpoint.java:303) >>>>>>> at >>>>>>> org.eclipse.jetty.websocket.common.WebSocketRemoteEndpoint.blockingWrite(WebSocketRemoteEndpoint.java:106) >>>>>>> at >>>>>>> org.eclipse.jetty.websocket.common.WebSocketRemoteEndpoint.sendString(WebSocketRemoteEndpoint.java:387) >>>>>>> at >>>>>>> org.wso2.carbon.event.output.adaptor.websocket.WebsocketEventAdaptor.publish(WebsocketEventAdaptor.java:87) >>>>>>> at >>>>>>> org.wso2.carbon.event.output.adaptor.core.AbstractOutputEventAdaptor.publishCall(AbstractOutputEventAdaptor.java:123) >>>>>>> at >>>>>>> org.wso2.carbon.event.output.adaptor.core.internal.CarbonOutputEventAdaptorService.publish(CarbonOutputEventAdaptorService.java:89) >>>>>>> at >>>>>>> org.wso2.carbon.event.formatter.core.config.EventFormatter.sendEventData(EventFormatter.java:160) >>>>>>> at >>>>>>> org.wso2.carbon.event.formatter.core.config.EventFormatter.consumeEventData(EventFormatter.java:210) >>>>>>> at >>>>>>> org.wso2.carbon.event.stream.manager.core.internal.stream.EventJunction.sendEvents(EventJunction.java:225) >>>>>>> at >>>>>>> org.wso2.carbon.event.processor.core.internal.listener.SiddhiOutputStreamListener.receive(SiddhiOutputStreamListener.java:78) >>>>>>> at >>>>>>> org.wso2.siddhi.core.stream.output.StreamCallback.send(StreamCallback.java:83) >>>>>>> at >>>>>>> org.wso2.siddhi.core.stream.output.StreamCallback.receive(StreamCallback.java:56) >>>>>>> at >>>>>>> org.wso2.siddhi.core.stream.StreamJunction.send(StreamJunction.java:45) >>>>>>> at >>>>>>> org.wso2.siddhi.core.query.output.callback.InsertIntoStreamCallback.send(InsertIntoStreamCallback.java:35) >>>>>>> at >>>>>>> org.wso2.siddhi.core.query.output.ratelimit.OutputRateManager.sendToCallBacks(OutputRateManager.java:38) >>>>>>> at >>>>>>> org.wso2.siddhi.core.query.output.ratelimit.PassThroughOutputRateManager.send(PassThroughOutputRateManager.java:26) >>>>>>> at >>>>>>> org.wso2.siddhi.core.query.selector.QuerySelector.process(QuerySelector.java:221) >>>>>>> at >>>>>>> org.wso2.siddhi.core.query.processor.handler.SimpleHandlerProcessor.processHandler(SimpleHandlerProcessor.java:149) >>>>>>> at >>>>>>> org.wso2.siddhi.core.query.processor.handler.SimpleHandlerProcessor.receive(SimpleHandlerProcessor.java:77) >>>>>>> at >>>>>>> org.wso2.siddhi.core.stream.StreamJunction.send(StreamJunction.java:45) >>>>>>> at >>>>>>> org.wso2.siddhi.core.stream.input.InputHandler.send(InputHandler.java:41) >>>>>>> at >>>>>>> org.wso2.carbon.event.processor.core.internal.listener.SiddhiInputEventDispatcher.sendEvent(SiddhiInputEventDispatcher.java:107) >>>>>>> at >>>>>>> org.wso2.carbon.event.processor.core.internal.listener.SiddhiInputEventDispatcher.consumeEventData(SiddhiInputEventDispatcher.java:95) >>>>>>> at >>>>>>> org.wso2.carbon.event.stream.manager.core.internal.stream.EventJunction.sendEventData(EventJunction.java:139) >>>>>>> at >>>>>>> org.wso2.carbon.event.builder.core.internal.EventBuilder.sendEvent(EventBuilder.java:247) >>>>>>> at >>>>>>> org.wso2.carbon.event.builder.core.internal.EventBuilder.processTypedEvent(EventBuilder.java:233) >>>>>>> at >>>>>>> org.wso2.carbon.event.builder.core.internal.EventBuilder$TypedEventListenerImpl.onEvent(EventBuilder.java:320) >>>>>>> at >>>>>>> org.wso2.carbon.event.input.adaptor.core.InputEventAdaptorListener.onEventCall(InputEventAdaptorListener.java:98) >>>>>>> at >>>>>>> org.wso2.carbon.event.input.adaptor.wso2event.WSO2EventEventAdaptorType$AgentTransportCallback.receive(WSO2EventEventAdaptorType.java:266) >>>>>>> at >>>>>>> org.wso2.carbon.databridge.core.internal.queue.QueueWorker.run(QueueWorker.java:81) >>>>>>> at >>>>>>> java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471) >>>>>>> at java.util.concurrent.FutureTask.run(FutureTask.java:262) >>>>>>> at >>>>>>> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145) >>>>>>> at >>>>>>> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) >>>>>>> at java.lang.Thread.run(Thread.java:745) >>>>>>> >>>>>>> the 2nd exception is ok since we are closing the connection, but the >>>>>>> exception is keep printing even we open the client side. >>>>>>> >>>>>>> could you please look into this and assist us >>>>>>> >>>>>>> Thanks and Regards >>>>>>> >>>>>>> >>>>>>> >>>>>>> On Fri, Jul 11, 2014 at 2:51 PM, Dilini Muthumala <[email protected]> >>>>>>> wrote: >>>>>>> >>>>>>>> Hi Senduran & Danesh, >>>>>>>> >>>>>>>> Can you try with the new NLP-toolbox.zip attached? >>>>>>>> >>>>>>>> >>>>>>>> On Fri, Jul 11, 2014 at 12:26 PM, Dilini Muthumala <[email protected] >>>>>>>> > wrote: >>>>>>>> >>>>>>>>> >>>>>>>>> >>>>>>>>> >>>>>>>>> On Fri, Jul 11, 2014 at 11:53 AM, Dilini Muthumala < >>>>>>>>> [email protected]> wrote: >>>>>>>>> >>>>>>>>>> Hi, >>>>>>>>>> >>>>>>>>>> Extract the zip (NLP-toolbox.zip) and put the contents into >>>>>>>>>> CEP_HOME/repository/components/dropins. >>>>>>>>>> >>>>>>>>>> Restart the CEP server. Pls note that running this requires Java >>>>>>>>>> 7. >>>>>>>>>> >>>>>>>>>> Also, I've attached the Javascript client you can use to get >>>>>>>>>> events. >>>>>>>>>> >>>>>>>>>> Let me know if it works fine :-) >>>>>>>>>> >>>>>>>>>> Regards, >>>>>>>>>> Dilini >>>>>>>>>> >>>>>>>>>> -- >>>>>>>>>> *Dilini Muthumala* >>>>>>>>>> Software Engineer, >>>>>>>>>> WSO2 Inc. >>>>>>>>>> >>>>>>>>>> *E-mail :* [email protected] >>>>>>>>>> *Mobile: *+94713 400 029 >>>>>>>>>> >>>>>>>>> >>>>>>>>> >>>>>>>>> >>>>>>>>> -- >>>>>>>>> *Dilini Muthumala* >>>>>>>>> Software Engineer, >>>>>>>>> WSO2 Inc. >>>>>>>>> >>>>>>>>> *E-mail :* [email protected] >>>>>>>>> *Mobile: *+94713 400 029 >>>>>>>>> >>>>>>>> >>>>>>>> >>>>>>>> >>>>>>>> -- >>>>>>>> *Dilini Muthumala* >>>>>>>> Software Engineer, >>>>>>>> WSO2 Inc. >>>>>>>> >>>>>>>> *E-mail :* [email protected] >>>>>>>> *Mobile: *+94713 400 029 >>>>>>>> >>>>>>> >>>>>>> >>>>>>> >>>>>>> -- >>>>>>> *Senduran * >>>>>>> Software Engineer, >>>>>>> WSO2, Inc.; http://wso2.com/ <http://wso2.com/> >>>>>>> Mobile: +94 77 952 6548 >>>>>>> >>>>>> >>>>>> >>>>>> >>>>>> -- >>>>>> *Dilini Muthumala* >>>>>> Software Engineer, >>>>>> WSO2 Inc. >>>>>> >>>>>> *E-mail :* [email protected] >>>>>> *Mobile: *+94713 400 029 >>>>>> >>>>> >>>>> >>>>> >>>>> -- >>>>> *Senduran * >>>>> Software Engineer, >>>>> WSO2, Inc.; http://wso2.com/ <http://wso2.com/> >>>>> Mobile: +94 77 952 6548 >>>>> >>>> >>>> >>>> >>>> -- >>>> *Dilini Muthumala* >>>> Software Engineer, >>>> WSO2 Inc. >>>> >>>> *E-mail :* [email protected] >>>> *Mobile: *+94713 400 029 >>>> >>> >>> >>> >>> -- >>> *Senduran * >>> Software Engineer, >>> WSO2, Inc.; http://wso2.com/ <http://wso2.com/> >>> Mobile: +94 77 952 6548 >>> >> >> >> >> -- >> *Senduran * >> Software Engineer, >> WSO2, Inc.; http://wso2.com/ <http://wso2.com/> >> Mobile: +94 77 952 6548 >> > -- *S. Suhothayan* Technical Lead & Team Lead of WSO2 Complex Event Processor *WSO2 Inc. *http://wso2.com * <http://wso2.com/>* lean . enterprise . middleware *cell: (+94) 779 756 757 | blog: http://suhothayan.blogspot.com/ <http://suhothayan.blogspot.com/>twitter: http://twitter.com/suhothayan <http://twitter.com/suhothayan> | linked-in: http://lk.linkedin.com/in/suhothayan <http://lk.linkedin.com/in/suhothayan>*
_______________________________________________ Dev mailing list [email protected] http://wso2.org/cgi-bin/mailman/listinfo/dev
