/*
 * 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 "MessageQueueONS.h"
#include "ONSClientException.h"
#include "UtilAll.h"

namespace ons {
    MessageQueueONS::MessageQueueONS() {
        m_queueId = -1;//invalide mq
        m_topic.clear();
        m_brokerName.clear();
    }

    MessageQueueONS::MessageQueueONS(const string &topic,
                                     const string &brokerName,
                                     int queueId) :
            m_topic(topic),
            m_brokerName(brokerName),
            m_queueId(queueId) {

    }

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

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

    string MessageQueueONS::getTopic() const {
        return m_topic;
    }

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

    string MessageQueueONS::getBrokerName() const {
        return m_brokerName;
    }

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

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

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

    bool MessageQueueONS::operator==(const MessageQueueONS &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 MessageQueueONS::compareTo(const MessageQueueONS &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 MessageQueueONS::operator<(const MessageQueueONS &mq) const {
        return compareTo(mq) < 0;
    }

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