Module: PulsarSdk

Extended by:
PulsarSdk
Included in:
PulsarSdk
Defined in:
lib/pulsar_sdk.rb,
lib/pulsar_sdk/client.rb,
lib/pulsar_sdk/version.rb,
lib/pulsar_sdk/consumer.rb,
lib/pulsar_sdk/producer.rb,
lib/pulsar_sdk/client/rpc.rb,
lib/pulsar_sdk/options/tls.rb,
lib/pulsar_sdk/options/base.rb,
lib/pulsar_sdk/consumer/base.rb,
lib/pulsar_sdk/producer/base.rb,
lib/pulsar_sdk/options/reader.rb,
lib/pulsar_sdk/protocol/frame.rb,
lib/pulsar_sdk/protocol/topic.rb,
lib/pulsar_sdk/producer/router.rb,
lib/pulsar_sdk/protocol/lookup.rb,
lib/pulsar_sdk/protocol/reader.rb,
lib/pulsar_sdk/tweaks/wait_map.rb,
lib/pulsar_sdk/consumer/manager.rb,
lib/pulsar_sdk/options/consumer.rb,
lib/pulsar_sdk/options/producer.rb,
lib/pulsar_sdk/producer/manager.rb,
lib/pulsar_sdk/producer/message.rb,
lib/pulsar_sdk/protocol/message.rb,
lib/pulsar_sdk/client/connection.rb,
lib/pulsar_sdk/options/connection.rb,
lib/pulsar_sdk/protocol/namespace.rb,
lib/pulsar_sdk/protocol/structure.rb,
lib/pulsar_sdk/tweaks/binary_heap.rb,
lib/pulsar_sdk/tweaks/base_command.rb,
lib/pulsar_sdk/protocol/partitioned.rb,
lib/pulsar_sdk/tweaks/clean_inspect.rb,
lib/pulsar_sdk/tweaks/timeout_queue.rb,
lib/pulsar_sdk/client/connection_pool.rb,
lib/pulsar_sdk/consumer/message_tracker.rb,
lib/pulsar_sdk/tweaks/assign_attributes.rb,
lib/pulsar_sdk/tweaks/time_at_microsecond.rb

Defined Under Namespace

Modules: Client, Consumer, Options, Producer, Protocol, Tweaks Classes: Formatter

Constant Summary collapse

VERSION = 
"0.8.8"

Instance Method Summary collapse

Instance Method Details

#create_client(options) ⇒ Object

options Hash see PulsarSdk::Options::Connection for detail



18
19
20
21
 
# File 'lib/pulsar_sdk.rb', line 18

def create_client(options)
  opts = ::PulsarSdk::Options::Connection.new(options)
  ::PulsarSdk::Client.create(opts)
end

#create_consumer(client, options) ⇒ Object

options Hash see PulsarSdk::Options::Consumer for detail



30
31
32
33
 
# File 'lib/pulsar_sdk.rb', line 30

def create_consumer(client, options)
  opts = ::PulsarSdk::Options::Consumer.new(options)
  client.subscribe(opts)
end

#create_producer(client, options) ⇒ Object

options Hash see PulsarSdk::Options::Producer for detail



24
25
26
27
 
# File 'lib/pulsar_sdk.rb', line 24

def create_producer(client, options)
  opts = ::PulsarSdk::Options::Producer.new(options)
  client.create_producer(opts)
end

#logger ⇒ Object 



35
36
37
38
39
 
# File 'lib/pulsar_sdk.rb', line 35

def logger
  @logger ||= Logger.new(STDOUT).tap do |logger|
                logger.formatter = Formatter.new
              end
end

#logger=(v) ⇒ Object 



41
42
43
 
# File 'lib/pulsar_sdk.rb', line 41

def logger=(v)
  @logger = v
end