monitor.hh

Go to the documentation of this file.

/*
 * monitor.hh
 *
 *  Created on: Jul 1, 2019
 *      Author: N.S. Oblath
 */
 
#ifndef DRIPLINE_MONITOR_HH_
#define DRIPLINE_MONITOR_HH_
 
#include "core.hh"
#include "listener.hh"
#include "receiver.hh"
 
namespace scarab
{
    class authentication;
}
 
namespace DRIPLINE_API dripline
{
 
    class monitor :
            public core,
            public listener_receiver
    {
        protected:
            enum class status
            {
                nothing = 0,
                channel_created = 10,
                exchange_declared = 20,
                queue_declared = 30,
                queue_bound = 40,
                consuming = 50,
                listening = 60
            };
 
        public:
            monitor( const scarab::param_node& a_config, const scarab::authentication& a_auth );
            monitor( const monitor& ) = delete;
            monitor( monitor&& a_orig ) = default;
            virtual ~monitor();
 
            monitor& operator=( const monitor& ) = delete;
            monitor& operator=( monitor&& a_orig ) = default;
 
            mv_accessible( status, status );
 
            mv_referrable( std::string, name );
 
            mv_accessible( bool, json_print );
            mv_accessible( bool, pretty_print );
 
            typedef std::vector< std::string > keys_t;
            mv_referrable( keys_t, requests_keys );
            mv_referrable( keys_t, alerts_keys );
 
        public:
            bool start();
 
            bool listen();
 
            bool stop();
 
        protected:
            bool bind_keys();
 
        public:
            virtual bool listen_on_queue();
 
            virtual void submit_message( message_ptr_t a_message );
    };
 
} /* namespace dripline */
 
#endif /* DRIPLINE_MONITOR_HH_ */