接口 CollectorQueue
-
- 所有已知实现类:
RangersCollectorQueue
public interface CollectorQueue
-
-
方法详细资料
-
take
List<Message> take() throws InterruptedException
功能描述: 从队列里消费一批message,没有过期时间,如果自行设置过期时间则需要在没有数据的时候返回null
-
poll
List<Message> poll(int waitTimeMs) throws InterruptedException
-
offer
boolean offer(Message t) throws InterruptedException
功能描述: 发送一个Message到队列中
-
size
int size()
-
-