Commit 1766db7f authored by hezhen's avatar hezhen

Merge branch 'master-tiande' into dev-tiande

parents 76faa405 952ace6e
...@@ -20,7 +20,7 @@ import java.util.Map; ...@@ -20,7 +20,7 @@ import java.util.Map;
import java.util.concurrent.ExecutorService; import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors; import java.util.concurrent.Executors;
import static com.github.wxiaoqi.security.admin.config.RabbitAdminConfig.CORPORATION_UPD_QUEUE; import static com.github.wxiaoqi.security.admin.config.RabbitAdminConfig.*;
@Component @Component
@Slf4j @Slf4j
...@@ -35,7 +35,7 @@ public class BranchCompanyMQHandler { ...@@ -35,7 +35,7 @@ public class BranchCompanyMQHandler {
* 同步门店信息 * 同步门店信息
* @param * @param
*/ */
@RabbitListener(queues = CORPORATION_UPD_QUEUE) @RabbitListener(queues = COMPANY_UPD_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)); log.info("同步门店信息 messageJson:"+ JSONUtil.parse(message));
ExecutorService executorService = Executors.newCachedThreadPool(); ExecutorService executorService = Executors.newCachedThreadPool();
......
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