subscriber_supervisor.h

Go to the documentation of this file.

#ifndef CVMFS_NOTIFY_SUBSCRIBER_SUPERVISOR_H_
#define CVMFS_NOTIFY_SUBSCRIBER_SUPERVISOR_H_

#include <string>

#include "supervisor.h"

namespace notify {

class Subscriber;

class SubscriberSupervisor : public Supervisor {
 public:
  SubscriberSupervisor(notify::Subscriber* s, std::string t, int max_retries,
                       uint64_t interval);
  virtual ~SubscriberSupervisor();

  virtual bool Task();

 private:
  notify::Subscriber* subscriber_;
  std::string topic_;
};

}  // namespace notify

#endif  // CVMFS_NOTIFY_SUBSCRIBER_SUPERVISOR_H_