merage

kimi

2020-05-27 c007f0ca1785db093d48f4846cda82fe8e955765

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

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



import com.highdatas.mdm.entity.SysDispenseLogs;

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

@@ -14,11 +14,16 @@
@Service

public interface DispenseService {



    Boolean getAes();



    String getAesUrl();



    boolean pushActiveMq(MqMessage message);



    boolean pushPassiveMq(MqMessage message);

    boolean pushActiveMq(MqMessage message, String touchType);



    PriorityBlockingQueue<Runnable> getQueue();

    Result pushPassiveMq(MqMessage message, String touchType, SysDispenseLogs logs);





    Integer passiveQueueSize();