lib/fluent/plugin/out_sakuraio.rb in fluent-plugin-sakuraio-0.1.0 vs lib/fluent/plugin/out_sakuraio.rb in fluent-plugin-sakuraio-0.1.1

- old
+ new

@@ -24,10 +24,10 @@ thread_create(:out_sakuraio_reactor) do EM.run end end - def run + def run() EM.next_tick do @client.on :open do log.info "sakuraio: starting websocket connection for #{@url}." end