io.openmessaging.joyqueue.producer.message

类 MessageAdapter

java.lang.Object

io.openmessaging.joyqueue.producer.message.MessageAdapter

所有已实现的接口:

ExtensionMessage, io.openmessaging.message.Message

public class MessageAdapter
extends Object
implements ExtensionMessage

MessageAdapter author: gaohaoxiang date: 2019/3/1

构造器概要

构造器

构造器和说明
MessageAdapter(ProduceMessage message)

方法概要

限定符和类型	方法和说明
Optional<io.openmessaging.extension.ExtensionHeader>	extensionHeader()
byte[]	getData()
io.openmessaging.consumer.MessageReceipt	getMessageReceipt()
ProduceMessage	getProduceMessage()
String	getStringData()
io.openmessaging.message.Header	header()
io.openmessaging.KeyValue	properties()
void	setData(byte[] data)
void	setStringData(String data)
String	toString()

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

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

构造器详细资料

MessageAdapter

public MessageAdapter(ProduceMessage message)

方法详细资料

header

public io.openmessaging.message.Header header()

指定者:

header 在接口中 io.openmessaging.message.Message

extensionHeader

public Optional<io.openmessaging.extension.ExtensionHeader> extensionHeader()

指定者:

extensionHeader 在接口中 io.openmessaging.message.Message

properties

public io.openmessaging.KeyValue properties()

指定者:

properties 在接口中 io.openmessaging.message.Message

getData

public byte[] getData()

指定者:

getData 在接口中 io.openmessaging.message.Message

setData

public void setData(byte[] data)

指定者:

setData 在接口中 io.openmessaging.message.Message

setStringData

public void setStringData(String data)

指定者:

setStringData 在接口中 ExtensionMessage

getStringData

public String getStringData()

指定者:

getStringData 在接口中 ExtensionMessage

getMessageReceipt

public io.openmessaging.consumer.MessageReceipt getMessageReceipt()

指定者:

getMessageReceipt 在接口中 io.openmessaging.message.Message

toString

public String toString()

覆盖:

toString 在类中 Object

getProduceMessage

public ProduceMessage getProduceMessage()