/*
 * 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 "MQMessageQueue.h"

namespace rocketmq {
//<!************************************************************************
MQMessageQueue::MQMessageQueue() {
  m_queueId = -1;  // invalide mq
  m_topic.clear();
  m_brokerName.clear();
}

MQMessageQueue::MQMessageQueue(const std::string& topic, const std::string& brokerName,
                               int queueId)
    : m_topic(topic), m_brokerName(brokerName), m_queueId(queueId) {}

MQMessageQueue::MQMessageQueue(const MQMessageQueue& other)
    : m_topic(other.m_topic),
      m_brokerName(other.m_brokerName),
      m_queueId(other.m_queueId) {}

MQMessageQueue& MQMessageQueue::operator=(const MQMessageQueue& other) {
  if (this != &other) {
    m_brokerName = other.m_brokerName;
    m_topic = other.m_topic;
    m_queueId = other.m_queueId;
  }
  return *this;
}

std::string MQMessageQueue::getTopic() const { return m_topic; }

void MQMessageQueue::setTopic(const std::string& topic) { m_topic = topic; }

std::string MQMessageQueue::getBrokerName() const { return m_brokerName; }

void MQMessageQueue::setBrokerName(const std::string& brokerName) {
  m_brokerName = brokerName;
}

int MQMessageQueue::getQueueId() const { return m_queueId; }

void MQMessageQueue::setQueueId(int queueId) { m_queueId = queueId; }

bool MQMessageQueue::operator==(const MQMessageQueue& mq) const {
  if (this == &mq) {
    return true;
  }

  if (m_brokerName != mq.m_brokerName) {
    return false;
  }

  if (m_queueId != mq.m_queueId) {
    return false;
  }

  if (m_topic != mq.m_topic) {
    return false;
  }

  return true;
}

int MQMessageQueue::compareTo(const MQMessageQueue& mq) const {
  int result = m_topic.compare(mq.m_topic);
  if (result != 0) {
    return result;
  }

  result = m_brokerName.compare(mq.m_brokerName);
  if (result != 0) {
    return result;
  }

  return m_queueId - mq.m_queueId;
}

bool MQMessageQueue::operator<(const MQMessageQueue& mq) const {
  return compareTo(mq) < 0;
}

//<!***************************************************************************
}  //<!end namespace;