/home/mhx/git/github/libmoost/src/mq/stomp_client.cpp

Go to the documentation of this file.

/* vim:set ts=3 sw=3 sts=3 et: */
#include "../../include/moost/mq/stomp_client.h"
#include "stomp_client_impl.h"

namespace moost { namespace mq {

stomp_client::stomp_client(size_t consumer_pool_size,
                           const boost::posix_time::time_duration& keepalive_interval,
                           const boost::posix_time::time_duration& reconnect_interval)
   : m_impl(new impl(consumer_pool_size, keepalive_interval, reconnect_interval))
{
}

stomp_client::~stomp_client()
{
   try
   {
      disconnect();
   }
   catch (...)
   {
   }
}

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

void stomp_client::disconnect()
{
   if (is_connected())
   {
      m_impl->disconnect();
   }
}

void stomp_client::subscribe(const std::string& topic, boost::function<void (const std::string&)> message_cb, ack::type ack_type,
                             const boost::posix_time::time_duration& max_msg_interval)
{
   m_impl->subscribe(topic, message_cb, ack_type, max_msg_interval);
}

void stomp_client::unsubscribe(const std::string& topic)
{
   m_impl->unsubscribe(topic);
}

void stomp_client::send(const std::string& topic, const std::string& message)
{
   m_impl->send(topic, message);
}

bool stomp_client::is_connected() const
{
   return m_impl->is_connected();
}

bool stomp_client::is_online() const
{
   return m_impl->is_online();
}

uint64_t stomp_client::get_num_processed() const
{
   return m_impl->get_num_processed();
}

size_t stomp_client::get_num_pending() const
{
   return m_impl->get_num_pending();
}

}}