【发布时间】:2014-02-25 18:01:58
【问题描述】:
我正在尝试处理数据上传,我正在尝试通过 PeopleSoft 通过集成代理在应用程序引擎中异步发布消息。重点是能够发送多条消息并在同一个节点中使用它们。在发送消息之前,我将数据存储在一个表中(比如 T1),以将所有字段值存储在上传文件中。
在消费时,我试图将每条消息公开给组件接口,并且异常记录到同一个表 T1 中。假设我们为每个事务标记表字段(例如 Processed_flag ='Y')。
我需要一种可以等待所有异步消息完成的机制。我正在考虑检查 T1 表,如果 T1 表上有 Processed_flag 为“N”的任何行,只需让线程休眠更多时间。虽然所有消息都没有得到处理,但让它保持休眠状态,不要让应用程序引擎完成。
我能得到的唯一好处是我不必一次等待多个实例,也不必进行同步调用。整个想法是通过不同的交易来使用该组件(就好像它被 100 个人使用 -> 100 笔交易一样)。
除非这 100 笔交易是完整的,否则我们将确保 T1 表记录发生和关闭的情况。如果出现问题,它可以记录 CI 捕获的异常。
任何采用这种方法的 cmets 将不胜感激。提前致谢!
【问题讨论】:
标签: asynchronous integration peoplesoft peoplesoft-app-engine