diff options
| author | Raphael <raphael@joindiaspora.com> | 2010-12-10 22:23:27 +0300 |
|---|---|---|
| committer | Raphael <raphael@joindiaspora.com> | 2010-12-10 22:25:38 +0300 |
| commit | 0e77577fbd6d409a30d6a0e0281510df0a884caa (patch) | |
| tree | 85a7748af51831ae2cb2138a8c3c433099b8ee09 /script | |
| parent | 8de5c5babd3b39793f09e479227628f4940c3f36 (diff) | |
Websocket now uses redis
Diffstat (limited to 'script')
| -rw-r--r-- | script/websocket_server.rb | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/script/websocket_server.rb b/script/websocket_server.rb index f338916ad..b8da36d04 100644 --- a/script/websocket_server.rb +++ b/script/websocket_server.rb @@ -28,10 +28,9 @@ def debug_pp thing pp thing if APP_CONFIG[:socket_debug] || ENV['SOCKET_DEBUG'] end -CHANNEL = Magent::GenericChannel.new('websocket') def process_message - if CHANNEL.queue_count > 0 - message = CHANNEL.dequeue + if Diaspora::WebSocket.length > 0 + message = JSON::parse(Diaspora::WebSocket.next) if message Diaspora::WebSocket.push_to_user(message['uid'], message['data']) end |