lib/rosetta_queue/consumer.rb in bmabey-rosetta_queue-0.1.3 vs lib/rosetta_queue/consumer.rb in bmabey-rosetta_queue-0.2.0

@@ -3,11 +3,18 @@
 
     def self.receive(destination, options = {})
       RosettaQueue::Adapter.instance.receive_once(Destinations.lookup(destination), options)
       
       rescue Exception=>e
-        RosettaQueue.logger.error("Caught exception in Consumer#receive: #{$!}\n" + e.backtrace.join("\n\t"))
+        RosettaQueue.logger.error("Caught exception in Consumer.receive: #{$!}\n" + e.backtrace.join("\n\t"))
     end
+
+    def self.delete(destination, options={})
+      RosettaQueue::Adapter.instance.delete(Destinations.lookup(destination), options)
+      
+      rescue Exception=>e
+        RosettaQueue.logger.error("Caught exception in Consumer.delete: #{$!}\n" + e.backtrace.join("\n\t"))
+    end 
 
     def initialize(message_handler)
       @message_handler = message_handler
     end