MigratoryDataClient.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 _MigratoryDataClient_h_included_
#define _MigratoryDataClient_h_included_

#include <vector>
#include <string>

#include "MigratoryDataLogLevel.h"
#include "MigratoryDataListener.h"

namespace migratorydata 
{

    class MigratoryDataLogListener;
    class PushClientImpl;

    class MigratoryDataClient 
    {

    private :
        PushClientImpl* clientImpl;

    public :

        const std::string NOTIFY_SERVER_UP;

        const std::string NOTIFY_SERVER_DOWN;

        const std::string NOTIFY_DATA_SYNC;

        const std::string NOTIFY_DATA_RESYNC;

        const std::string NOTIFY_SUBSCRIBE_ALLOW;

        const std::string NOTIFY_SUBSCRIBE_DENY;

        const std::string NOTIFY_SUBSCRIBE_TIMEOUT;

        const std::string NOTIFY_PUBLISH_DENIED;

        const std::string NOTIFY_PUBLISH_NO_SUBSCRIBER;

        const std::string NOTIFY_PUBLISH_OK;

        const std::string NOTIFY_PUBLISH_FAILED;

        const std::string NOTIFY_RECONNECT_RATE_EXCEEDED;

        const std::string CONSTANT_WINDOW_BACKOFF;

        const std::string TRUNCATED_EXPONENTIAL_BACKOFF;

        MigratoryDataClient();

        void setLogListener(MigratoryDataLogListener* logListener);

        void setLogLevel(MigratoryDataLogLevel logLevel);
        
#if !defined (SSL_DISABLED)
        void setEncryption(bool encryption);

#endif
        void setListener(MigratoryDataListener* listener);

        void setServers(std::vector<std::string>& servers);

        void subscribe(std::vector<std::string>& subjects);

        void subscribeWithConflation(std::vector<std::string>& subjects, int conflationMillis);

        void unsubscribe(std::vector<std::string>& subjects);

        void setEntitlementToken(std::string& token);

        void getSubjects(std::vector<std::string>& subjects);

        void notifyBeforeReconnectRetries(int n);

        void notifyWhenReconnectRateExceedsThreshold(int n);

        void setQuickReconnectInitialDelay(int seconds);

        void setQuickReconnectMaxRetries(int retries);

        void setReconnectPolicy(std::string policy);

        void setReconnectTimeInterval(int seconds);

        void setReconnectMaxDelay(int seconds);

        void publish(MigratoryDataMessage& message);

        void disconnect();

        // @cond
        void pause();
        void resume();
        // @endcond

        virtual ~MigratoryDataClient();
    };

}

#endif // _MigratoryDataClient_h_included_