class Gnip::GnipStream::ErrorReconnect

Public Class Methods

new(source_class, method_name) click to toggle source
# File lib/gnip/gnip-stream/error_reconnect.rb, line 6
def initialize(source_class, method_name)
  @source_class = source_class
  @method_name = method_name
  @reconnect_attempts = 0
end

Public Instance Methods

attempt_to_reconnect(error_message) click to toggle source
# File lib/gnip/gnip-stream/error_reconnect.rb, line 12
def attempt_to_reconnect(error_message)
  @error_message = error_message
  if @reconnect_attempts < 5
    @reconnect_attempts += 1
    sleep(2)
    @source_class.send(@method_name)
  else
    reconnect_failed_raise_error
  end
end
reconnect_failed_raise_error() click to toggle source
# File lib/gnip/gnip-stream/error_reconnect.rb, line 23
def reconnect_failed_raise_error
  raise @error_message
end