module PulsarSdk::Consumer
Public Instance Methods
create(client, opts)
click to toggle source
# File lib/pulsar_sdk/consumer.rb, line 9 def create(client, opts) PulsarSdk::Consumer::Manager.new(client, opts) end