From c007f0ca1785db093d48f4846cda82fe8e955765 Mon Sep 17 00:00:00 2001 From: kimi <kimi42345@gmail.com> Date: 星期三, 27 五月 2020 09:59:29 +0800 Subject: [PATCH] merage --- src/main/java/com/highdatas/mdm/service/DispenseService.java | 13 +++++++++---- 1 files changed, 9 insertions(+), 4 deletions(-) diff --git a/src/main/java/com/highdatas/mdm/service/DispenseService.java b/src/main/java/com/highdatas/mdm/service/DispenseService.java index 740614e..43c60b6 100644 --- a/src/main/java/com/highdatas/mdm/service/DispenseService.java +++ b/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(); -- Gitblit v1.8.0