lib/alephant/publisher.rb in alephant-publisher-0.3.1 vs lib/alephant/publisher.rb in alephant-publisher-0.4.0

@@ -53,12 +53,16 @@
 
       def aws_queue
         AWS::SQS.new.queues[opts.queue[:sqs_queue_url]]
       end
 
+      def write(msg)
+        Writer.new(opts.writer, msg).run!
+      end
+
       def process(msg)
         unless msg.nil?
-          Writer.new(@opts.writer, msg).run!
+          write msg
           msg.delete
         end
       end
 
     end