处理器将对传入事件应用事件处理语言(Event Processing Language)规则。如果事件与规则相符,则处理器再发送一个事件给相关的流组件。我将在下文中介绍预先定义在处理器中的规则。
每个分支的结束部分都有两个 POJO 组件用于接收事件并将数据发送给外部服务器。距离计算分支将生成接近报警将其作为消息发送给外部WebLogic JMS服务器上的JMS TOPIC。事件记录分支将使用JDBC连接到Oracle库并在其中插入所有GPS事件。
事件处理语言规则
EPL规则 将在EPN的处理器上执行。事件记录分支处理器将对所有经过的事件执行一个简单的规则:
select * from GPSInputEvent retain 1 event 在这个规则中,GPSInputEvent是存储库中注册的一种事件类型。它由含有事件数据的另一个POJO实现。
距离计算分支处理器中的规则比较复杂:
select * from (
insert into GPSDistanceEvent
select id, lat, lon, time, seq,
Utils.distance(lat, lon, 37.352889, -121.905531) as distance,
'San Jose, CA' as target
from GPSInputEvent
)
retain all events
where distance < 15 and target = 'San Jose, CA'
文章来源于领测软件测试网 https://www.ltesting.net/