Module: PulsarSdk::Consumer

Extended by:: Consumer

Included in:: Consumer

Defined in:: lib/pulsar_sdk/consumer.rb,
lib/pulsar_sdk/consumer/base.rb,
lib/pulsar_sdk/consumer/manager.rb,
lib/pulsar_sdk/consumer/message_tracker.rb

Defined Under Namespace

Classes: Base, Manager, MessageTracker

Instance Method Summary collapse

#create(client, opts) ⇒ Object

Instance Method Details

#create(client, opts) ⇒ `Object`



9
10
11

# File 'lib/pulsar_sdk/consumer.rb', line 9

def create(client, opts)
  PulsarSdk::Consumer::Manager.new(client, opts)
end