能否在ActiveMQ启动配置阶段发送初始定时消息？

要避开应用层发送，直接通过ActiveMQ自身配置实现定时推送空消息（用于维护共享时钟），可通过以下两种方案实现：

方案一：静态消息 + Broker调度器 #

这是最直接的配置方式，无需额外脚本，完全通过ActiveMQ配置文件实现：

1. 开启Broker调度器
   在activemq.xml的broker节点中启用调度支持：

<broker xmlns="http://activemq.apache.org/schema/core" brokerName="localhost" dataDirectory="${activemq.data}" schedulerSupport="true">
  <!-- 原有Broker配置 -->
</broker>

2. 配置定时静态消息
   在destinationPolicy节点下，为目标队列/主题添加静态消息配置，指定空消息的定时发送规则：

<destinationPolicy>
  <policyMap>
    <policyEntries>
      <!-- 替换为你的目标队列/主题名称 -->
      <policyEntry queue="shared-clock-maintain">
        <staticMessage>
          <!-- 空消息内容 -->
          <text></text>
          <!-- 调度Cron表达式，示例为每5分钟发送一次，按需修改X值 -->
          <schedule cron="*/5 * * * *"/>
          <!-- 设置为-1表示无限重复发送 -->
          <repeat>-1</repeat>
        </staticMessage>
      </policyEntry>
    </policyEntries>
  </policyMap>
</destinationPolicy>

配置完成后，ActiveMQ启动后会自动按照设定的Cron规则，定时推送空消息到目标队列/主题，无需应用层参与。

方案二：启动脚本执行定时消息发送 #

如果需要更灵活的控制逻辑，可通过ActiveMQ的启动脚本功能，让Broker启动后自动执行消息发送逻辑：

1. 编写消息发送脚本
   在ActiveMQ的conf目录下创建send-clock-maintain.js脚本：

importPackage(org.apache.activemq);
importPackage(javax.jms);

// 建立与本地Broker的连接
let connFactory = new ActiveMQConnectionFactory("vm://localhost");
let connection = connFactory.createConnection();
connection.start();

let session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
let destination = session.createQueue("shared-clock-maintain");
let producer = session.createProducer(destination);

// 创建空消息并设置定时调度
let emptyMsg = session.createTextMessage("");
emptyMsg.setStringProperty("AMQ_SCHEDULED_CRON", "*/5 * * * *");

// 发送调度消息（Broker会自动重复发送）
producer.send(emptyMsg);

// 清理资源
producer.close();
session.close();
connection.close();

2. 配置Broker启动执行脚本
   在activemq.xml的broker节点中添加启动脚本配置：

<broker ...>
  <plugins>
    <runtimeConfigurationPlugin>
      <startupScripts>
        <script>file:${activemq.conf}/send-clock-maintain.js</script>
      </startupScripts>
    </runtimeConfigurationPlugin>
  </plugins>
</broker>

Broker启动时会自动执行该脚本，发送带有定时规则的空消息，后续由Broker的调度器负责重复推送。

注意事项 #

• 无论哪种方案，都必须确保Broker的schedulerSupport="true"已开启，这是定时消息功能的基础。
• 根据实际需求调整Cron表达式，例如每10分钟发送一次可改为*/10 * * * *。
• 静态消息配置适合简单场景，脚本方案适合需要额外自定义逻辑的场景。

内容的提问来源于stack exchange，提问作者Scoobie