From df920af3e8574ba688098673e8b84ba3d5df0d1a Mon Sep 17 00:00:00 2001
From: Gregory Eremin <g@erem.in>
Date: Sat, 27 Sep 2014 00:51:41 +0400
Subject: [PATCH] Add flush endpoint

---
 lib/burlesque/client.rb | 11 +++++++++++
 1 file changed, 11 insertions(+)

diff --git a/lib/burlesque/client.rb b/lib/burlesque/client.rb
index 1f4c27e..9025cae 100644
--- a/lib/burlesque/client.rb
+++ b/lib/burlesque/client.rb
@@ -7,6 +7,7 @@ module Burlesque
 
     PUB_ENDPOINT = '/publish'
     SUB_ENDPOINT = '/subscribe'
+    FLUSH_ENDPOINT = '/flush'
     STATUS_ENDPOINT = '/status'
     DEBUG_ENDPOINT = '/debug'
     OK = 'OK'
@@ -33,6 +34,16 @@ module Burlesque
       end
     end
 
+    def flush *queues
+      req = Net::HTTP::Get.new("#{FLUSH_ENDPOINT}?queues=#{queues.join(?,)}")
+
+      begin
+        res = http.request(req)
+        JSON.parse(res.body) if res.is_a? Net::HTTPOK
+      rescue Net::ReadTimeout
+      end
+    end
+
     def status
       req = Net::HTTP::Get.new(STATUS_ENDPOINT)
       res = http.request(req)