lib/alephant/publisher.rb in alephant-publisher-0.2.1 vs lib/alephant/publisher.rb in alephant-publisher-0.2.2

@@ -6,24 +6,22 @@
 require 'alephant/publisher/writer'
 require 'alephant/logger'
 
 module Alephant
   module Publisher
-    include ::Alephant::Logger
+    include Logger
 
-    def self.create(opts = {}, logger = nil)
-      Publisher.new(opts, logger)
+    def self.create(opts = {})
+      Publisher.new(opts)
     end
 
     class Publisher
       VISIBILITY_TIMEOUT = 60
       RECEIVE_WAIT_TIME  = 15
 
       attr_reader :queue, :executor
 
-      def initialize(opts, logger)
-        ::Alephant::Logger.set_logger(logger) unless logger.nil?
-
+      def initialize(opts)
         @opts = opts
 
         @queue = Queue.new(
           opts.queue[:sqs_queue_url],
           opts.queue[:visibility_timeout] || VISIBILITY_TIMEOUT,