io.openmessaging.joyqueue.consumer.message

类 MessageHeaderAdapter

java.lang.Object

io.openmessaging.joyqueue.consumer.message.MessageHeaderAdapter

所有已实现的接口:

io.openmessaging.message.Header

public class MessageHeaderAdapter
extends Object
implements io.openmessaging.message.Header

MessageHeaderAdapter author: gaohaoxiang date: 2019/3/1

构造器概要

构造器

构造器和说明
MessageHeaderAdapter(ConsumeMessage message)

方法概要

限定符和类型	方法和说明
String	getBornHost()
long	getBornTimestamp()
short	getCompression()
int	getDeliveryCount()
String	getDestination()
short	getDurability()
String	getMessageId()
short	getPriority()
io.openmessaging.message.Header	setBornHost(String bornHost)
io.openmessaging.message.Header	setBornTimestamp(long bornTimestamp)
io.openmessaging.message.Header	setCompression(short compression)
io.openmessaging.message.Header	setDeliveryCount(int deliveryCount)
io.openmessaging.message.Header	setDestination(String destination)
io.openmessaging.message.Header	setDurability(short durability)
io.openmessaging.message.Header	setMessageId(String messageId)
io.openmessaging.message.Header	setPriority(short priority)

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

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

构造器详细资料

MessageHeaderAdapter

public MessageHeaderAdapter(ConsumeMessage message)

方法详细资料

setDestination

public io.openmessaging.message.Header setDestination(String destination)

指定者:

setDestination 在接口中 io.openmessaging.message.Header

setMessageId

public io.openmessaging.message.Header setMessageId(String messageId)

指定者:

setMessageId 在接口中 io.openmessaging.message.Header

setBornTimestamp

public io.openmessaging.message.Header setBornTimestamp(long bornTimestamp)

指定者:

setBornTimestamp 在接口中 io.openmessaging.message.Header

setBornHost

public io.openmessaging.message.Header setBornHost(String bornHost)

指定者:

setBornHost 在接口中 io.openmessaging.message.Header

setPriority

public io.openmessaging.message.Header setPriority(short priority)

指定者:

setPriority 在接口中 io.openmessaging.message.Header

setDurability

public io.openmessaging.message.Header setDurability(short durability)

指定者:

setDurability 在接口中 io.openmessaging.message.Header

setDeliveryCount

public io.openmessaging.message.Header setDeliveryCount(int deliveryCount)

指定者:

setDeliveryCount 在接口中 io.openmessaging.message.Header

setCompression

public io.openmessaging.message.Header setCompression(short compression)

指定者:

setCompression 在接口中 io.openmessaging.message.Header

getDestination

public String getDestination()

指定者:

getDestination 在接口中 io.openmessaging.message.Header

getMessageId

public String getMessageId()

指定者:

getMessageId 在接口中 io.openmessaging.message.Header

getBornTimestamp

public long getBornTimestamp()

指定者:

getBornTimestamp 在接口中 io.openmessaging.message.Header

getBornHost

public String getBornHost()

指定者:

getBornHost 在接口中 io.openmessaging.message.Header

getPriority

public short getPriority()

指定者:

getPriority 在接口中 io.openmessaging.message.Header

getDurability

public short getDurability()

指定者:

getDurability 在接口中 io.openmessaging.message.Header

getDeliveryCount

public int getDeliveryCount()

指定者:

getDeliveryCount 在接口中 io.openmessaging.message.Header

getCompression

public short getCompression()

指定者:

getCompression 在接口中 io.openmessaging.message.Header