package com.highdatas.mdm.service;
|
|
import com.highdatas.mdm.util.pool.MqMessage;
|
import org.springframework.stereotype.Service;
|
|
import java.util.concurrent.PriorityBlockingQueue;
|
|
/**
|
* @author kimi
|
* @description
|
* @date 2020-04-14 12:53
|
*/
|
|
@Service
|
public interface DispenseService {
|
|
boolean pushActiveMq(MqMessage message);
|
|
boolean pushPassiveMq(MqMessage message);
|
|
PriorityBlockingQueue<Runnable> getQueue();
|
|
Integer passiveQueueSize();
|
|
Integer avtiveQueueSize();
|
}
|
