工作流事件的重新排序
寻找有关以下用例的建议或解决方案
- 应用程序接收按功能键（如员工id）标识的更改时间排序的消息。功能键可以有多条消息
- 每条消息都会触发一个工作流。如果员工有待定工作流，则希望将新消息排队，直到待定工作流完成
是否有任何方法可以在节奏中对消息重新排序，以将它们作为由消息中的功能键标识的组进行处理？
共有1个答案
我希望每个员工都有一个工作流，它接收消息（可能使用SignalWithStart），如果已经在处理消息，则将其排队到变量中。处理可以作为子工作流实现，也可以直接作为员工工作流的一部分实现。处理完成后，如果有缓冲请求，则启动新的工作流。如果没有缓冲请求并且处理完成，则员工工作流可以退出。
-
问题内容： 我有一个使用Sidekiq连接到我的另一个服务的后台作业，如下所示： 有时，此ABCClient关闭了，在这种情况下，我想重新安排“执行”作业。像这样： 问题答案： https://github.com/mperham/sidekiq/wiki/Scheduled- Jobs
-
问题内容： 我已经阅读了很多有关Java同步以及可能发生的所有问题的文章。但是，我仍然有些困惑的是JIT如何重新排序写入。 例如，简单的双重检查锁对我来说很有意义： 我们在第1行使用volatile来强制发生事前关系。没有它，JIT完全有可能整理我们的代码。例如： 线程1位于第6行，并且已分配内存，但是构造函数尚未运行，因为JIT可能会重新排序我们的代码。 线程2进入第2行，并获取一个尚未完全创建
-
我正在尝试使用Apache Camel运行一个简单的重新排序程序。该程序使用Java DSL对传入的Java消息重新排序。当我运行这个程序时，消息会被写入文件夹，但根据标题值或消息正文中单个单词的字母顺序，不会出现任何特定的顺序。Camel创建的文件仍然无序，就好像DSL函数什么都没做一样。 如何让这个程序像方法那样对消息进行实际排序？此外，如何让这个程序重新排序，然后以正确的排序顺序将消息聚合到
-
我已经编写了如下所示的重新调度代码。尽管时间表上写着“每120秒重复一次”，但在结束UpdateQuartzJobTrigger方法后，Execute（）方法会立即被调用。
-
我有两个独立的应用程序运行在同一服务器上。 null 我已经实现了从用户管理到钱包管理的事件来源。它运行得很好。 但是，当我将从钱包管理应用程序中的事件处理程序发布新事件时，我将收到以下错误消息日志。 以下是我的日志详细信息
-
在我们的节奏工作流程中，我们通常需要等待一定时间的外部事件才能继续（即电子邮件阅读、链接点击等）。 我想知道什么是将这些事件通知我们工作流程的最佳方式。信号是正确的方式，还是我们应该创建一个等待事件的活动？ 根据我所看到的，我们需要创建一个信号通道，但是上下文在活动中不可用。