Re: [Dev] siddhi v2.2.0-SNAPSHOT stop calling callbacks after few seconds
Hi Lasantha, I have changed my storm topology. Now, all stream go to the same siddhiManager instance and all queries works fine. But now, I only have 1 instance of siddhiManager without distributed processing ... How can I get scalability??? Thanks, Andrés - -- Andres Gomez Developer at Eneo Tecnologia. Website: http://redborder.net LinkedIn: http://lnkd.in/sHnbJe -- View this message in context: http://wso2-oxygen-tank.10903.n7.nabble.com/siddhi-v2-2-0-SNAPSHOT-stop-calling-callbacks-after-few-seconds-tp103254p104350.html Sent from the WSO2 Development mailing list archive at Nabble.com. ___ Dev mailing list Dev@wso2.org http://wso2.org/cgi-bin/mailman/listinfo/dev
Re: [Dev] siddhi v2.2.0-SNAPSHOT stop calling callbacks after few seconds
Thanks for your help, Lasantha! -- Andres Gomez Developer at Eneo Tecnologia. Website: http://redborder.net LinkedIn: http://lnkd.in/sHnbJe En 3 de octubre de 2014 en 10:25:06, Lasantha Fernando [via WSO2 Oxygen Tank] (ml-node+s10903n104356...@n7.nabble.com) escrito: Hi Andrés, In your earlier query, it seems that you have a sequence with two predicates running on different threads/nodes. In such a case, synching between the two threads can be non-trivial AFAIK. However, you can try to scale first for other usecases (other than patterns, sequences). Different queries can be scaled in pipeline fashion, and also partitioning the input stream to scale might be another option. We are currently writing Siddhi 3.0.0 with more support for distributed cases. You can find the siddhi-3.0.0 branch at [1]. Please consider this as still 'Work in Progress'. However, let me dig deeper into your usecase and get back to you on how to tackle scalability on your usecase. [1] https://github.com/wso2-dev/siddhi/tree/Siddhi-3.0.0 Thanks, Lasantha On 3 October 2014 12:57, andresgomez92 [hidden email] wrote: Hi Lasantha, I have changed my storm topology. Now, all stream go to the same siddhiManager instance and all queries works fine. But now, I only have 1 instance of siddhiManager without distributed processing ... How can I get scalability??? Thanks, Andrés - -- Andres Gomez Developer at Eneo Tecnologia. Website: http://redborder.net LinkedIn: http://lnkd.in/sHnbJe -- View this message in context: http://wso2-oxygen-tank.10903.n7.nabble.com/siddhi-v2-2-0-SNAPSHOT-stop-calling-callbacks-after-few-seconds-tp103254p104350.html Sent from the WSO2 Development mailing list archive at Nabble.com. ___ Dev mailing list [hidden email] http://wso2.org/cgi-bin/mailman/listinfo/dev -- Lasantha Fernando Software Engineer - Data Technologies Team WSO2 Inc. http://wso2.com email: [hidden email] mobile: (+94) 71 5247551 ___ Dev mailing list [hidden email] http://wso2.org/cgi-bin/mailman/listinfo/dev If you reply to this email, your message will be added to the discussion below: http://wso2-oxygen-tank.10903.n7.nabble.com/siddhi-v2-2-0-SNAPSHOT-stop-calling-callbacks-after-few-seconds-tp103254p104356.html To unsubscribe from siddhi v2.2.0-SNAPSHOT stop calling callbacks after few seconds, click here. NAML - -- Andres Gomez Developer at Eneo Tecnologia. Website: http://redborder.net LinkedIn: http://lnkd.in/sHnbJe -- View this message in context: http://wso2-oxygen-tank.10903.n7.nabble.com/siddhi-v2-2-0-SNAPSHOT-stop-calling-callbacks-after-few-seconds-tp103254p104367.html Sent from the WSO2 Development mailing list archive at Nabble.com.___ Dev mailing list Dev@wso2.org http://wso2.org/cgi-bin/mailman/listinfo/dev
Re: [Dev] siddhi v2.2.0-SNAPSHOT stop calling callbacks after few seconds
Hi Lasantha, I try the same set of queries without distributed processing. Now this query work fine: *- queryB:*'from streamFlow#window.timeBatch( 5 sec ) select max(bytes) as maxBytes, min(bytes) as minBytes, avg(bytes) as avgBytes, sum(bytes) as sumBytes, src group by src insert into infoBytes'* but this query doesn't work: *- queryA:* 'from flow=streamFlow[bytes250]+, monitor=streamMonitor[monitor==cpu and value25.00] within 1 select flow[0].src as src, monitor.value as cpu insert into streamD'* I try explain you how I am using Siddhi within the TridentTopology. I am using the Trident State API. I put siddhiManager inside a Trident State, and I use this Trident State across my topology, for example: --- STORM |- Siddhi --- -- TridentStream( FLOW )-- Trident State with Siddhi | - SiddhiStream(streamFlow) [Thread 1] | -- TridentStream( MONITOR ) -- Trident State with Siddhi | - SiddhiStream(streamMonitor) [Thread 2] I need the distributed processing to make a communication between Thread1 and Thread2 [queryA]. I can have multiple parallelism in the same Trident State to do it scalable. What do you think? Thanks, Andres - -- Andres Gomez Developer at Eneo Tecnologia. Website: http://redborder.net LinkedIn: http://lnkd.in/sHnbJe -- View this message in context: http://wso2-oxygen-tank.10903.n7.nabble.com/siddhi-v2-2-0-SNAPSHOT-stop-calling-callbacks-after-few-seconds-tp103254p103966.html Sent from the WSO2 Development mailing list archive at Nabble.com. ___ Dev mailing list Dev@wso2.org http://wso2.org/cgi-bin/mailman/listinfo/dev
[Dev] siddhi v2.2.0-SNAPSHOT stop calling callbacks after few seconds
Hii
I am using siddhi on distribute mode inside Apache Storm with Trident API. I
am trying two queries like this:
* - queryA:* 'from flow=streamFlow[bytes250]+,
monitor=streamMonitor[monitor==cpu and value25.00] within 1 select
flow[0].src as src, monitor.value as cpu insert into streamD'
* - queryB:*'from streamFlow#window.timeBatch( 5 sec ) select max(bytes) as
maxBytes, min(bytes) as minBytes, avg(bytes) as avgBytes, sum(bytes) as
sumBytes, src group by src insert into infoBytes'
The queries at start works fine but after few seconds it doesn't work ... I
enable the trace on siddhiManager, and I can see this:
* --- FIRST TIME [queryA]
---*
2014-09-18 09:14:28 STDIO [INFO] TRACE: [Event: Event{streamId='streamFlow',
timeStamp=1411031668462, data=[10.0.30.27, 416], type=new} - Msg: on Event
Stream ]
2014-09-18 09:14:28 STDIO [INFO] TRACE: [Event: Event{streamId='streamFlow',
timeStamp=1411031668463, data=[10.0.30.27, 416], type=new} - Msg: on Event
Stream ]
2014-09-18 09:14:28 STDIO [INFO] TRACE: [Event: Event{streamId='streamFlow',
timeStamp=1411031668463, data=[10.0.30.91, 60], type=new} - Msg: on Event
Stream ]
2014-09-18 09:14:28 STDIO [INFO] TRACE: [Event: Event{streamId='streamFlow',
timeStamp=1411031668463, data=[10.0.30.91, 60], type=new} - Msg: on Event
Stream ]
2014-09-18 09:14:28 STDIO [INFO] TRACE: [Event: Event{streamId='streamFlow',
timeStamp=1411031668465, data=[10.0.30.27, 416], type=new} - Msg: on Event
Stream ]
2014-09-18 09:14:28 STDIO [INFO] TRACE: [Event: Event{streamId='streamFlow',
timeStamp=1411031668465, data=[10.0.30.91, 60], type=new} - Msg: on Event
Stream ]
2014-09-18 09:14:28 STDIO [INFO] TRACE: [Event: Event{streamId='streamFlow',
timeStamp=1411031668465, data=[10.0.30.27, 416], type=new} - Msg: on Event
Stream ]
2014-09-18 09:14:29 STDIO [INFO] TRACE: [Event:
SingleEventList{events=[Event{streamId='infoBytes', timeStamp=1411031667725,
data=[60, 60, 60.0, 1200, 10.0.30.91], type=new},
Event{streamId='infoBytes', timeStamp=1411031667725, data=[416, 416, 416.0,
7072, 10.0.30.27], type=new}, Event{streamId='infoBytes',
timeStamp=1411031667725, data=[283, 283, 283.0, 1132, 108.160.167.159],
type=new}]} - Msg: on Event Stream ]
2014-09-18 09:14:29 STDIO [INFO] TRACE: [Event:
SingleEventList{events=[Event{streamId='infoBytes', timeStamp=1411031667725,
data=[60, 60, 60.0, 1200, 10.0.30.91], type=new},
Event{streamId='infoBytes', timeStamp=1411031667725, data=[416, 416, 416.0,
7072, 10.0.30.27], type=new}, Event{streamId='infoBytes',
timeStamp=1411031667725, data=[283, 283, 283.0, 1132, 108.160.167.159],
type=new}]} - Msg: on Stream Callback ]
* --- FIRST TIME [queryB]
---*
2014-09-18 09:19:29 STDIO [INFO] TRACE: [Event: Event{streamId='streamFlow',
timeStamp=1411031969449, data=[192.168.41.8, 2220], type=new} - Msg: on
Event Stream ]
2014-09-18 09:19:31 STDIO [INFO] TRACE: [Event:
SingleEventList{events=2014-09-18 09:19:44 STDIO [INFO] TRACE: [Event:
Event{streamId='streamMonitor', timeStamp=1411031984360, data=[244.0, cpu],
type=new} - Msg: on Event Stream ]
2014-09-18 09:19:44 STDIO [INFO] TRACE: [Event: Event{streamId='streamD',
timeStamp=1411031984360, data=[192.168.41.8, 244.0], type=new} - Msg: on
Event Stream ]
2014-09-18 09:19:44 STDIO [INFO] TRACE: [Event: Event{streamId='streamD',
timeStamp=1411031984360, data=[192.168.41.8, 244.0], type=new} - Msg: on
Stream Callback ]
*--- AFTER FEW SECONDS ---*
2014-09-18 09:44:17 STDIO [INFO] TRACE: [Event: Event{streamId='streamFlow',
timeStamp=1411033457630, data=[108.160.167.159, 283], type=new} - Msg: on
Event Stream ]
2014-09-18 09:44:17 STDIO [INFO] TRACE: [Event: Event{streamId='streamFlow',
timeStamp=1411033457630, data=[108.160.167.159, 283], type=new} - Msg: on
Event Stream ]
2014-09-18 09:44:17 STDIO [INFO] TRACE: [Event: Event{streamId='streamFlow',
timeStamp=1411033457630, data=[192.168.41.8, 2220], type=new} - Msg: on
Event Stream ]
*---*
At the first time I can see how the events arrives and enable the queries
... all works fine! :) But after few seconds I can see how the events
arrives into siddhiManager instances but the queries always are disable ..
any idea???
This is my SiddhiConfiguration:
SiddhiConfiguration configuration = new SiddhiConfiguration();
configuration.setDistributedProcessing(true);
configuration.setQueryPlanIdentifier(storm);
configuration.setEventBatchSize(3000);
configuration.setAsyncProcessing(true);
-
--
Andres Gomez Ferrer
--
View this message in context:
http://wso2-oxygen-tank.10903.n7.nabble.com/siddhi-v2-2-0-SNAPSHOT-stop-calling-callbacks-after-few-seconds-tp103254.html
Sent from the WSO2 Development mailing list archive at Nabble.com.
___
Dev
Re: [Dev] parser - java.lang.Long, Problem!! CEP
ok!! Please. if you can let me know when you fix it!! Thanks. Regards, Andrés -- View this message in context: http://wso2-oxygen-tank.10903.n7.nabble.com/Dev-parser-java-lang-Long-Problem-CEP-tp88734p88767.html Sent from the WSO2 Development mailing list archive at Nabble.com. ___ Dev mailing list Dev@wso2.org http://wso2.org/cgi-bin/mailman/listinfo/dev
[Dev] parser - java.lang.Long, Problem!! CEP
Hi all,
I have a problem when I try to parse java.lang.Long.
For example:
I send to CEP this json event:
*{timestamp:1383580897,sensor_id:0,sensor_name:pablo06}
where:
* timestamp is a Long.
* sensor_id is an Integer.
* Sensor_name is a String.*
My eventBuilder is like this:
*?xml version=1.0 encoding=UTF-8?
eventBuilder name=builder_rb_monitor statistics=enable
trace=disable xmlns=http://wso2.org/carbon/eventbuilder;
from eventAdaptorName=wso2KafkaConsumer
eventAdaptorType=kafkaConsumerBroker
property name=topicrb_monitor/property
/from
mapping customMapping=enable type=json
property
from jsonPath=$.timestamp/
to default=-1 name=timestamp type=long/
/property
property
from jsonPath=$.sensor_id/
to default=-1 name=sensor_id type=int/
/property
property
from jsonPath=$.sensor_name/
to default=none name=sensor_name type=string/
/property
/mapping
to streamName=rb_monitor_stream version=1.0.0/
/eventBuilder*
and my eventStream is like this:
*streamDefinition name=rb_monitor_stream version=1.0.0
payloadData
property name=timestamp type=LONG /
property name=sensor_id type=INT /
property name=sensor_name type=STRING /
/payloadData
/streamDefinition*
But when I send eventJson in the terminal I can see this:
*[2013-11-20 19:54:51,382] WARN - {JsonInputMapper} Unable to cast the
input data to required type :java.lang.Long*
and in the eventTracer I can see:
*19:53:08,286 [-] [pool-12-thread-1] INFO TenantId=-1234 : Event Builder :
builder_rb_monitor, before processing
{timestamp:1383580897,sensor_id:0,sensor_name:pablo06}
19:53:08,287 [-] [pool-12-thread-1] INFO TenantId=-1234 : Event Builder :
builder_rb_monitor : Event Stream : rb_monitor_stream:1.0.0 , after
processing
[0, pablo06]*
Does anyone know why this happens?
Regards and thanks!
Andrés Gómez
--
View this message in context:
http://wso2-oxygen-tank.10903.n7.nabble.com/Dev-parser-java-lang-Long-Problem-CEP-tp88734.html
Sent from the WSO2 Development mailing list archive at Nabble.com.
___
Dev mailing list
Dev@wso2.org
http://wso2.org/cgi-bin/mailman/listinfo/dev
Re: [Dev] What does this file? CEP Activity Search Report.jrxml
ok, Thanks !! Mohan Regards, Andrés Gómez -- View this message in context: http://wso2-oxygen-tank.10903.n7.nabble.com/Dev-What-does-this-file-CEP-Activity-Search-Report-jrxml-tp88645p88687.html Sent from the WSO2 Development mailing list archive at Nabble.com. ___ Dev mailing list Dev@wso2.org http://wso2.org/cgi-bin/mailman/listinfo/dev
[Dev] What does this file? CEP Activity Search Report.jrxml
What is the use of this file? [CEP HOME]/repository/resources/reports/Activity Search Report.jrxml Is it important? I have a problem with the spaces .. Could I change the name or delete? Thanks.. Andrés Gómez -- View this message in context: http://wso2-oxygen-tank.10903.n7.nabble.com/Dev-What-does-this-file-CEP-Activity-Search-Report-jrxml-tp88645.html Sent from the WSO2 Development mailing list archive at Nabble.com. ___ Dev mailing list Dev@wso2.org http://wso2.org/cgi-bin/mailman/listinfo/dev
Re: [Dev] Input Event Adaptor - Event Builder CEP 3.0.0 - method onEventCall()
Finally I've solved it, thank you very much! Andrés Gómez -- View this message in context: http://wso2-oxygen-tank.10903.n7.nabble.com/Input-Event-Adaptor-Event-Builder-CEP-3-0-0-method-onEventCall-tp87973p87985.html Sent from the WSO2 Development mailing list archive at Nabble.com. ___ Dev mailing list Dev@wso2.org http://wso2.org/cgi-bin/mailman/listinfo/dev
[Dev] Event Builder JSON Builder - Default Value, use????
Hi all,
I have a question about the field Default Value on the Event Builder.
I think the following:
If I receive an event like this:
*{Nombre:Andres, Dinero10, Other:100}
*
and I use this:
http://img189.imageshack.us/img189/761/qdhx.png
When the event leaves the event builder, I have this:
*[Andres 10]
*
Now, If I receive an event like this:
*{Nombre:Andres, Other:100}
*
When the event leaves the event builder, I have this:
*[Andres]
*
But I expected to get this:
*[Andres 0]
*
Since the field Default Value to Dinero is 0.
Do not operate in this manner? Could I do it in any way?
Regards,
Andrés Gómez
--
View this message in context:
http://wso2-oxygen-tank.10903.n7.nabble.com/Event-Builder-JSON-Builder-Default-Value-use-tp87986.html
Sent from the WSO2 Development mailing list archive at Nabble.com.
___
Dev mailing list
Dev@wso2.org
http://wso2.org/cgi-bin/mailman/listinfo/dev
Re: [Dev] Input Event Adaptor - Event Builder CEP 3.0.0 - method onEventCall()
Hi again Lasantha, I have been reading the links and I think I am right. I can see how JSON events arrive! img src='http://img201.imageshack.us/img201/3949/7wc.png' border='0'/ http://imageshack.us/photo/my-images/201/7wc.png/ But the event builder can't map them ... img src='http://img585.imageshack.us/img585/4753/o36b.png' border='0'/ http://imageshack.us/photo/my-images/585/o36b.png/ my event builder is like this: img src='http://img189.imageshack.us/img189/761/qdhx.png' border='0'/ http://imageshack.us/photo/my-images/189/qdhx.png/ Do you see any error? Regards and thanks!! Andrés Gómez -- View this message in context: http://wso2-oxygen-tank.10903.n7.nabble.com/Input-Event-Adaptor-Event-Builder-CEP-3-0-0-method-onEventCall-tp87973p87977.html Sent from the WSO2 Development mailing list archive at Nabble.com. ___ Dev mailing list Dev@wso2.org http://wso2.org/cgi-bin/mailman/listinfo/dev
Re: [Dev] wso2 cep 3.0.0 - Event Builder Problem
Finally I've solved, I have used the topic of Kafka as InputMessageProperties
and the problem was solved!!
Now establish connection and receive the messages of kafka :) I can process
the messages and I can send mail :D ... But if all goes well, jump an error
Why? I have a curiosity!!
[2013-11-01 00:24:50,384] ERROR - {AsyncDataPublisher} Error while
connection to event receiver
org.wso2.carbon.databridge.agent.thrift.exception.AgentException: Cannot
borrow client for TCP,localhost:7661,TCP,localhost:7761
at
org.wso2.carbon.databridge.agent.thrift.internal.publisher.authenticator.AgentAuthenticator.connect(AgentAuthenticator.java:58)
at
org.wso2.carbon.databridge.agent.thrift.DataPublisher.start(DataPublisher.java:273)
at
org.wso2.carbon.databridge.agent.thrift.DataPublisher.init(DataPublisher.java:211)
at
org.wso2.carbon.databridge.agent.thrift.AsyncDataPublisher$ReceiverConnectionWorker.run(AsyncDataPublisher.java:782)
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:724)
Caused by: org.apache.thrift.transport.TTransportException: Could not
connect to 192.168.0.5 on port 7761
at
org.apache.thrift.transport.TSSLTransportFactory.createClient(TSSLTransportFactory.java:212)
at
org.apache.thrift.transport.TSSLTransportFactory.getClientSocket(TSSLTransportFactory.java:166)
at
org.wso2.carbon.databridge.agent.thrift.internal.pool.client.secure.SecureClientPoolFactory.makeObject(SecureClientPoolFactory.java:90)
at
org.wso2.carbon.databridge.agent.thrift.internal.pool.client.secure.SecureClientPoolFactory.makeObject(SecureClientPoolFactory.java:48)
at
org.apache.commons.pool.impl.GenericKeyedObjectPool.borrowObject(GenericKeyedObjectPool.java:1212)
at
org.wso2.carbon.databridge.agent.thrift.internal.publisher.authenticator.AgentAuthenticator.connect(AgentAuthenticator.java:50)
... 8 more
Caused by: java.net.ConnectException: Connection refused
at java.net.PlainSocketImpl.socketConnect(Native Method)
at
java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:339)
at
java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:200)
at
java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:182)
at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)
at java.net.Socket.connect(Socket.java:579)
at sun.security.ssl.SSLSocketImpl.connect(SSLSocketImpl.java:618)
at sun.security.ssl.SSLSocketImpl.init(SSLSocketImpl.java:407)
at
sun.security.ssl.SSLSocketFactoryImpl.createSocket(SSLSocketFactoryImpl.java:88)
at
org.apache.thrift.transport.TSSLTransportFactory.createClient(TSSLTransportFactory.java:208)
... 13 more
[2013-11-01 00:25:20,366] ERROR - {ReceiverGroup} No receiver is reachable
at reconnection, can't publish the events
[2013-11-01 00:25:20,372] ERROR - {AsyncDataPublisher} Reconnection failed
for for tcp://localhost:7661
Andrés Gómez
--
View this message in context:
http://wso2-oxygen-tank.10903.n7.nabble.com/Dev-wso2-cep-3-0-0-Event-Builder-Problem-tp87891p87930.html
Sent from the WSO2 Development mailing list archive at Nabble.com.
___
Dev mailing list
Dev@wso2.org
http://wso2.org/cgi-bin/mailman/listinfo/dev
Re: [Dev] wso2 cep 3.0.0 - Event Builder Problem
Hi Mohan,
Finally I've got to try to create the event builder :)
img src='http://img15.imageshack.us/img15/871/mn3w.png' border='0'/
http://imageshack.us/photo/my-images/15/mn3w.png/
But ... when I click in the Add event builder, jumps another exception I
can't understand :(
*[2013-10-31 21:54:15,255] ERROR - {StandardWrapperValve} Servlet.service()
for servlet [bridgeservlet] in context with path [/] threw exception
[java.lang.ArrayIndexOutOfBoundsException: 1] with root cause
java.lang.ArrayIndexOutOfBoundsException: 1
at
org.apache.jsp.eventbuilder.add_005feventbuilder_005fajaxprocessor_jsp._jspService(org.apache.jsp.eventbuilder.add_005feventbuilder_005fajaxprocessor_jsp:106)
at org.apache.jasper.runtime.HttpJspBase.service(HttpJspBase.java:111)
at javax.servlet.http.HttpServlet.service(HttpServlet.java:848)
at
org.apache.jasper.servlet.JspServletWrapper.service(JspServletWrapper.java:403)
at
org.apache.jasper.servlet.JspServlet.serviceJspFile(JspServlet.java:492)
at org.apache.jasper.servlet.JspServlet.service(JspServlet.java:378)
at javax.servlet.http.HttpServlet.service(HttpServlet.java:848)
at org.wso2.carbon.ui.JspServlet.service(JspServlet.java:155)
at org.wso2.carbon.ui.TilesJspServlet.service(TilesJspServlet.java:80)
at javax.servlet.http.HttpServlet.service(HttpServlet.java:848)
at
org.eclipse.equinox.http.helper.ContextPathServletAdaptor.service(ContextPathServletAdaptor.java:37)
at
org.eclipse.equinox.http.servlet.internal.ServletRegistration.service(ServletRegistration.java:61)
at
org.eclipse.equinox.http.servlet.internal.ProxyServlet.processAlias(ProxyServlet.java:128)
at
org.eclipse.equinox.http.servlet.internal.ProxyServlet.service(ProxyServlet.java:68)
at javax.servlet.http.HttpServlet.service(HttpServlet.java:848)
at
org.wso2.carbon.tomcat.ext.servlet.DelegationServlet.service(DelegationServlet.java:68)
at
org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:305)
at
org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:210)
at
org.wso2.carbon.tomcat.ext.filter.CharacterSetFilter.doFilter(CharacterSetFilter.java:61)
at
org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:243)
at
org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:210)
at
org.apache.catalina.core.StandardWrapperValve.invoke(StandardWrapperValve.java:222)
at
org.apache.catalina.core.StandardContextValve.invoke(StandardContextValve.java:123)
at
org.apache.catalina.authenticator.AuthenticatorBase.invoke(AuthenticatorBase.java:472)
at
org.apache.catalina.core.StandardHostValve.invoke(StandardHostValve.java:171)
at
org.apache.catalina.valves.ErrorReportValve.invoke(ErrorReportValve.java:99)
at
org.wso2.carbon.tomcat.ext.valves.CompositeValve.continueInvocation(CompositeValve.java:178)
at
org.wso2.carbon.tomcat.ext.valves.CarbonTomcatValve$1.invoke(CarbonTomcatValve.java:47)
at
org.wso2.carbon.webapp.mgt.TenantLazyLoaderValve.invoke(TenantLazyLoaderValve.java:56)
at
org.wso2.carbon.tomcat.ext.valves.TomcatValveContainer.invokeValves(TomcatValveContainer.java:47)
at
org.wso2.carbon.tomcat.ext.valves.CompositeValve.invoke(CompositeValve.java:141)
at
org.wso2.carbon.tomcat.ext.valves.CarbonStuckThreadDetectionValve.invoke(CarbonStuckThreadDetectionValve.java:156)
at
org.apache.catalina.valves.AccessLogValve.invoke(AccessLogValve.java:936)
at
org.wso2.carbon.tomcat.ext.valves.CarbonContextCreatorValve.invoke(CarbonContextCreatorValve.java:52)
at
org.apache.catalina.core.StandardEngineValve.invoke(StandardEngineValve.java:118)
at
org.apache.catalina.connector.CoyoteAdapter.service(CoyoteAdapter.java:407)
at
org.apache.coyote.http11.AbstractHttp11Processor.process(AbstractHttp11Processor.java:1004)
at
org.apache.coyote.AbstractProtocol$AbstractConnectionHandler.process(AbstractProtocol.java:589)
at
org.apache.tomcat.util.net.NioEndpoint$SocketProcessor.run(NioEndpoint.java:1653)
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:724)*
Andrés Gómez
--
View this message in context:
http://wso2-oxygen-tank.10903.n7.nabble.com/Dev-wso2-cep-3-0-0-Event-Builder-Problem-tp87891p87929.html
Sent from the WSO2 Development mailing list archive at Nabble.com.
___
Dev mailing list
Dev@wso2.org
http://wso2.org/cgi-bin/mailman/listinfo/dev
Re: [Dev] wso2 cep 3.0.0 - Event Builder Problem
Fixed the exception was jumping on another site! Thanks anyway :) I continue! I hope to have it ready soon and post it! Andrés Gómez. -- View this message in context: http://wso2-oxygen-tank.10903.n7.nabble.com/Dev-wso2-cep-3-0-0-Event-Builder-Problem-tp87891p87928.html Sent from the WSO2 Development mailing list archive at Nabble.com. ___ Dev mailing list Dev@wso2.org http://wso2.org/cgi-bin/mailman/listinfo/dev
Re: [Dev] wso2 cep 3.0.0 - Event Builder Problem
Hi again!
I understand the issue of the topics but at the first i don't need it.
I return an empty list in the getInputMessageProperties like you have told
me:
*@Override
protected ListProperty getInputMessageProperties() {
ListProperty propertyList = new ArrayListProperty();
return propertyList;
}*
and the method subscribe is similar than i used in the wso cep 2.1.0:
* public String subscribe(
InputEventAdaptorMessageConfiguration
inputEventAdaptorMessageConfiguration,
InputEventAdaptorListener inputEventAdaptorListener,
InputEventAdaptorConfiguration inputEventAdaptorConfiguration,
AxisConfiguration axisConfiguration) {
MapString, String brokerProperties = new HashMapString,
String();
brokerProperties.putAll(inputEventAdaptorConfiguration.getInputProperties());
String zkConnect =
brokerProperties.get(ConsumerKafkaConstants.BROKER_SUSCRIBER_ZOOKEEPER_CONNECT);
String topic =
brokerProperties.get(ConsumerKafkaConstants.BROKER_SUSCRIBER_TOPIC);
String groupID =
brokerProperties.get(ConsumerKafkaConstants.BROKER_SUSCRIBER_GROUP_ID);
String threadsStr =
brokerProperties.get(ConsumerKafkaConstants.BROKER_SUSCRIBER_THREADS);
int threads = Integer.parseInt(threadsStr);
consumerRedBorder = new ConsumerKafkaRedBorder(zkConnect, groupID,
topic,
ConsumerKafkaType.createConsumerConfig(zkConnect, groupID));
consumerRedBorder.run(threads, inputEventAdaptorListener);
return null;
}*
But the exception is still jumping! :S
Have I do something with inputEventAdaptorMessageConfiguration
Thanks.
Andrés Gómez!
--
View this message in context:
http://wso2-oxygen-tank.10903.n7.nabble.com/Dev-wso2-cep-3-0-0-Event-Builder-Problem-tp87891p87927.html
Sent from the WSO2 Development mailing list archive at Nabble.com.
___
Dev mailing list
Dev@wso2.org
http://wso2.org/cgi-bin/mailman/listinfo/dev
[Dev] wso2 cep 3.0.0 - Event Builder Problem
Hi all, I try to deploy a custom event input adaptors to kafka, I already have the implementation with OSGI Bundle and put the jar into drop ins directory! I make the custom adapter, like this: img src='http://img577.imageshack.us/img577/7190/6nqs.png' border='0'/ http://imageshack.us/photo/my-images/577/6nqs.png/ img src='http://img513.imageshack.us/img513/771/i8i0.png' border='0'/ http://imageshack.us/photo/my-images/513/i8i0.png/ But when i try to make the event builder I can see this: img src='http://img585.imageshack.us/img585/2441/bntt.png' border='0'/ http://imageshack.us/photo/my-images/585/bntt.png/ And I think that I should see something like this: http://docs.wso2.org/download/attachments/28717819/map-builder.png?version=1modificationDate=1379580919000 Can anyone help me? How can I create the event builder? Andrés Gómez -- View this message in context: http://wso2-oxygen-tank.10903.n7.nabble.com/Dev-wso2-cep-3-0-0-Event-Builder-Problem-tp87891.html Sent from the WSO2 Development mailing list archive at Nabble.com. ___ Dev mailing list Dev@wso2.org http://wso2.org/cgi-bin/mailman/listinfo/dev
Re: [Dev] [CEP] Custom Event Adaptor??? CEP 3.0.0
Hello again Mohan, I have a question, when I compile the OSGI bundles, I must put the jar inside CEP_HOME/repository/components/plugins nothing more? Thanks! Andrés Gómez -- View this message in context: http://wso2-oxygen-tank.10903.n7.nabble.com/CEP-Dev-Custom-Event-Adaptor-CEP-3-0-0-tp87834p87858.html Sent from the WSO2 Development mailing list archive at Nabble.com. ___ Dev mailing list Dev@wso2.org http://wso2.org/cgi-bin/mailman/listinfo/dev
Re: [Dev] [CEP] Custom Event Adaptor??? CEP 3.0.0
Hi Mohan, That's exactly what I've done (clean and build the code and put the jar in CEP_HOME/repository/components/plugins). I start WSO2 CEP boots normally but when I try to create the event adaptor, this does not appear in the field Event Adaport Type. img src='http://img4.imageshack.us/img4/4555/r2r1.png' border='0'/ http://imageshack.us/photo/my-images/4/r2r1.png/ What do you think? Thanks again, you help me a lot! There is little on this subject. Andrés Gómez -- View this message in context: http://wso2-oxygen-tank.10903.n7.nabble.com/CEP-Dev-Custom-Event-Adaptor-CEP-3-0-0-tp87834p87864.html Sent from the WSO2 Development mailing list archive at Nabble.com. ___ Dev mailing list Dev@wso2.org http://wso2.org/cgi-bin/mailman/listinfo/dev
Re: [Dev] [CEP] Custom Event Adaptor??? CEP 3.0.0
Thanks! You're right, that mistake!! Andrés Gómez -- View this message in context: http://wso2-oxygen-tank.10903.n7.nabble.com/CEP-Dev-Custom-Event-Adaptor-CEP-3-0-0-tp87834p87867.html Sent from the WSO2 Development mailing list archive at Nabble.com. ___ Dev mailing list Dev@wso2.org http://wso2.org/cgi-bin/mailman/listinfo/dev
[Dev] [CEP] Custom Event Adaptor??? CEP 3.0.0
Hi all, I would like to know how to implement a custom event adaptors to CEP 3.0.0 . I've looked here: http://docs.wso2.org/display/CEP300/Writing+Custom+Event+Adaptors But the link http://wso2.com/library/articles/2013/08/writing-custom-transport-adaptors-for-cep-3.0.0 doesn't work. Where can I find an some information? Is It available in maven? Thanks!! Andrés Gómez -- View this message in context: http://wso2-oxygen-tank.10903.n7.nabble.com/CEP-Dev-Custom-Event-Adaptor-CEP-3-0-0-tp87834.html Sent from the WSO2 Development mailing list archive at Nabble.com. ___ Dev mailing list Dev@wso2.org http://wso2.org/cgi-bin/mailman/listinfo/dev
[Dev] Custom broker kafka, all implemented! Error when testing
Hi all, I have already implemented all the code needed to kafka broker. I
made the connection between WSO2 and kafka queue.
I send the events to WSO2 as follows:
**
public class ConsumerTest implements Runnable {
private KafkaStream m_stream;
private int m_threadNumber;
private BrokerListener m_brokerListener;
private ObjectMapper mapper = new ObjectMapper();
private MapString, Object evento;
public ConsumerTest(KafkaStream a_stream, int a_threadNumber,
BrokerListener a_brokerListener) {
m_threadNumber = a_threadNumber;
m_stream = a_stream;
m_brokerListener = a_brokerListener;
}
public void run() {
ConsumerIteratorbyte[], byte[] it = m_stream.iterator();
while (it.hasNext()) {
try {
evento = mapper.readValue(new String(it.next().message()),
new TypeReferenceMaplt;String, Object() {
});
m_brokerListener.onEvent(evento);
} catch (IOException ex) {
Logger.getLogger(ConsumerTest.class.getName()).log(Level.SEVERE, null, ex);
} catch (BrokerEventProcessingException ex) {
Logger.getLogger(ConsumerTest.class.getName()).log(Level.SEVERE, null, ex);
}
}
}
}
**
When I write a message on kafka like this: {Name: Andrew, Age: 20},
but WSO2 does nothing, I have configured the broker and bucket like this:
**
?xml version=1.0 encoding=UTF-8?
cep:bucket name=kafkaBucket xmlns:cep=http://wso2.org/carbon/cep;
cep:description
Some Description.
/cep:description
cep:engineProviderConfiguration engineProvider=SiddhiCEPRuntime
cep:property
name=siddhi.persistence.snapshot.time.interval.minutes0/cep:property
cep:property
name=siddhi.enable.distributed.processingfalse/cep:property
/cep:engineProviderConfiguration
cep:input brokerName=kafkaBroker topic=org.wso2.kafka/1.0.0
cep:mapMapping queryEventType=Map stream=stream1
cep:property inputName=Name name=Name type=java.lang.String/
cep:property inputName=Age name=Age type=java.lang.Integer/
/cep:mapMapping
/cep:input
cep:query name=KPIQuery
cep:expression/cep:expression
cep:output brokerName=emailBroker topic=andresgome...@gmail.com/
WSO2
cep:textMappingHi this is a test!!
My name is {Name} and I have {Age}./cep:textMapping
/cep:output
/cep:query
/cep:bucket
**
Obviously I don't receive any email. I have also configured the mail as
explained:
http://docs.wso2.org/display/CEP210/Configuring+E-mail+Broker
Can anyone see any fault??? thank you very much
Andres Gomez.
Pd: When I start WSO2, this exception happened. I do not know if It will
have something to do:
**
INFO {org.wso2.carbon.registry.core.internal.RegistryCoreServiceComponent} -
Registry Mode: READ-WRITE
java.lang.reflect.InvocationTargetException
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at
org.xerial.snappy.SnappyLoader.loadNativeLibrary(SnappyLoader.java:317)
at org.xerial.snappy.SnappyLoader.load(SnappyLoader.java:219)
at org.xerial.snappy.Snappy.clinit(Snappy.java:44)
at
org.apache.cassandra.io.compress.SnappyCompressor.create(SnappyCompressor.java:46)
at
org.apache.cassandra.io.compress.SnappyCompressor.isAvailable(SnappyCompressor.java:56)
at
org.apache.cassandra.io.compress.SnappyCompressor.clinit(SnappyCompressor.java:38)
at org.apache.cassandra.config.CFMetaData.clinit(CFMetaData.java:76)
at
org.apache.cassandra.config.KSMetaData.systemKeyspace(KSMetaData.java:79)
at
org.apache.cassandra.config.DatabaseDescriptor.loadYaml(DatabaseDescriptor.java:441)
at
org.apache.cassandra.config.DatabaseDescriptor.clinit(DatabaseDescriptor.java:117)
at
org.apache.cassandra.service.AbstractCassandraDaemon.setup(AbstractCassandraDaemon.java:126)
at
org.apache.cassandra.service.AbstractCassandraDaemon.activate(AbstractCassandraDaemon.java:353)
at
org.wso2.carbon.cassandra.server.CassandraServerController$1.run(CassandraServerController.java:48)
at java.lang.Thread.run(Thread.java:724)
Caused by: java.lang.UnsatisfiedLinkError: no
Re: [Dev] Custom broker kafka, all implemented! Error when testing
Hi Mohan,
First, Thank you for your help!!
To verify that my custom broker kafka get events properly! I have thrown an
exception on the line marked / / HERE!! and I could see that the map is
created successfully! I map I can print objects without problems! :) That
map is the same That I send to the method onEvent (event);
****
public class ConsumerTest implements Runnable {
private KafkaStream m_stream;
private int m_threadNumber;
private BrokerListener m_brokerListener;
private ObjectMapper mapper = new ObjectMapper();
private MapString, Object evento;
public ConsumerTest(KafkaStream a_stream, int a_threadNumber,
BrokerListener a_brokerListener) {
m_threadNumber = a_threadNumber;
m_stream = a_stream;
m_brokerListener = a_brokerListener;
}
public void run() {
ConsumerIteratorbyte[], byte[] it = m_stream.iterator();
while (it.hasNext()) {
try {
evento = mapper.readValue(new String(it.next().message()),
new TypeReferenceMapamp;lt;String, Object() {
});
*///HERE/*
m_brokerListener.onEvent(evento);
} catch (IOException ex) {
Logger.getLogger(ConsumerTest.class.getName()).log(Level.SEVERE, null, ex);
} catch (BrokerEventProcessingException ex) {
Logger.getLogger(ConsumerTest.class.getName()).log(Level.SEVERE, null, ex);
}
}
}
}
****
About cep: expression (Sidhi query) wasn't copy before I use this:
****
cep:expression/cep:expression
****
I send you a picture of the bucket:
img src='http://img202.imageshack.us/img202/3871/hxll.png' border='0'/
http://imageshack.us/photo/my-images/202/hxll.png/
img src='http://img819.imageshack.us/img819/894/2p8z.png' border='0'/
http://imageshack.us/photo/my-images/819/2p8z.png/
****
when, referencing the bucket before I put:
- Nombre is Name.
- Edad is Age.
- broker is a KafkaBroker.
I've used *./wso2server.sh -Ddisable.cassandra.server.startup=true* and the
exception disappeared. :)
I have all the jars in CEP_HOME / repository / components / lib.
Can you see any problems in that configuration? Because I send a
java.util.Map that is fine with the method onEvent (...) and I can see in
the log as WSO2 connects kafka.
Thank you very much again, really!
Andrés!!
--
View this message in context:
http://wso2-oxygen-tank.10903.n7.nabble.com/Dev-Custom-broker-kafka-all-implemented-Error-when-testing-tp87435p87439.html
Sent from the WSO2 Development mailing list archive at Nabble.com.
___
Dev mailing list
Dev@wso2.org
http://wso2.org/cgi-bin/mailman/listinfo/dev
Re: [Dev] Custom broker kafka, all implemented! Error when testing
It works perfectly!! THANK YOU :) When I test it a little more if you're interested in the broker I will give it to you!! -- View this message in context: http://wso2-oxygen-tank.10903.n7.nabble.com/Dev-Custom-broker-kafka-all-implemented-Error-when-testing-tp87435p87442.html Sent from the WSO2 Development mailing list archive at Nabble.com. ___ Dev mailing list Dev@wso2.org http://wso2.org/cgi-bin/mailman/listinfo/dev
[Dev] Custom Broker, Kafka to CEP exception: not supported yet
Hi, Finally I created the JAR and load without problems WSO2-CEP, but when I
try to create my broker jumps an exception not supported yet attached a
photo and the result of the terminal.
*--Photo 1 not supported yet--*
img src='http://img853.imageshack.us/img853/1603/bwgd.png' border='0'/
http://imageshack.us/photo/my-images/853/bwgd.png/
*--Terminal--*
[2013-10-14 14:42:19,820] ERROR
{org.apache.axis2.rpc.receivers.RPCMessageReceiver} - Not supported yet.
java.lang.reflect.InvocationTargetException
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
at java.lang.reflect.Method.invoke(Method.java:597)
at
org.apache.axis2.rpc.receivers.RPCUtil.invokeServiceClass(RPCUtil.java:212)
at
org.apache.axis2.rpc.receivers.RPCMessageReceiver.invokeBusinessLogic(RPCMessageReceiver.java:117)
at
org.apache.axis2.receivers.AbstractInOutMessageReceiver.invokeBusinessLogic(AbstractInOutMessageReceiver.java:40)
at
org.apache.axis2.receivers.AbstractMessageReceiver.receive(AbstractMessageReceiver.java:110)
at org.apache.axis2.engine.AxisEngine.receive(AxisEngine.java:180)
at
org.apache.axis2.transport.local.LocalTransportReceiver.processMessage(LocalTransportReceiver.java:169)
at
org.apache.axis2.transport.local.LocalTransportReceiver.processMessage(LocalTransportReceiver.java:82)
at
org.wso2.carbon.core.transports.local.CarbonLocalTransportSender.finalizeSendWithToAddress(CarbonLocalTransportSender.java:45)
at
org.apache.axis2.transport.local.LocalTransportSender.invoke(LocalTransportSender.java:77)
at org.apache.axis2.engine.AxisEngine.send(AxisEngine.java:442)
at
org.apache.axis2.description.OutInAxisOperationClient.send(OutInAxisOperation.java:398)
at
org.apache.axis2.description.OutInAxisOperationClient.executeImpl(OutInAxisOperation.java:224)
at
org.apache.axis2.client.OperationClient.execute(OperationClient.java:149)
at
org.wso2.carbon.brokermanager.stub.BrokerManagerAdminServiceStub.addBrokerConfiguration(BrokerManagerAdminServiceStub.java:1089)
at
org.apache.jsp.brokermanager.add_005fbroker_005fajaxprocessor_jsp._jspService(add_005fbroker_005fajaxprocessor_jsp.java:105)
at org.apache.jasper.runtime.HttpJspBase.service(HttpJspBase.java:97)
at javax.servlet.http.HttpServlet.service(HttpServlet.java:722)
at
org.apache.jasper.servlet.JspServletWrapper.service(JspServletWrapper.java:332)
at
org.apache.jasper.servlet.JspServlet.serviceJspFile(JspServlet.java:314)
at org.apache.jasper.servlet.JspServlet.service(JspServlet.java:264)
at javax.servlet.http.HttpServlet.service(HttpServlet.java:722)
at org.wso2.carbon.ui.JspServlet.service(JspServlet.java:161)
at org.wso2.carbon.ui.TilesJspServlet.service(TilesJspServlet.java:80)
at javax.servlet.http.HttpServlet.service(HttpServlet.java:722)
at
org.eclipse.equinox.http.helper.ContextPathServletAdaptor.service(ContextPathServletAdaptor.java:36)
at
org.eclipse.equinox.http.servlet.internal.ServletRegistration.handleRequest(ServletRegistration.java:90)
at
org.eclipse.equinox.http.servlet.internal.ProxyServlet.processAlias(ProxyServlet.java:111)
at
org.eclipse.equinox.http.servlet.internal.ProxyServlet.service(ProxyServlet.java:67)
at javax.servlet.http.HttpServlet.service(HttpServlet.java:722)
at
org.wso2.carbon.tomcat.ext.servlet.DelegationServlet.service(DelegationServlet.java:68)
at
org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:305)
at
org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:210)
at
org.wso2.carbon.tomcat.ext.filter.CharacterSetFilter.doFilter(CharacterSetFilter.java:61)
at
org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:243)
at
org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:210)
at
org.apache.catalina.core.StandardWrapperValve.invoke(StandardWrapperValve.java:225)
at
org.apache.catalina.core.StandardContextValve.invoke(StandardContextValve.java:123)
at
org.apache.catalina.authenticator.AuthenticatorBase.invoke(AuthenticatorBase.java:472)
at
org.apache.catalina.core.StandardHostValve.invoke(StandardHostValve.java:168)
at
org.apache.catalina.valves.ErrorReportValve.invoke(ErrorReportValve.java:98)
at
org.wso2.carbon.tomcat.ext.valves.CompositeValve.invoke(CompositeValve.java:172)
at
org.wso2.carbon.tomcat.ext.valves.CarbonStuckThreadDetectionValve.invoke(CarbonStuckThreadDetectionValve.java:156)
at
Re: [Dev] Custom Broker, Kafka to CEP exception: not supported yet
ok!!! thanks Mohan. Andrés Gómez. -- View this message in context: http://wso2-oxygen-tank.10903.n7.nabble.com/Dev-Custom-Broker-Kafka-to-CEP-exception-not-supported-yet-tp87361p87368.html Sent from the WSO2 Development mailing list archive at Nabble.com. ___ Dev mailing list Dev@wso2.org http://wso2.org/cgi-bin/mailman/listinfo/dev
Re: [Dev] Kafka Custom Broker to CEP, exception when I try run!
Thanks Mohan, that was the problem! It is solved :) Andres -- View this message in context: http://wso2-oxygen-tank.10903.n7.nabble.com/Dev-Kafka-Custom-Broker-to-CEP-exception-when-I-try-run-tp87332p87339.html Sent from the WSO2 Development mailing list archive at Nabble.com. ___ Dev mailing list Dev@wso2.org http://wso2.org/cgi-bin/mailman/listinfo/dev
[Dev] Kafka Custom Broker to CEP, exception when I try run!
Hello everyone,
I'm implementing a custom broker for CEP, but when I try to run the server
wso2server.sh. The server throws an exception that is triggered by
BrokerTypeFactory. I have attached my BrokerTypeFactory and the thrown
exception. Does anyone have idea why the exception happened?
Thank you very much ,
Andrés Gómez
Pdt: If you need anything more than source code, please let me know.
*-*
*This is my BrokerTypeFactory: *
package com.redborder.custombroker;
import org.wso2.carbon.broker.core.BrokerType;
import org.wso2.carbon.broker.core.BrokerTypeFactory;
public class RedBorderBrokerFactory implements BrokerTypeFactory {
public BrokerType getBrokerType() {
return RedBorderBroker.getInstance();
}
}
**
*Exception occurred:*
[2013-10-13 00:43:04,964] ERROR {org.wso2.carbon.broker.core.BrokerService}
-
java.lang.ExceptionInInitializerError
at
com.redborder.custombroker.RedBorderBrokerFactory.getBrokerType(RedBorderBrokerFactory.java:25)
at
org.wso2.carbon.broker.core.internal.builder.BrokerServiceBuilder.registerBrokerType(BrokerServiceBuilder.java:125)
at
org.wso2.carbon.broker.core.internal.builder.BrokerServiceBuilder.createBrokerService(BrokerServiceBuilder.java:81)
at
org.wso2.carbon.broker.core.internal.ds.BrokerServiceDS.activate(BrokerServiceDS.java:57)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
at java.lang.reflect.Method.invoke(Method.java:597)
at
org.eclipse.equinox.internal.ds.model.ServiceComponent.activate(ServiceComponent.java:252)
at
org.eclipse.equinox.internal.ds.model.ServiceComponentProp.activate(ServiceComponentProp.java:146)
at
org.eclipse.equinox.internal.ds.model.ServiceComponentProp.build(ServiceComponentProp.java:346)
at
org.eclipse.equinox.internal.ds.InstanceProcess.buildComponent(InstanceProcess.java:588)
at
org.eclipse.equinox.internal.ds.InstanceProcess.buildComponents(InstanceProcess.java:196)
at
org.eclipse.equinox.internal.ds.Resolver.getEligible(Resolver.java:328)
at
org.eclipse.equinox.internal.ds.SCRManager.serviceChanged(SCRManager.java:221)
at
org.eclipse.osgi.internal.serviceregistry.FilteredServiceListener.serviceChanged(FilteredServiceListener.java:104)
at
org.eclipse.osgi.framework.internal.core.BundleContextImpl.dispatchEvent(BundleContextImpl.java:861)
at
org.eclipse.osgi.framework.eventmgr.EventManager.dispatchEvent(EventManager.java:230)
at
org.eclipse.osgi.framework.eventmgr.ListenerQueue.dispatchEventSynchronous(ListenerQueue.java:148)
at
org.eclipse.osgi.internal.serviceregistry.ServiceRegistry.publishServiceEventPrivileged(ServiceRegistry.java:819)
at
org.eclipse.osgi.internal.serviceregistry.ServiceRegistry.publishServiceEvent(ServiceRegistry.java:771)
at
org.eclipse.osgi.internal.serviceregistry.ServiceRegistrationImpl.register(ServiceRegistrationImpl.java:130)
at
org.eclipse.osgi.internal.serviceregistry.ServiceRegistry.registerService(ServiceRegistry.java:214)
at
org.eclipse.osgi.framework.internal.core.BundleContextImpl.registerService(BundleContextImpl.java:433)
at
org.eclipse.osgi.framework.internal.core.BundleContextImpl.registerService(BundleContextImpl.java:451)
at
org.wso2.carbon.event.core.internal.builder.EventBrokerHandler.startEventBroker(EventBrokerHandler.java:57)
at
org.wso2.carbon.event.core.internal.builder.EventBrokerBuilderDS.activate(EventBrokerBuilderDS.java:72)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
at java.lang.reflect.Method.invoke(Method.java:597)
at
org.eclipse.equinox.internal.ds.model.ServiceComponent.activate(ServiceComponent.java:252)
at
org.eclipse.equinox.internal.ds.model.ServiceComponentProp.activate(ServiceComponentProp.java:146)
at
org.eclipse.equinox.internal.ds.model.ServiceComponentProp.build(ServiceComponentProp.java:346)
at
org.eclipse.equinox.internal.ds.InstanceProcess.buildComponent(InstanceProcess.java:588)
at
org.eclipse.equinox.internal.ds.InstanceProcess.buildComponents(InstanceProcess.java:196)
at
org.eclipse.equinox.internal.ds.Resolver.getEligible(Resolver.java:328)
at
org.eclipse.equinox.internal.ds.SCRManager.serviceChanged(SCRManager.java:221)
at
[Dev] Input Custom Broker, CEP
Hello all, I try make a Custom Broker to CEP, I need connect to Kafka queue (Consumer with zookeeper), but i haven't found any example, which the method Suscriber is implemented!! I see a example of FIX custom Broker: http://mohanadarshan.wordpress.com/2013/02/22/fix/ This broker implements the Subscriber method but can't find the source code. Can anyone explain to me how you would implement?? Thanks!! Andrés Gómez -- View this message in context: http://wso2-oxygen-tank.10903.n7.nabble.com/Dev-Input-Custom-Broker-CEP-tp87147.html Sent from the WSO2 Development mailing list archive at Nabble.com. ___ Dev mailing list Dev@wso2.org http://wso2.org/cgi-bin/mailman/listinfo/dev
