Sha256: fe5a7fffd39bddf8e202a0a3e0accd9beb31931626931f3596de47af150e638d
Contents?: true
Size: 496 Bytes
Versions: 9
Compression:
Stored size: 496 Bytes
Contents
require 'java'
require 'jruby-kafka/namespace'
class Kafka::Utility
def self.java_properties(properties)
java_properties = java.util.Properties.new
properties.each do |k,v|
k = k.to_s.gsub '_', '.'
v = v.to_s
java_properties.setProperty k, v
end
java_properties
end
def self.validate_arguments(required_options, options)
required_options.each do |opt|
raise ArgumentError, "Parameter :#{opt} is required." unless options[opt]
end
end
end
Version data entries
9 entries across 9 versions & 1 rubygems