module AvroPinions

Constants

VERSION

Public Instance Methods

configuration() click to toggle source

Your code goes here…

# File lib/avro_pinions.rb, line 12
def configuration
  AvroPinions::Configuration.instance
end
configure(messages) click to toggle source
# File lib/avro_pinions.rb, line 16
def configure(messages)
  if messages.respond_to?(:each_pair)
    messages.each_pair do |key, value|
      if value && configuration.respond_to?("#{key}=")
        configuration.send("#{key}=", value)
      elsif configuration.respond_to?(key)
        configuration.send(key, *value)
      end
    end
  else
    configuration.send(messages)
  end
end
publish(message) click to toggle source
# File lib/avro_pinions.rb, line 38
def publish(message)
  topic = message.topic
  encoded = message.encode

  publisher.publish(topic, encoded)
end
publisher() click to toggle source
# File lib/avro_pinions.rb, line 30
def publisher
  configuration.publisher
end
schema_registry() click to toggle source
# File lib/avro_pinions.rb, line 34
def schema_registry
  configuration.schema_registry
end