接口的使用
com.datarangers.message.Message
-
使用Message的程序包 程序包 说明 com.datarangers.asynccollector com.datarangers.collector com.datarangers.message -
-
com.datarangers.asynccollector中Message的使用
返回变量类型为Message的类型的com.datarangers.asynccollector中的方法 修饰符和类型 方法 说明 List<Message>CollectorContainer. consume()List<Message>CollectorContainer. consume(int waitTimeMs)List<Message>CollectorQueue. poll(int waitTimeMs)List<Message>RangersCollectorQueue. poll(int waitTimeMs)List<Message>CollectorQueue. take()功能描述: 从队列里消费一批message，没有过期时间，如果自行设置过期时间则需要在没有数据的时候返回nullList<Message>RangersCollectorQueue. take()参数类型为Message的com.datarangers.asynccollector中的方法 修饰符和类型 方法 说明 booleanCollectorQueue. offer(Message t)功能描述: 发送一个Message到队列中booleanRangersCollectorQueue. offer(Message t)booleanCollectorContainer. produce(Message message) -
com.datarangers.collector中Message的使用
参数类型为Message的com.datarangers.collector中的方法 修饰符和类型 方法 说明 voidCollector. send(Message message)protected voidCollector. sendMessage(Message message) -
com.datarangers.message中Message的使用
实现Message的com.datarangers.message中的类 修饰符和类型 类 说明 classAppMessage
-