具有调度程序延迟的ActiveMq故障转移



假设我有2个MQ服务器(A,B)。A配置故障转移到B,并且这些MQ服务器配置了调度程序延迟5分钟来处理每个队列。当A有50个队列并且由于某种原因突然失败时。MQ服务器B是否能够继续处理A中排队的50个存储?或者MQ B只能处理传入队列,但不能在A中处理?

我假设您已经使用KahaDB的共享文件系统目录进行了故障转移设置。当您有延迟和/或计划的消息时,它们不会放在默认的KahaDB数据库中,而是放在您的本地"数据"目录中(即默认情况下一个用于A,一个用于B)。

您必须将您的调度程序配置为也使用共享目录(在某个网络磁盘上或其他什么地方)。配置示例:

<broker ... schedulerSupport="true" schedulerDirectory="/path/to/shared/directory">

最新更新