| /* |
| * 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 "TopicConfig.h" |
| #include <stdlib.h> |
| #include <sstream> |
| #include "PermName.h" |
| |
| namespace rocketmq { |
| //<!*************************************************************************** |
| int TopicConfig::DefaultReadQueueNums = 16; |
| int TopicConfig::DefaultWriteQueueNums = 16; |
| string TopicConfig::SEPARATOR = " "; |
| |
| TopicConfig::TopicConfig() |
| : m_topicName(""), |
| m_readQueueNums(DefaultReadQueueNums), |
| m_writeQueueNums(DefaultWriteQueueNums), |
| m_perm(PermName::PERM_READ | PermName::PERM_WRITE), |
| m_topicFilterType(SINGLE_TAG) {} |
| |
| TopicConfig::TopicConfig(const string& topicName) |
| : m_topicName(topicName), |
| m_readQueueNums(DefaultReadQueueNums), |
| m_writeQueueNums(DefaultWriteQueueNums), |
| m_perm(PermName::PERM_READ | PermName::PERM_WRITE), |
| m_topicFilterType(SINGLE_TAG) {} |
| |
| TopicConfig::TopicConfig(const string& topicName, int readQueueNums, |
| int writeQueueNums, int perm) |
| : m_topicName(topicName), |
| m_readQueueNums(readQueueNums), |
| m_writeQueueNums(writeQueueNums), |
| m_perm(perm), |
| m_topicFilterType(SINGLE_TAG) {} |
| |
| TopicConfig::~TopicConfig() {} |
| |
| string TopicConfig::encode() { |
| stringstream ss; |
| ss << m_topicName << SEPARATOR << m_readQueueNums << SEPARATOR |
| << m_writeQueueNums << SEPARATOR << m_perm << SEPARATOR |
| << m_topicFilterType; |
| |
| return ss.str(); |
| } |
| |
| bool TopicConfig::decode(const string& in) { |
| stringstream ss(in); |
| |
| ss >> m_topicName; |
| ss >> m_readQueueNums; |
| ss >> m_writeQueueNums; |
| ss >> m_perm; |
| |
| int type; |
| ss >> type; |
| m_topicFilterType = (TopicFilterType)type; |
| |
| return true; |
| } |
| |
| const string& TopicConfig::getTopicName() { return m_topicName; } |
| |
| void TopicConfig::setTopicName(const string& topicName) { |
| m_topicName = topicName; |
| } |
| |
| int TopicConfig::getReadQueueNums() { return m_readQueueNums; } |
| |
| void TopicConfig::setReadQueueNums(int readQueueNums) { |
| m_readQueueNums = readQueueNums; |
| } |
| |
| int TopicConfig::getWriteQueueNums() { return m_writeQueueNums; } |
| |
| void TopicConfig::setWriteQueueNums(int writeQueueNums) { |
| m_writeQueueNums = writeQueueNums; |
| } |
| |
| int TopicConfig::getPerm() { return m_perm; } |
| |
| void TopicConfig::setPerm(int perm) { m_perm = perm; } |
| |
| TopicFilterType TopicConfig::getTopicFilterType() { return m_topicFilterType; } |
| |
| void TopicConfig::setTopicFilterType(TopicFilterType topicFilterType) { |
| m_topicFilterType = topicFilterType; |
| } |
| //<!*************************************************************************** |
| } //<!end namespace; |