/home/mhx/git/github/libmoost/include/moost/mq/stomp_client.h

Go to the documentation of this file.

/* vim:set ts=3 sw=3 sts=3 et: */
#ifndef MOOST_MQ_STOMP_CLIENT_H_
#define MOOST_MQ_STOMP_CLIENT_H_

#include <string>

#include <boost/date_time/posix_time/posix_time.hpp>
#include <boost/system/error_code.hpp>
#include <boost/shared_ptr.hpp>
#include <boost/function.hpp>
#include <boost/cstdint.hpp>

namespace moost { namespace mq {

class stomp_client
{
public:
   struct ack
   {
      enum type
      {
         automatic,
         client
      };
   };

   stomp_client(size_t consumer_pool_size = 1,
                const boost::posix_time::time_duration& keepalive_interval = boost::posix_time::seconds(30),
                const boost::posix_time::time_duration& reconnect_interval = boost::posix_time::seconds(1));

   ~stomp_client();

   void connect(const std::string& hostname, int port,
                boost::function<void (const boost::system::error_code&, const std::string&)> error_cb);

   void disconnect();

   void subscribe(const std::string& topic, boost::function<void (const std::string&)> message_cb, ack::type ack_type = ack::automatic,
                  const boost::posix_time::time_duration& max_msg_interval = boost::posix_time::pos_infin);

   void unsubscribe(const std::string& topic);

   void send(const std::string& topic, const std::string& message);

   bool is_connected() const;

   bool is_online() const;

   uint64_t get_num_processed() const;

   size_t get_num_pending() const;

private:
   class impl;
   boost::shared_ptr<impl> m_impl;
};

}}

#endif