Module: PulsarSdk::Producer

Extended by:: Producer

Included in:: Producer

Defined in:: lib/pulsar_sdk/producer.rb,
lib/pulsar_sdk/producer/base.rb,
lib/pulsar_sdk/producer/router.rb,
lib/pulsar_sdk/producer/manager.rb,
lib/pulsar_sdk/producer/message.rb

Defined Under Namespace

Modules: Murmur3 Classes: Base, Manager, Message, ReceiptQueue, Router, SeqGenerator

Instance Method Summary collapse

#create(client, opts) ⇒ Object

Instance Method Details

#create(client, opts) ⇒ `Object`



10
11
12

# File 'lib/pulsar_sdk/producer.rb', line 10

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