lib/kafka_session.rb in kafka_session-0.4.1 vs lib/kafka_session.rb in kafka_session-0.5.0

@@ -4,20 +4,21 @@
 
 require 'kafka_session/delivered_message'
 require 'kafka_session/message'
 
 require 'securerandom'
-require 'active_support/time'
-require 'active_support/core_ext/hash'
 
 class KafkaSession
   class << self
     attr_writer :clock, :producer
   end
 
   def self.configure(options = {})
-    producer_options = options.slice(:name, :brokers)
+    producer_options = {
+      name:    options.fetch(:name),
+      brokers: options.fetch(:brokers)
+    }
 
     @producer = Producer.new(producer_options)
   end
 
   def self.producer
@@ -31,10 +32,10 @@
   def self.session_id=(session_id)
     Thread.current[:kafka_session_session_id] = session_id
   end
 
   def self.clock
-    @clock ||= Time.public_method(:current)
+    @clock ||= proc { Time.now.utc }
   end
 
   def self.now
     clock.call
   end