This commit is contained in:
Jordan Sissel 2010-10-31 08:52:41 +00:00
parent 8ef912a624
commit b3e67888a1

View file

@ -27,6 +27,7 @@ class LogStash::Outputs::Websocket < LogStash::Outputs::Base
def receive(event)
# Only publish the event to websockets if there are subscribers
# TODO(sissel): send a patch to eventmachine to fix this.
if @subscribers > 0
@channel.push event.to_json
end