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