软件包 net.neoremind.fountain.common.mq

接口摘要
FountainMQ fountain需要的内存mq的抽象描述。
 

类摘要
AbstractMaxCapacityFountainMQ 内存队列实现的抽象类.
MemFountainMQ FountainMQ缺省实现,每个放入队列的对象 占用队列容量数为1

封装BlockingQueue,必须有界,这是为了防止内存oom

MultiPermitsMemFountainMQ 每个数据消息占用多个队列容量的队列。
 



Copyright © 2016 neoremind. All rights reserved.