Commit 0cc595ff authored by jiaorz's avatar jiaorz

Merge remote-tracking branch 'origin/dev' into dev

parents d73efe5b aef33454
...@@ -42,6 +42,7 @@ public class WaterMQHandler { ...@@ -42,6 +42,7 @@ public class WaterMQHandler {
*/ */
@RabbitListener(queues = ORDER_WATER_QUEUE) @RabbitListener(queues = ORDER_WATER_QUEUE)
public void integralHandler(Message message, @Headers Map<String, Object> headers, Channel channel) { public void integralHandler(Message message, @Headers Map<String, Object> headers, Channel channel) {
log.info("拥金队列 messageJson:"+ JSONUtil.parse(message));
ExecutorService executorService = Executors.newCachedThreadPool(); ExecutorService executorService = Executors.newCachedThreadPool();
executorService.execute(new Runnable() { executorService.execute(new Runnable() {
@Override @Override
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment