diff options
| author | rhenium <re4k@re4k.info> | 2013-05-12 00:05:13 +0900 |
|---|---|---|
| committer | rhenium <re4k@re4k.info> | 2013-05-12 00:05:13 +0900 |
| commit | e22402c59c082df3d793255af658b631f68a0908 (patch) | |
| tree | cc2d2db8831315b25b011cadc8b40c6e98300ca2 /collector | |
| parent | fdbf71d19986bcd4a959d1814934622735549fec (diff) | |
| download | aclog-e22402c59c082df3d793255af658b631f68a0908.tar.gz | |
UserStreams 503 support (503 will happen when trying to connect stream with deleted account)
Diffstat (limited to 'collector')
| -rw-r--r-- | collector/stream.rb | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/collector/stream.rb b/collector/stream.rb index 26a0471..78afca7 100644 --- a/collector/stream.rb +++ b/collector/stream.rb @@ -36,6 +36,10 @@ module Aclog log(:warn, "Unauthorized") @client.connection.stop @callback.call(type: "unauthorized", user_id: @user_id, id: @account_id) } + @client.on_service_unavailable { + # account deleted? + log(:warn, "Service Unavailable") + @client.connection.stop } @client.each do |chunk| begin |