利用虚拟处理代理的流处理方法和系统

    公开(公告)号:CN106663039B

    公开(公告)日:2020-10-23

    申请号:CN201580037434.1

    申请日:2015-07-06

    Abstract: 本文描述了用于利用虚拟处理代理进行事件递送和流处理的技术。在接收到队列中的事件发布之后,运行时系统标识可能对被发布的事件感兴趣但是尚未显式地订阅所述被发布的事件的一个或多个虚拟处理代理。被发布的事件的事件信息随后被递送至被标识的虚拟处理代理。在实际递送之前,运行时系统还确定虚拟处理代理是否已被激活并且激活尚未被激活的那些处理代理。基于所接收的事件信息,一些虚拟处理代理可决定显式地提交订阅以从该队列接收更多事件。显式订阅随后可触发运行时系统向处理代理递送被订阅事件,这些被订阅事件可包括在该显式订阅被接收之前队列中已经发布的过去事件。

    利用虚拟处理代理的流处理

    公开(公告)号:CN106663039A

    公开(公告)日:2017-05-10

    申请号:CN201580037434.1

    申请日:2015-07-06

    Abstract: 本文描述了用于利用虚拟处理代理进行事件递送和流处理的技术。在接收到队列中的事件发布之后,运行时系统标识可能对被发布的事件感兴趣但是尚未显式地订阅所述被发布的事件的一个或多个虚拟处理代理。被发布的事件的事件信息随后被递送至被标识的虚拟处理代理。在实际递送之前,运行时系统还确定虚拟处理代理是否已被激活并且激活尚未被激活的那些处理代理。基于所接收的事件信息,一些虚拟处理代理可决定显式地提交订阅以从该队列接收更多事件。显式订阅随后可触发运行时系统向处理代理递送被订阅事件,这些被订阅事件可包括在该显式订阅被接收之前队列中已经发布的过去事件。

Patent Agency Ranking