Commit 3cdbf9f8 by 徐高华

队列名调整

parent 544fa2bc
...@@ -28,7 +28,6 @@ public interface DealSyncOperationApiService { ...@@ -28,7 +28,6 @@ public interface DealSyncOperationApiService {
/** /**
* mq拆分 * mq拆分
* 部门同步处理 * 部门同步处理
* "routerName": "departmentSyncDealMq2"
* *
* @param params * @param params
*/ */
......
...@@ -169,7 +169,7 @@ public class SelfFriendSyncNewOperation implements BaseSyncOperation { ...@@ -169,7 +169,7 @@ public class SelfFriendSyncNewOperation implements BaseSyncOperation {
GicMQClient clientInstance = GICMQClientUtil.getClientInstance(); GicMQClient clientInstance = GICMQClientUtil.getClientInstance();
try { try {
Log.info("发送队列SelfFriendSyncNewOperation={}",JSON.toJSONString(ret)); Log.info("发送队列SelfFriendSyncNewOperation={}",JSON.toJSONString(ret));
clientInstance.sendBatchMessages("departmentSyncDealMq2", ret); clientInstance.sendBatchMessages("departmentSyncDealMq", ret);
} catch (Exception e) { } catch (Exception e) {
logger.info("发送失败:{},{}", taskId); logger.info("发送失败:{},{}", taskId);
e.printStackTrace(); e.printStackTrace();
......
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