delivery_token.h

Go to the documentation of this file.

/*******************************************************************************
 * Copyright (c) 2013-2016 Frank Pagliughi <fpagliughi@mindspring.com>
 *
 * All rights reserved. This program and the accompanying materials
 * are made available under the terms of the Eclipse Public License v1.0
 * and Eclipse Distribution License v1.0 which accompany this distribution.
 *
 * The Eclipse Public License is available at
 *    http://www.eclipse.org/legal/epl-v10.html
 * and the Eclipse Distribution License is available at
 *   http://www.eclipse.org/org/documents/edl-v10.php.
 *
 * Contributors:
 *    Frank Pagliughi - initial implementation and documentation
 *******************************************************************************/

#ifndef __mqtt_delivery_token_h
#define __mqtt_delivery_token_h

#include "MQTTAsync.h"
#include "mqtt/token.h"
#include "mqtt/message.h"
#include <memory>

namespace mqtt {


class delivery_token : public token
{
    const_message_ptr msg_;

    friend class async_client;

    void set_message(const_message_ptr msg) { msg_ = msg; }

public:
    using ptr_t = std::shared_ptr<delivery_token>;
    using const_ptr_t = std::shared_ptr<delivery_token>;
    using weak_ptr_t = std::weak_ptr<delivery_token>;

    delivery_token(iasync_client& cli) : token(cli) {}
    delivery_token(iasync_client& cli, const_message_ptr msg)
            : token(cli, msg->get_topic()), msg_(std::move(msg)) {}
    delivery_token(iasync_client& cli, const_message_ptr msg,
                   void* userContext, iaction_listener& cb)
            : token(cli, msg->get_topic(), userContext, cb), msg_(std::move(msg)) {}
    static ptr_t create(iasync_client& cli) {
        return std::make_shared<delivery_token>(cli);
    }
    static ptr_t create(iasync_client& cli, const_message_ptr msg) {
        return std::make_shared<delivery_token>(cli, msg);
    }
    static ptr_t create(iasync_client& cli, const_message_ptr msg,
                        void* userContext, iaction_listener& cb) {
        return std::make_shared<delivery_token>(cli, msg, userContext, cb);
    }
    virtual const_message_ptr get_message() const { return msg_; }
};

using delivery_token_ptr = delivery_token::ptr_t;

using const_delivery_token_ptr = delivery_token::const_ptr_t;

// end namespace mqtt
}

#endif      // __mqtt_delivery_token_h