my-message-0: Mon Mar  2 15:41:56 2020
my-message-1: Mon Mar  2 15:41:56 2020
my-message-2: Mon Mar  2 15:41:56 2020
my-message-0: Mon Mar  2 15:42:06 2020
my-message-1: Mon Mar  2 15:42:06 2020
my-message-2: Mon Mar  2 15:42:06 2020
my-message-0: Mon Mar  2 15:42:16 2020
my-message-1: Mon Mar  2 15:42:16 2020
my-message-2: Mon Mar  2 15:42:16 2020

my-message-0: Mon Mar  2 15:41:56 2020
my-message-1: Mon Mar  2 15:41:56 2020
my-message-2: Mon Mar  2 15:41:56 2020
my-message-0: Mon Mar  2 15:41:59 2020
my-message-1: Mon Mar  2 15:41:59 2020
my-message-2: Mon Mar  2 15:41:59 2020
my-message-0: Mon Mar  2 15:42:03 2020
my-message-1: Mon Mar  2 15:42:03 2020
my-message-2: Mon Mar  2 15:42:03 2020

#include <iostream>
#include <pulsar/Client.h>
#include <pulsar/Authentication.h>
#include <boost/property_tree/ini_parser.hpp>
#include <time.h>

using namespace std;
using namespace pulsar;
using namespace boost::property_tree;

void messageListener(Consumer consumer, const Message &msg) {
  time_t t = time(NULL);
  printf("%s: %s", msg.getDataAsString().c_str(), ctime(&t));
  // consumer.acknowledge(msg);
  consumer.negativeAcknowledge(msg);
}

int main() {
  Client client("pulsar://<broker url>");

  ConsumerConfiguration conf = ConsumerConfiguration();
  // conf.setUnAckedMessagesTimeoutMs(10000);
  conf.setNegativeAckRedeliveryDelayMs(10000);
  conf.setMessageListener(messageListener);

  Consumer consumer;
  Result result = client.subscribe("persistent://<tenant>/<ns>/<topic>", "sub1", conf, consumer);
  if (result != ResultOk) {
      cout << "error" << "\n";
      return -1;
  }

  if (result != ResultOk) {
    cerr << "Failed to create consumer: " << result << endl;
    return -1;
  }

  int n;
  cin >> n;

  client.close();
}