mackuba.eu
+6
app/firehose_stream.rb
+6
app/firehose_stream.rb
···
33
34
@sky = sky = Skyfall::Firehose.new(@service, :subscribe_repos, cursor)
35
36
@sky.on_message do |m|
37
process_message(m)
38
end
39
40
if @log_status
41
@sky.on_connecting { |u| log "Connecting to #{u}..." }
42
@sky.on_connect {
43
@replaying = !!(cursor)
44
log "Connected ✓"
45
}
46
@sky.on_disconnect {
47
log "Disconnected."
48
save_cursor(sky.cursor)
49
}
50
@sky.on_reconnect { log "Connection lost, reconnecting..." }
51
@sky.on_error { |e| log "ERROR: #{e.class} #{e.message}" }
52
end
···
33
34
@sky = sky = Skyfall::Firehose.new(@service, :subscribe_repos, cursor)
35
36
+
@sky.check_heartbeat = true
37
+
38
@sky.on_message do |m|
39
process_message(m)
40
end
41
42
if @log_status
43
@sky.on_connecting { |u| log "Connecting to #{u}..." }
44
+
45
@sky.on_connect {
46
@replaying = !!(cursor)
47
log "Connected ✓"
48
}
49
+
50
@sky.on_disconnect {
51
log "Disconnected."
52
save_cursor(sky.cursor)
53
}
54
+
55
+
@sky.on_timeout { log "Trying to reconnect..." }
56
@sky.on_reconnect { log "Connection lost, reconnecting..." }
57
@sky.on_error { |e| log "ERROR: #{e.class} #{e.message}" }
58
end