类 com.datarangers.message.Message
的使用

使用Message的程序包

程序包	说明
com.datarangers.asynccollector
com.datarangers.collector
com.datarangers.message.saas
com.datarangers.sender
com.datarangers.sender.saas

com.datarangers.asynccollector中Message的使用

返回变量类型为Message的类型的com.datarangers.asynccollector中的方法

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

参数类型为Message的com.datarangers.asynccollector中的方法

限定符和类型	方法和说明
boolean	RangersCollectorQueue.offer(Message t)
boolean	CollectorQueue.offer(Message t) 功能描述: 发送一个Message到队列中
boolean	CollectorContainer.produce(Message message)

com.datarangers.collector中Message的使用

参数类型为Message的com.datarangers.collector中的方法

限定符和类型	方法和说明
void	Collector.send(Message message)
protected void	Collector.sendMessage(Message message)

com.datarangers.message.saas中Message的使用

参数类型为Message的com.datarangers.message.saas中的构造器

构造器和说明
SaasProfileAppMessage(Message message)
SaasServerAppMessage(Message message)

com.datarangers.sender中Message的使用

参数类型为Message的com.datarangers.sender中的方法

限定符和类型	方法和说明
static MessageSender	MessageSenderFactory.getMessageSender(Message message)
void	MessageSender.senderMessage(Message message, DataRangersSDKConfigProperties sdkConfigProperties) 发送消息
void	PrivatizationMessageSender.senderMessage(Message message, DataRangersSDKConfigProperties sdkConfigProperties)

com.datarangers.sender.saas中Message的使用

参数类型为Message的com.datarangers.sender.saas中的方法

限定符和类型	方法和说明
void	SaasServerAppMessageSender.senderMessage(Message message, DataRangersSDKConfigProperties sdkConfigProperties)
void	SaasItemAppMessageSender.senderMessage(Message message, DataRangersSDKConfigProperties sdkConfigProperties)
void	SaasProfileAppMessageSender.senderMessage(Message message, DataRangersSDKConfigProperties sdkConfigProperties)