Contents

#ifndef __PULSAR_RUBY_CLIENT_MESSAGE_HPP
#define __PULSAR_RUBY_CLIENT_MESSAGE_HPP

#include "rice/Module.hpp"
#include "rice/String.hpp"
#include "rice/Data_Object.hpp"
#include <pulsar/Client.h>

namespace pulsar_rb {
  class MessageId {
  public:
    pulsar::MessageId _msgId;
    MessageId(const pulsar::MessageId& msgId) : _msgId(msgId) {};

    Rice::String toString();

    typedef Rice::Data_Object<MessageId> ptr;
  };

  class Message {
  public:
    pulsar::Message _msg;
    Message(const pulsar::Message& msg) : _msg(msg) {};
    Message(const std::string& data);

    Rice::String getData();
    MessageId::ptr getMessageId();

    typedef Rice::Data_Object<Message> ptr;
  };
};

void bind_message(Rice::Module& module);

#endif

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
pulsar-client-2.4.1.pre.beta.4	ext/bindings/message.hpp
pulsar-client-2.4.1.pre.beta.2	ext/bindings/message.hpp
pulsar-client-2.4.1.pre.beta.1	ext/bindings/message.hpp