001package io.jboot.components.mq.rocketmq;
002
003import io.jboot.components.mq.MessageContext;
004import io.jboot.components.mq.Jbootmq;
005import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyContext;
006import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyStatus;
007import org.apache.rocketmq.common.message.MessageExt;
008
009import java.util.List;
010
011public class RokectmqMessageContext extends MessageContext {
012
013    private ConsumeConcurrentlyStatus returnStatus = ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
014    private final List<MessageExt> msgs;
015    private final ConsumeConcurrentlyContext context;
016
017    public RokectmqMessageContext(Jbootmq jbootmq, List<MessageExt> msgs, ConsumeConcurrentlyContext context) {
018        super(jbootmq);
019        this.msgs = msgs;
020        this.context = context;
021    }
022
023    public ConsumeConcurrentlyStatus getReturnStatus() {
024        return returnStatus;
025    }
026
027    public void setReturnStatus(ConsumeConcurrentlyStatus returnStatus) {
028        this.returnStatus = returnStatus;
029    }
030
031    public List<MessageExt> getMsgs() {
032        return msgs;
033    }
034
035    public ConsumeConcurrentlyContext getContext() {
036        return context;
037    }
038}