类 com.taobao.metamorphosis.Message
的使用

使用 Message 的软件包

com.taobao.metamorphosis
com.taobao.metamorphosis.client
com.taobao.metamorphosis.client.consumer
com.taobao.metamorphosis.client.extension.consumer
com.taobao.metamorphosis.client.extension.producer
com.taobao.metamorphosis.client.extension.spring
com.taobao.metamorphosis.client.producer
com.taobao.metamorphosis.consumer
com.taobao.metamorphosis.metaslave
com.taobao.metamorphosis.storm.spout
com.taobao.metamorphosis.tools.monitor.core
com.taobao.metamorphosis.utils

com.taobao.metamorphosis 中 Message 的使用

参数类型为 Message 的 com.taobao.metamorphosis 中的方法

static int	MessageAccessor.getFlag(Message message)
static boolean	MessageAccessor.isRollbackOnly(Message message)
static void	MessageAccessor.setFlag(Message message, int flag)
static void	MessageAccessor.setId(Message message, long id)
static void	MessageAccessor.setPartition(Message message, Partition partition)

com.taobao.metamorphosis.client 中 Message 的使用

返回 Message 的 com.taobao.metamorphosis.client 中的方法

Message

MetaTopicBrowser.Itr.next()

返回变量类型为 Message 的类型的 com.taobao.metamorphosis.client 中的方法

Iterator<Message>	TopicBrowser.iterator() Returns an iterator to iterate all messages under this topic from all alive brokers.The iteration order is from the smallest broker's smallest partition to the biggest broker's biggest partition.Everytime it returns a new iterator.
Iterator<Message>	MetaTopicBrowser.iterator()

com.taobao.metamorphosis.client.consumer 中 Message 的使用

返回 Message 的 com.taobao.metamorphosis.client.consumer 中的方法

Message	MessageIterator.getPrevMessage() 已过时。
Message	MessageIterator.next() 已过时。 返回下一个消息

参数类型为 Message 的 com.taobao.metamorphosis.client.consumer 中的方法

void	RecoverStorageManager.append(String group, Message message)
void	RecoverManager.append(String group, Message message) 存入一个消息
void	SimpleMessageConsumer.appendCouldNotProcessMessage(Message message)
void	InnerConsumer.appendCouldNotProcessMessage(Message message) 处理无法被客户端消费的消息
void	MessageListener.recieveMessages(Message message) 接收到消息，只有messages不为空并且不为null的情况下会触发此方法
void	SimpleMessageConsumer.DropPolicy.rejectConsumption(Message message, MessageConsumer messageConsumer)
void	SimpleMessageConsumer.LocalRecoverPolicy.rejectConsumption(Message message, MessageConsumer messageConsumer)
void	RejectConsumptionHandler.rejectConsumption(Message message, MessageConsumer messageConsumer) Method that may be invoked by a MessageConsumer when receiveMessages cannot process a message when retry too many times.

com.taobao.metamorphosis.client.extension.consumer 中 Message 的使用

参数类型为 Message 的 com.taobao.metamorphosis.client.extension.consumer 中的方法

void	RecoverNotifyManager.append(String group, Message message)

com.taobao.metamorphosis.client.extension.producer 中 Message 的使用

参数类型为 Message 的 com.taobao.metamorphosis.client.extension.producer 中的方法

void	MessageRecoverManager.append(Message message, Partition partition) 存入消息
void	LocalMessageStorageManager.append(Message message, Partition partition)
void	AsyncMetaMessageProducer.asyncSendMessage(Message message)
void	AsyncMessageProducer.asyncSendMessage(Message message) 异步发送消息.
void	AsyncMetaMessageProducer.asyncSendMessage(Message message, long timeout, TimeUnit unit)
void	AsyncMessageProducer.asyncSendMessage(Message message, long timeout, TimeUnit unit) 异步发送消息.
protected abstract Partition	OrderedMessagePartitionSelector.choosePartition(String topic, List<Partition> partitions, Message message)
Partition	OrderedMessagePartitionSelector.getPartition(String topic, List<Partition> partitions, Message message)
void	MessageRecoverManager.MessageRecoverer.handle(Message msg) recover出来的消息如何处理
void	AsyncMetaMessageProducer.handle(Message msg)
boolean	AsyncMessageProducer.IgnoreMessageProcessor.handle(Message message) 处理一条消息
protected BooleanCommand	AsyncMetaMessageProducer.invokeToGroup(String serverUrl, Partition partition, PutCommand putCommand, Message message, long timeout, TimeUnit unit)
SendResult	OrderedMessageProducer.sendMessage(Message message, long timeout, TimeUnit unit)

com.taobao.metamorphosis.client.extension.spring 中 Message 的使用

返回 Message 的 com.taobao.metamorphosis.client.extension.spring 中的方法

Message	MessageBuilder.build() Build a message.
<T> Message	MessageBuilder.build(MessageBodyConverter<T> converter) Build message by message body converter.
Message	MetaqMessage.getRawMessage() Returns the raw metaq message.

参数类型为 Message 的 com.taobao.metamorphosis.client.extension.spring 中的方法

void	DefaultMessageListener.recieveMessages(Message message)

参数类型为 Message 的 com.taobao.metamorphosis.client.extension.spring 中的构造方法

MetaqMessage(Message rawMessage, T body)

com.taobao.metamorphosis.client.producer 中 Message 的使用

参数类型为 Message 的 com.taobao.metamorphosis.client.producer 中的方法

protected void	SimpleMessageProducer.checkMessage(Message message)
Partition	PartitionSelector.getPartition(String topic, List<Partition> partitions, Message message) 根据topic、message从partitions列表中选择分区
Partition	AbstractPartitionSelector.getPartition(String topic, List<Partition> partitions, Message message)
Partition	RoundRobinPartitionSelector.getPartition0(String topic, List<Partition> partitions, Message message)
Partition	RandomPartitionSelector.getPartition0(String topic, List<Partition> partitions, Message message)
abstract Partition	AbstractPartitionSelector.getPartition0(String topic, List<Partition> partitions, Message message)
protected BooleanCommand	SimpleMessageProducer.invokeToGroup(String serverUrl, Partition partition, PutCommand putCommand, Message message, long timeout, TimeUnit unit)
Partition	ProducerZooKeeper.selectPartition(String topic, Message message, PartitionSelector partitionSelector) 根据topic和message选择分区
SendResult	SimpleMessageProducer.sendMessage(Message message)
SendResult	MessageProducer.sendMessage(Message message) 发送消息
SendResult	SimpleMessageProducer.sendMessage(Message message, long timeout, TimeUnit unit)
SendResult	MessageProducer.sendMessage(Message message, long timeout, TimeUnit unit) 发送消息,如果超出指定的时间内没有返回，则抛出异常
void	SimpleMessageProducer.sendMessage(Message message, SendMessageCallback cb)
void	MessageProducer.sendMessage(Message message, SendMessageCallback cb) 异步发送消息，在默认时间内（3秒）回调callback，此模式下无法使用事务
void	SimpleMessageProducer.sendMessage(Message message, SendMessageCallback cb, long time, TimeUnit unit)
void	MessageProducer.sendMessage(Message message, SendMessageCallback cb, long time, TimeUnit unit) 异步发送消息，在指定时间内回调callback,此模式下无法使用事务
protected SendResult	SimpleMessageProducer.sendMessageToServer(Message message, long timeout, TimeUnit unit) 正常的消息发送到服务器

com.taobao.metamorphosis.consumer 中 Message 的使用

返回 Message 的 com.taobao.metamorphosis.consumer 中的方法

Message	MessageIterator.getPrevMessage()
Message	MessageIterator.next() 返回下一个消息

参数类型为 Message 的 com.taobao.metamorphosis.consumer 中的方法

boolean

ConsumerMessageFilter.accept(String group, Message message) Test if the filter can accept a metaq message.Any exceptions threw by this method means the message is not accepted.This method must be thread-safe.

com.taobao.metamorphosis.metaslave 中 Message 的使用

参数类型为 Message 的 com.taobao.metamorphosis.metaslave 中的方法

void	MetaSlaveListener.recieveMessages(Message message)

com.taobao.metamorphosis.storm.spout 中 Message 的使用

声明为 Message 的 com.taobao.metamorphosis.storm.spout 中的字段

Message

MetaMessageWrapper.message

参数类型为 Message 的 com.taobao.metamorphosis.storm.spout 中的构造方法

MetaMessageWrapper(Message message)

com.taobao.metamorphosis.tools.monitor.core 中 Message 的使用

返回 Message 的 com.taobao.metamorphosis.tools.monitor.core 中的方法

Message

SendResultWrapper.getMessage()

返回变量类型为 Message 的类型的 com.taobao.metamorphosis.tools.monitor.core 中的方法

List<Message>

ReveiceResult.getMessages()

参数类型为 Message 的 com.taobao.metamorphosis.tools.monitor.core 中的方法

void	ReveiceResult.addMessage(Message message)
SendResultWrapper	SendResultWrapper.setMessage(Message message)

com.taobao.metamorphosis.utils 中 Message 的使用

声明为 Message 的 com.taobao.metamorphosis.utils 中的字段

Message

MessageUtils.DecodedMessage.message

参数类型为 Message 的 com.taobao.metamorphosis.utils 中的方法

static byte[]	MessageUtils.encodePayload(Message message) 将消息属性和消息payload打包，结构如下： 0或者1个定长attribute + payload
static int	MessageFlagUtils.getFlag(Message message)

参数类型为 Message 的 com.taobao.metamorphosis.utils 中的构造方法

MessageUtils.DecodedMessage(int newOffset, Message message, ByteBuffer buf)