| | |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 对时设置应答 |
|---|
| | | * 对时设置 |
|---|
| | | */ |
|---|
| | | public SendResult timingSettingReplyMessage(JSONObject jsonObject) { |
|---|
| | | TimingSettingReplyMessage message = JSON.parseObject(jsonObject.toJSONString(),TimingSettingReplyMessage.class); |
|---|
| | | public SendResult timingSettingMessage(JSONObject jsonObject) { |
|---|
| | | TimingSettingMessage message = JSON.parseObject(jsonObject.toJSONString(),TimingSettingMessage.class); |
|---|
| | | // 设置业务key |
|---|
| | | message.setKey(UUID.randomUUID().toString()); |
|---|
| | | // 设置消息来源，便于查询 |
|---|
| | | message.setSource(SendTagConstant.TIMING_SETTING_REPLY); |
|---|
| | | return rocketMQEnhanceTemplate.send(TOPIC, SendTagConstant.TIMING_SETTING_REPLY, message); |
|---|
| | | message.setSource(SendTagConstant.TIMING_SETTING); |
|---|
| | | return rocketMQEnhanceTemplate.send(TOPIC, SendTagConstant.TIMING_SETTING, message); |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
