19 #ifndef PULSAR_CLIENT_HPP_ 20 #define PULSAR_CLIENT_HPP_ 22 #include <pulsar/Consumer.h> 23 #include <pulsar/Producer.h> 24 #include <pulsar/Result.h> 25 #include <pulsar/Message.h> 26 #include <pulsar/MessageBuilder.h> 27 #include <pulsar/ClientConfiguration.h> 30 #pragma GCC visibility push(default) 33 typedef boost::function<void(Result, Producer)> CreateProducerCallback;
34 typedef boost::function<void(Result, Consumer)> SubscribeCallback;
35 typedef boost::function<void(Result)> CloseCallback;
48 Client(
const std::string& serviceUrl);
84 void createProducerAsync(
const std::string& topic, CreateProducerCallback callback);
87 CreateProducerCallback callback);
89 Result subscribe(
const std::string& topic,
const std::string& consumerName,
Consumer& consumer);
90 Result subscribe(
const std::string& topic,
const std::string& consumerName,
93 void subscribeAsync(
const std::string& topic,
const std::string& consumerName,
94 SubscribeCallback callback);
95 void subscribeAsync(
const std::string& topic,
const std::string& consumerName,
104 void closeAsync(CloseCallback callback);
110 Client(
const boost::shared_ptr<ClientImpl>);
112 friend class PulsarFriend;
113 friend class PulsarWrapper;
114 boost::shared_ptr<ClientImpl> impl_;
119 #pragma GCC visibility pop Result createProducer(const std::string &topic, Producer &producer)
Client(const std::string &serviceUrl)
Definition: Producer.h:32
Definition: Authentication.h:31
Definition: ConsumerConfiguration.h:45
Definition: Consumer.h:36
Result
Definition: Result.h:31
Definition: ProducerConfiguration.h:39
Definition: ClientConfiguration.h:27