001package io.jboot.components.mq.aliyunmq;
002
003import com.aliyun.openservices.ons.api.Action;
004import com.aliyun.openservices.ons.api.ConsumeContext;
005import com.aliyun.openservices.ons.api.Message;
006import io.jboot.components.mq.MessageContext;
007import io.jboot.components.mq.Jbootmq;
008
009public class AliyunmqMessageContext extends MessageContext {
010
011    final Message orginalMessage;
012    final ConsumeContext context;
013    private Action returnAction = Action.CommitMessage;
014
015    public AliyunmqMessageContext(Jbootmq mq, Message orginalMessage, ConsumeContext context) {
016        super(mq);
017        this.orginalMessage = orginalMessage;
018        this.context = context;
019    }
020
021    public Message getOrginalMessage() {
022        return orginalMessage;
023    }
024
025    public ConsumeContext getContext() {
026        return context;
027    }
028
029    public Action getReturnAction() {
030        return returnAction;
031    }
032
033    public void setReturnAction(Action returnAction) {
034        this.returnAction = returnAction;
035    }
036}