lib/fluent/plugin/azureeventhubs/http.rb in sk-fluent-plugin-azureeventhubs-0.0.6 vs lib/fluent/plugin/azureeventhubs/http.rb in sk-fluent-plugin-azureeventhubs-0.0.7

@@ -51,10 +51,11 @@
     token = generate_sas_token(@uri.to_s)    
     Unirest.post "#{@uri.to_s}?timeout=10&api-version=2014-01", 
                         headers:{ 'Content-Type' => 'application/atom+xml;type=entry;charset=utf-8',
                             'Authorization' => token
                         }, 
-                        parameters: payload.to_s {|response|
-    response.code 
-}   
+                        parameters: payload.to_s {|response| response.code }   
+    rescue Exception => e
+      log.warn "Send exception occurred: #{e}"
+      raise e
   end
 end