lib/automate-em/service/http_service.rb in automate-em-0.0.3 vs lib/automate-em/service/http_service.rb in automate-em-0.0.4
- old
+ new
@@ -48,11 +48,11 @@
#@connection = EventMachine::HttpRequest.new(@uri, @config)
@default_request_options = {
:wait => true, # Wait for response
:delay => 0, # Delay next request by x.y seconds
- :delay_on_recieve => 0, # Delay next request after a recieve by x.y seconds (only works when we are waiting for responses)
+ :delay_on_receive => 0, # Delay next request after a receive by x.y seconds (only works when we are waiting for responses)
#:emit
:retries => 2,
:priority => 50,
#
@@ -102,11 +102,11 @@
#
# State
#
@last_sent_at = 0.0
- @last_recieve_at = 0.0
+ @last_receive_at = 0.0
#
# Configure links between objects
#
@@ -369,11 +369,11 @@
end
end
#
- # Caled from recieve
+ # Caled from receive
#
def process_response(response, command)
EM.defer do
@received_lock.synchronize { # This lock protects the send queue lock when we are emiting status
@send_monitor.mon_synchronize {
@@ -425,11 +425,11 @@
@send_queue.push(command, command[:priority] - @config[:priority_bonus])
end
#else result == :abort || result == :success || result == true || waits and retries exceeded
- if command[:delay_on_recieve] > 0.0
- delay_for = (@last_recieve_at + command[:delay_on_recieve] - Time.now.to_f)
+ if command[:delay_on_receive] > 0.0
+ delay_for = (@last_receive_at + command[:delay_on_receive] - Time.now.to_f)
if delay_for > 0.0
EM.add_timer delay_for do
process_next_send
end
\ No newline at end of file