142 lines
4.9 KiB
C++
142 lines
4.9 KiB
C++
/*
|
|
* 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.
|
|
*/
|
|
#ifndef __MESSAGE_H__
|
|
#define __MESSAGE_H__
|
|
|
|
#include <map>
|
|
#include <sstream>
|
|
#include <string>
|
|
#include <vector>
|
|
#include "RocketMQClient.h"
|
|
|
|
namespace rocketmq {
|
|
class ROCKETMQCLIENT_API MQMessage {
|
|
public:
|
|
MQMessage();
|
|
MQMessage(const std::string& topic, const std::string& body);
|
|
MQMessage(const std::string& topic, const std::string& tags, const std::string& body);
|
|
MQMessage(const std::string& topic, const std::string& tags, const std::string& keys, const std::string& body);
|
|
MQMessage(const std::string& topic,
|
|
const std::string& tags,
|
|
const std::string& keys,
|
|
const int flag,
|
|
const std::string& body,
|
|
bool waitStoreMsgOK);
|
|
|
|
virtual ~MQMessage();
|
|
MQMessage(const MQMessage& other);
|
|
MQMessage& operator=(const MQMessage& other);
|
|
|
|
void setProperty(const std::string& name, const std::string& value);
|
|
const std::string& getProperty(const std::string& name) const;
|
|
|
|
const std::string& getTopic() const;
|
|
void setTopic(const std::string& topic);
|
|
void setTopic(const char* body, int len);
|
|
|
|
const std::string& getTags() const;
|
|
void setTags(const std::string& tags);
|
|
|
|
const std::string& getKeys() const;
|
|
void setKeys(const std::string& keys);
|
|
void setKeys(const std::vector<std::string>& keys);
|
|
|
|
int getDelayTimeLevel() const;
|
|
void setDelayTimeLevel(int level);
|
|
|
|
bool isWaitStoreMsgOK() const;
|
|
void setWaitStoreMsgOK(bool waitStoreMsgOK);
|
|
|
|
int getFlag() const;
|
|
void setFlag(int flag);
|
|
|
|
int getSysFlag() const;
|
|
void setSysFlag(int sysFlag);
|
|
|
|
const std::string& getBody() const;
|
|
|
|
void setBody(const char* body, int len);
|
|
void setBody(const std::string& body);
|
|
|
|
void setTransactionId(const std::string& id) { m_transactionId = id; }
|
|
std::string getTransactionId() const { return m_transactionId; }
|
|
|
|
std::map<std::string, std::string> getProperties() const;
|
|
void setProperties(std::map<std::string, std::string>& properties);
|
|
|
|
const std::string toString() const {
|
|
std::stringstream ss;
|
|
std::string tags = getTags();
|
|
ss << "Message [topic=" << m_topic << ", flag=" << m_flag << ", tag=" << tags << "]";
|
|
return ss.str();
|
|
}
|
|
|
|
protected:
|
|
friend class MQDecoder;
|
|
void setPropertyInternal(const std::string& name, const std::string& value);
|
|
void setPropertiesInternal(std::map<std::string, std::string>& properties);
|
|
|
|
void Init(const std::string& topic,
|
|
const std::string& tags,
|
|
const std::string& keys,
|
|
const int flag,
|
|
const std::string& body,
|
|
bool waitStoreMsgOK);
|
|
|
|
public:
|
|
static const std::string PROPERTY_KEYS;
|
|
static const std::string PROPERTY_TAGS;
|
|
static const std::string PROPERTY_WAIT_STORE_MSG_OK;
|
|
static const std::string PROPERTY_DELAY_TIME_LEVEL;
|
|
static const std::string PROPERTY_RETRY_TOPIC;
|
|
static const std::string PROPERTY_REAL_TOPIC;
|
|
static const std::string PROPERTY_REAL_QUEUE_ID;
|
|
static const std::string PROPERTY_TRANSACTION_PREPARED;
|
|
static const std::string PROPERTY_PRODUCER_GROUP;
|
|
static const std::string PROPERTY_MIN_OFFSET;
|
|
static const std::string PROPERTY_MAX_OFFSET;
|
|
|
|
static const std::string PROPERTY_BUYER_ID;
|
|
static const std::string PROPERTY_ORIGIN_MESSAGE_ID;
|
|
static const std::string PROPERTY_TRANSFER_FLAG;
|
|
static const std::string PROPERTY_CORRECTION_FLAG;
|
|
static const std::string PROPERTY_MQ2_FLAG;
|
|
static const std::string PROPERTY_RECONSUME_TIME;
|
|
static const std::string PROPERTY_MSG_REGION;
|
|
static const std::string PROPERTY_TRACE_SWITCH;
|
|
static const std::string PROPERTY_UNIQ_CLIENT_MESSAGE_ID_KEYIDX;
|
|
static const std::string PROPERTY_MAX_RECONSUME_TIMES;
|
|
static const std::string PROPERTY_CONSUME_START_TIMESTAMP;
|
|
static const std::string PROPERTY_TRANSACTION_PREPARED_QUEUE_OFFSET;
|
|
static const std::string PROPERTY_TRANSACTION_CHECK_TIMES;
|
|
static const std::string PROPERTY_CHECK_IMMUNITY_TIME_IN_SECONDS;
|
|
|
|
static const std::string KEY_SEPARATOR;
|
|
|
|
protected:
|
|
int m_sysFlag;
|
|
|
|
private:
|
|
std::string m_topic;
|
|
int m_flag;
|
|
std::string m_body;
|
|
std::string m_transactionId;
|
|
std::map<std::string, std::string> m_properties;
|
|
};
|
|
} // namespace rocketmq
|
|
#endif
|