ConsumeMessageContext.cpp

/*
 * Licensed to the Apache Software Foundation (ASF) under one or more
 * contributor license agreements.  See the NOTICE file distributed with
 * this work for additional information regarding copyright ownership.
 * The ASF licenses this file to You under the Apache License, Version 2.0
 * (the "License"); you may not use this file except in compliance with
 * the License.  You may obtain a copy of the License at
 *
 *     http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

#include "ConsumeMessageContext.h"
#include <string>
#include <vector>
#include "DefaultMQPushConsumerImpl.h"

namespace rocketmq {
ConsumeMessageContext::ConsumeMessageContext() {
  m_defaultMQPushConsumer = NULL;
  // m_traceContext = NULL;
}
ConsumeMessageContext::~ConsumeMessageContext() {
  m_traceContext.reset();
}
std::string ConsumeMessageContext::getConsumerGroup() {
  return m_consumerGroup;
}

void ConsumeMessageContext::setConsumerGroup(const std::string& mConsumerGroup) {
  m_consumerGroup = mConsumerGroup;
}

bool ConsumeMessageContext::getSuccess() {
  return m_success;
}

void ConsumeMessageContext::setSuccess(bool mSuccess) {
  m_success = mSuccess;
}

std::vector<MQMessageExt> ConsumeMessageContext::getMsgList() {
  return m_msgList;
}

void ConsumeMessageContext::setMsgList(std::vector<MQMessageExt> mMsgList) {
  m_msgList = mMsgList;
}

std::string ConsumeMessageContext::getStatus() {
  return m_status;
}

void ConsumeMessageContext::setStatus(const std::string& mStatus) {
  m_status = mStatus;
}

int ConsumeMessageContext::getMsgIndex() {
  return m_msgIndex;
}

void ConsumeMessageContext::setMsgIndex(int mMsgIndex) {
  m_msgIndex = mMsgIndex;
}

MQMessageQueue ConsumeMessageContext::getMessageQueue() {
  return m_messageQueue;
}

void ConsumeMessageContext::setMessageQueue(const MQMessageQueue& mMessageQueue) {
  m_messageQueue = mMessageQueue;
}

DefaultMQPushConsumerImpl* ConsumeMessageContext::getDefaultMQPushConsumer() {
  return m_defaultMQPushConsumer;
}

void ConsumeMessageContext::setDefaultMQPushConsumer(DefaultMQPushConsumerImpl* mDefaultMqPushConsumer) {
  m_defaultMQPushConsumer = mDefaultMqPushConsumer;
}

std::shared_ptr<TraceContext> ConsumeMessageContext::getTraceContext() {
  return m_traceContext;
}

void ConsumeMessageContext::setTraceContext(TraceContext* mTraceContext) {
  m_traceContext.reset(mTraceContext);
}

std::map<std::string, std::string> ConsumeMessageContext::getProps() {
  return m_props;
}

void ConsumeMessageContext::setProps(std::map<std::string, std::string>& props) {
  m_props = props;
}

std::string ConsumeMessageContext::getClientId() {
  return m_clientId;
}

void ConsumeMessageContext::setClientId(const std::string& clientId) {
  m_clientId = clientId;
}

std::string ConsumeMessageContext::getNameSpace() {
  return m_nameSpace;
}

void ConsumeMessageContext::setNameSpace(const std::string& mNameSpace) {
  m_nameSpace = mNameSpace;
}
}  // namespace rocketmq