org.joyqueue.client.internal.producer.domain

类 ProduceMessage

java.lang.Object

org.joyqueue.client.internal.producer.domain.ProduceMessage

所有已实现的接口:

Serializable

直接已知子类:

OMSProduceMessage

public class ProduceMessage
extends Object
implements Serializable

ProduceMessageRequest author: gaohaoxiang date: 2018/12/10

另请参阅:

序列化表格

字段概要

字段

限定符和类型	字段和说明
static short	NONE_PARTITION
static String	NONE_PARTITION_KEY

构造器概要

构造器

构造器和说明
ProduceMessage()
ProduceMessage(String topic, String body)
ProduceMessage(String topic, String body, String businessId)
ProduceMessage(String topic, String body, String businessId, String partitionKey)

方法概要

限定符和类型	方法和说明
boolean	containsAttribute(String key)
String	getAttribute(String key)
Map<String,String>	getAttributes()
String	getBody()
byte[]	getBodyBytes()
String	getBusinessId()
short	getFlag()
short	getPartition()
String	getPartitionKey()
byte	getPriority()
String	getTopic()
boolean	putAttribute(String key, String value)
void	setAttributes(Map<String,String> attributes)
void	setBody(String body)
void	setBodyBytes(byte[] bodyBytes)
void	setBusinessId(String businessId)
void	setFlag(short flag)
void	setPartition(short partition)
void	setPartitionKey(String partitionKey)
void	setPriority(byte priority)
void	setTopic(String topic)
String	toString()

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

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

字段详细资料

NONE_PARTITION

public static final short NONE_PARTITION

另请参阅:

常量字段值

NONE_PARTITION_KEY

public static final String NONE_PARTITION_KEY

构造器详细资料

ProduceMessage

public ProduceMessage()

ProduceMessage

public ProduceMessage(String topic,
                      String body)

ProduceMessage

public ProduceMessage(String topic,
                      String body,
                      String businessId)

ProduceMessage

public ProduceMessage(String topic,
                      String body,
                      String businessId,
                      String partitionKey)

方法详细资料

getTopic

public String getTopic()

setTopic

public void setTopic(String topic)

getBody

public String getBody()

setBody

public void setBody(String body)

getBodyBytes

public byte[] getBodyBytes()

setBodyBytes

public void setBodyBytes(byte[] bodyBytes)

getPartition

public short getPartition()

setPartition

public void setPartition(short partition)

getPartitionKey

public String getPartitionKey()

setPartitionKey

public void setPartitionKey(String partitionKey)

getBusinessId

public String getBusinessId()

setBusinessId

public void setBusinessId(String businessId)

getPriority

public byte getPriority()

setPriority

public void setPriority(byte priority)

setFlag

public void setFlag(short flag)

getFlag

public short getFlag()

getAttributes

public Map<String,String> getAttributes()

setAttributes

public void setAttributes(Map<String,String> attributes)

putAttribute

public boolean putAttribute(String key,
                            String value)

getAttribute

public String getAttribute(String key)

containsAttribute

public boolean containsAttribute(String key)

toString

public String toString()

覆盖:

toString 在类中 Object