subscriber.h

Go to the documentation of this file.

#ifndef CVMFS_NOTIFY_SUBSCRIBER_H_
#define CVMFS_NOTIFY_SUBSCRIBER_H_

#include <string>

namespace notify {

class Subscriber {
 public:
  enum Status {
    kContinue,
    kFinish,
    kError,
  };

  Subscriber() {}
  virtual ~Subscriber() {}

  virtual bool Subscribe(const std::string& topic) = 0;

  virtual void Unsubscribe() {}

 protected:
  virtual Status Consume(const std::string& topic,
                         const std::string& msg_text) = 0;
};

}  // namespace notify

#endif  // CVMFS_NOTIFY_SUBSCRIBER_H_