Moving to dev@
Suho
On Jul 17, 2014 9:27 AM, "Senduran Balasubramaniyam" <sendu...@wso2.com>
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 <
> sendu...@wso2.com> wrote:
>
>> Thanks you Dilini
>> we'll try this and let you know
>>
>>
>>
>> On Mon, Jul 14, 2014 at 4:05 PM, Dilini Muthumala <dil...@wso2.com>
>> 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 <
>>> sendu...@wso2.com> 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 <dil...@wso2.com>
>>>> 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 <
>>>>> sendu...@wso2.com> 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 <dil...@wso2.com>
>>>>>> 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 <dil...@wso2.com>
>>>>>>> wrote:
>>>>>>>
>>>>>>>>
>>>>>>>>
>>>>>>>>
>>>>>>>> On Fri, Jul 11, 2014 at 11:53 AM, Dilini Muthumala <dil...@wso2.com
>>>>>>>> > 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 :* dil...@wso2.com
>>>>>>>>> *Mobile: *+94713 400 029
>>>>>>>>>
>>>>>>>>
>>>>>>>>
>>>>>>>>
>>>>>>>> --
>>>>>>>> *Dilini Muthumala*
>>>>>>>> Software Engineer,
>>>>>>>> WSO2 Inc.
>>>>>>>>
>>>>>>>> *E-mail :* dil...@wso2.com
>>>>>>>> *Mobile: *+94713 400 029
>>>>>>>>
>>>>>>>
>>>>>>>
>>>>>>>
>>>>>>> --
>>>>>>> *Dilini Muthumala*
>>>>>>> Software Engineer,
>>>>>>> WSO2 Inc.
>>>>>>>
>>>>>>> *E-mail :* dil...@wso2.com
>>>>>>> *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 :* dil...@wso2.com
>>>>> *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 :* dil...@wso2.com
>>> *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
>
_______________________________________________
Dev mailing list
Dev@wso2.org
http://wso2.org/cgi-bin/mailman/listinfo/dev
