MigratoryDataMessage.h

Go to the documentation of this file.

/*
 * Copyright (c) 2007-2014 Migratory Data Systems (http://migratorydata.com)
 * ALL RIGHTS RESERVED. Use is subject to license terms.
 */
#ifndef _Message_h_included_
#define _Message_h_included_

#include "MigratoryDataField.h"
#include <vector>
#include <string>

namespace migratorydata 
{

    class MigratoryDataMessage
    {

    private :
        std::string subject;
        std::string content;
        std::string closure;
        std::vector<MigratoryDataField> fields;
        std::string replyToSubject;

    protected:
        bool snapshot;
        bool recovery;
        int seq;
        int epoch;

    public :

        MigratoryDataMessage();

        MigratoryDataMessage(const MigratoryDataMessage& message);

        MigratoryDataMessage(const std::string& subject, const std::string& content);
        
        MigratoryDataMessage(const std::string& subject, const std::string& content, const std::string& closure);

        MigratoryDataMessage(const std::string& subject, const std::string& content, std::vector<MigratoryDataField>& fields);

        MigratoryDataMessage(const std::string& subject, const std::string& content, std::vector<MigratoryDataField>& fields, const std::string& closure);

        std::string getSubject() const;
        
        std::string getContent() const;
        
        std::vector<MigratoryDataField> getFields() const;

        std::string getClosure() const;

        bool isSnapshot() const;

        void setReplyTosubject(std::string& replyToSubject);

        std::string getReplyToSubject() const;
        
        virtual ~MigratoryDataMessage();
        
        bool isRecovery() const;

        int getSeq() const;

        int getEpoch() const;
    };
}

#endif // _Message_h_included_