Merge pull request #2 from mokhan/kafkamain

Kafka

1 files changed, 0 insertions, 47 deletions

diff --git a/lib/killjoy/amqp_configuration.rb b/lib/killjoy/amqp_configuration.rb
deleted file mode 100644
index 62262f8..0000000
--- a/lib/killjoy/amqp_configuration.rb
+++ /dev/null
@@ -1,47 +0,0 @@
-module Killjoy
-  class AMQPConfiguration
-    attr_reader :environment
-
-    def initialize(environment: ENV.fetch("ENV", "development"))
-      @environment = environment
-    end
-
-    def amqp_uri
-      configuration['amqp_uri']
-    end
-
-    def heartbeat
-      configuration['heartbeat'].to_i
-    end
-
-    def prefetch
-      configuration['prefetch'].to_i
-    end
-
-    def exchange
-      configuration['exchange']
-    end
-
-    def exchange_type
-      configuration['exchange_type']
-    end
-
-    def shards
-      configuration['shards'].to_i
-    end
-
-    def to_hash
-      configuration
-    end
-
-    private
-
-    def configuration(file = "config/amqp.yml")
-      @configuration ||= YAML.load(expand_template(file))[environment]
-    end
-
-    def expand_template(file)
-      ERB.new(File.read(file)).result(binding)
-    end
-  end
-end