com.datarangers.asynccollector

接口 CollectorQueue

所有已知实现类:

RangersCollectorQueue

public interface CollectorQueue

方法概要

方法

限定符和类型	方法和说明
boolean	offer(Message t) 功能描述: 发送一个Message到队列中
List<Message>	poll(int waitTimeMs)
int	size()
List<Message>	take() 功能描述: 从队列里消费一批message，没有过期时间，如果自行设置过期时间则需要在没有数据的时候返回null

方法详细资料

take

List<Message> take()
                   throws InterruptedException

功能描述: 从队列里消费一批message，没有过期时间，如果自行设置过期时间则需要在没有数据的时候返回null

抛出:

InterruptedException

poll

List<Message> poll(int waitTimeMs)
                   throws InterruptedException

抛出:

InterruptedException

offer

boolean offer(Message t)
              throws InterruptedException

功能描述: 发送一个Message到队列中

抛出:

InterruptedException

size

int size()