Sha256: 44e46e9ee15f7db8a7c8ec746e71ac130a1ff7b4c0a866101ee83d858e6593a6

Contents?: true

Size: 743 Bytes

Versions: 3

Compression:

Stored size: 743 Bytes

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