diff options
-rw-r--r-- | core/plugin/streaming/streamer.rb | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/core/plugin/streaming/streamer.rb b/core/plugin/streaming/streamer.rb index 66836f46..60b4c5a4 100644 --- a/core/plugin/streaming/streamer.rb +++ b/core/plugin/streaming/streamer.rb @@ -46,7 +46,7 @@ module ::Plugin::Streaming @queue = {} end def mainloop - service.streaming{ |q| + service.streaming(:userstream, include_followings_activity: true){ |q| if q and not q.empty? parsed = JSON.parse(q) rescue nil event_factory parsed if parsed end } |