Contents

#ifndef __PULSAR_RUBY_CLIENT_PRODUCER_HPP
#define __PULSAR_RUBY_CLIENT_PRODUCER_HPP

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

#include "message.hpp"

namespace pulsar_rb {
  class Producer {
  public:
    pulsar::Producer _producer;
    Producer() {};
    Producer(const pulsar::Producer& producer) : _producer(producer) {}

    void send(const Message& message);

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

  // direct typedef instead of wrapping because implementations don't need any
  // wrapping. but still re-namespaced for consistency
  typedef pulsar::ProducerConfiguration ProducerConfiguration;
};

void bind_producer(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/producer.hpp
pulsar-client-2.4.1.pre.beta.2	ext/bindings/producer.hpp
pulsar-client-2.4.1.pre.beta.1	ext/bindings/producer.hpp