gem "pulsar-client", "~> 2.6.1.pre"

# use a standard Pulsar client config (see https://github.com/apache/pulsar/blob/master/conf/client.conf)
# export PULSAR_CLIENT_CONF=/path/to/your/client/conf/client_conf.conf
# OR, if not present have these in your shell with appropriate values
# export PULSAR_BROKER_URI=pulsar://your-pulsar-broker:6651
# export PULSAR_CERT_PATH=/path/to/your/pulsar-ca.pem
# export PULSAR_AUTH_TOKEN=your-auth-token
# export PULSAR_AUTH_OAUTH2_PARAMS=your-oauth2-params

# create client using values from environment
client = Pulsar::Client.from_environment

# produce a message on the "hello-world" topic in the "namespace"
# namespace of the "tenant" tenant
topic = "tenant/namespace/topic"
producer = client.create_producer(topic)
producer.send("Hello, world!")

# consumer that message from the topic with an exclusive subscription
# named "hello-consumer"
subscription = "hello-consumer"
consumer = client.subscribe(topic, subscription)

msg = consumer.receive
message = msg.data
puts "got #{message}"
consumer.acknolwedge(msg)

consumer.listen do |message, _, done|
  # process message here; call done to stop the loop.
  # messages are auto-acknowledged.
  puts "got #{message}"
  done.call()
end

listenerThread = consumer.listen_in_thread do |message, _, done|
  # process message here; call done to stop the loop.
  # messages are auto-acknowledged.
  puts "got #{message}"
  done.call()
end
# ...
listenerThread.join # wait for the thread to finish