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