io.jboot.components.mq.rocketmq

类 RokectmqMessageContext

java.lang.Object

io.jboot.components.mq.MessageContext

io.jboot.components.mq.rocketmq.RokectmqMessageContext

public class RokectmqMessageContext
extends MessageContext

字段概要

字段

限定符和类型	字段和说明
private org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyContext	context
private List<org.apache.rocketmq.common.message.MessageExt>	msgs
private org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyStatus	returnStatus

构造器概要

构造器

构造器和说明
RokectmqMessageContext(Jbootmq jbootmq, List<org.apache.rocketmq.common.message.MessageExt> msgs, org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyContext context)

方法概要

限定符和类型	方法和说明
org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyContext	getContext()
List<org.apache.rocketmq.common.message.MessageExt>	getMsgs()
org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyStatus	getReturnStatus()
void	setReturnStatus(org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyStatus returnStatus)

从类继承的方法 io.jboot.components.mq.MessageContext

getMq

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

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

字段详细资料

returnStatus

private org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyStatus returnStatus

msgs

private final List<org.apache.rocketmq.common.message.MessageExt> msgs

context

private final org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyContext context

构造器详细资料

RokectmqMessageContext

public RokectmqMessageContext(Jbootmq jbootmq,
                              List<org.apache.rocketmq.common.message.MessageExt> msgs,
                              org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyContext context)

方法详细资料

getReturnStatus

public org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyStatus getReturnStatus()

setReturnStatus

public void setReturnStatus(org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyStatus returnStatus)

getMsgs

public List<org.apache.rocketmq.common.message.MessageExt> getMsgs()

getContext

public org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyContext getContext()