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