add 分发 master_author 添加字段 subscribe increment， 添加7个表 master_author...

kimi

2020-04-22 5268a2b7dfa556bd6f5a2d5e446cea3ea9940c10

 src/main/java/com/highdatas/mdm/service/DispenseService.java

@@ -1,9 +1,8 @@
package com.highdatas.mdm.service;



import com.highdatas.mdm.pojo.Result;

import com.highdatas.mdm.util.pool.MqMessage;

import org.springframework.stereotype.Service;



import java.util.concurrent.PriorityBlockingQueue;



/**

 * @author kimi

@@ -16,9 +15,8 @@


    boolean pushActiveMq(MqMessage message);



    boolean pushPassiveMq(MqMessage message);

    Result pushPassiveMq(MqMessage message, String touchType);



    PriorityBlockingQueue<Runnable> getQueue();



    Integer passiveQueueSize();