接口 CollectorQueue

    • 方法概要

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