Проверки работоспособности WSO2

Question

Основываясь на том, что я прочитал в документации и исходном коде, WSO2CEP работает как пассивное программное обеспечение, поэтому он только что-то делает, если на него приходит событие потока. Поэтому, если я хочу разработать «проверку работоспособности» в потоке, мне нужно реализовать его самостоятельно. Мой вопрос: есть ли у кого-то первый шаг, как это сделать? Я немного потерял, с чего начать. Я использую InputEventAdapterFactory или TimeWindowProcessor? Мой сценарий «прост», если поток не приходит в x раз, мне нужно создать предупреждение.

Спасибо,

Марсело Сабино

Answer 1

Эта концепция будет работать.

@Plan:name('ExecutionPlan') 

@Import('rss.in:1.0.0') 
define stream inStream (meta_title string, meta_description string, meta_url string); 

define trigger ThirtySecTriggerStream at every 30 sec; 

from inStream#window.length(1) 
select meta_title, time:currentTimestamp() as meta_time 
insert into table1; 

from ThirtySecTriggerStream join table1 
select meta_title, meta_time 
insert into tempStream; 

from ThirtySecTriggerStream[time:timestampInMilliseconds(meta_time)-time:timestampInMilliseconds(time:curretTimestamp())>30000] 
select meta_title 
insert into OutStream