com.alibaba.rocketmq.common.message

类 Message

java.lang.Object

com.alibaba.rocketmq.common.message.Message

所有已实现的接口:

Serializable

直接已知子类:

MessageExt

public class Message
extends Object
implements Serializable

消息，Producer与Consumer使用

从以下版本开始:

2013-7-18

作者:

shijia.wxr

另请参阅:

序列化表格

构造器概要

构造器

构造器和说明
Message()
Message(String topic, byte[] body)
Message(String topic, String tags, byte[] body)
Message(String topic, String tags, String keys, byte[] body)
Message(String topic, String tags, String keys, int flag, byte[] body, boolean waitStoreMsgOK)

方法概要

方法

限定符和类型	方法和说明
byte[]	getBody()
String	getBuyerId()
int	getDelayTimeLevel()
int	getFlag()
String	getKeys()
Map<String,String>	getProperties()
String	getProperty(String name)
String	getTags()
String	getTopic()
String	getUserProperty(String name)
boolean	isWaitStoreMsgOK()
void	putUserProperty(String name, String value)
void	setBody(byte[] body)
void	setBuyerId(String buyerId)
void	setDelayTimeLevel(int level)
void	setFlag(int flag)
void	setKeys(Collection<String> keys)
void	setKeys(String keys)
void	setTags(String tags)
void	setTopic(String topic)
void	setWaitStoreMsgOK(boolean waitStoreMsgOK)
String	toString()

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

构造器详细资料

Message

public Message()

Message

public Message(String topic,
       byte[] body)

Message

public Message(String topic,
       String tags,
       byte[] body)

Message

public Message(String topic,
       String tags,
       String keys,
       byte[] body)

Message

public Message(String topic,
       String tags,
       String keys,
       int flag,
       byte[] body,
       boolean waitStoreMsgOK)

方法详细资料

putUserProperty

public void putUserProperty(String name,
                   String value)

getUserProperty

public String getUserProperty(String name)

getProperty

public String getProperty(String name)

getTopic

public String getTopic()

setTopic

public void setTopic(String topic)

getTags

public String getTags()

setTags

public void setTags(String tags)

getKeys

public String getKeys()

setKeys

public void setKeys(String keys)

setKeys

public void setKeys(Collection<String> keys)

getDelayTimeLevel

public int getDelayTimeLevel()

setDelayTimeLevel

public void setDelayTimeLevel(int level)

isWaitStoreMsgOK

public boolean isWaitStoreMsgOK()

setWaitStoreMsgOK

public void setWaitStoreMsgOK(boolean waitStoreMsgOK)

getFlag

public int getFlag()

setFlag

public void setFlag(int flag)

getBody

public byte[] getBody()

setBody

public void setBody(byte[] body)

getProperties

public Map<String,String> getProperties()

setBuyerId

public void setBuyerId(String buyerId)

getBuyerId

public String getBuyerId()

toString

public String toString()

覆盖:

toString 在类中 Object