| | |
|---|
| | | private RocketMQEnhanceTemplate rocketMQEnhanceTemplate; |
|---|
| | | |
|---|
| | | private static final String TOPIC = "charge_"; |
|---|
| | | private static final String TOPIC_JIANGUAN = "jianguan_"; |
|---|
| | | private static final String TOPIC_JIANGUAN = "jianguan_message"; |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 充电桩登录认证 |
|---|
| | |
|---|
| | | message.setSource(SendTagConstant.END_CHARGE); |
|---|
| | | return rocketMQEnhanceTemplate.send(TOPIC+SendTagConstant.END_CHARGE, SendTagConstant.END_CHARGE, message); |
|---|
| | | } |
|---|
| | | public SendResult endChargeMessageJianGuan(EndChargeMessage message) { |
|---|
| | | // 设置业务key |
|---|
| | | message.setKey(UUID.randomUUID().toString()); |
|---|
| | | // 设置消息来源，便于查询 |
|---|
| | | message.setSource(SendTagConstant.END_CHARGE); |
|---|
| | | return rocketMQEnhanceTemplate.send(TOPIC_JIANGUAN, SendTagConstant.END_CHARGE, message); |
|---|
| | | } |
|---|
| | | /** |
|---|
| | | * 错误报文 |
|---|
| | | */ |
|---|
