@@ -73,7 +73,7 @@ def start!(odp_config)
73
73
74
74
def flush
75
75
begin
76
- @event_queue . push ( :FLUSH_SIGNAL , non_block : true )
76
+ @event_queue . push ( :FLUSH_SIGNAL , true )
77
77
rescue ThreadError
78
78
@logger . log ( Logger ::ERROR , 'Error flushing ODP event queue.' )
79
79
return
@@ -87,7 +87,7 @@ def flush
87
87
def update_config
88
88
begin
89
89
# Adds update config signal to event_queue.
90
- @event_queue . push ( :UPDATE_CONFIG , non_block : true )
90
+ @event_queue . push ( :UPDATE_CONFIG , true )
91
91
rescue ThreadError
92
92
@logger . log ( Logger ::ERROR , 'Error updating ODP config for the event queue' )
93
93
end
@@ -111,7 +111,7 @@ def dispatch(event)
111
111
112
112
begin
113
113
@logger . log ( Logger ::DEBUG , 'ODP event queue: adding event.' )
114
- @event_queue . push ( event , non_block : true )
114
+ @event_queue . push ( event , true )
115
115
rescue => e
116
116
@logger . log ( Logger ::WARN , format ( Helpers ::Constants ::ODP_LOGS [ :ODP_EVENT_FAILED ] , e . message ) )
117
117
return
@@ -143,7 +143,7 @@ def stop!
143
143
return unless running?
144
144
145
145
begin
146
- @event_queue . push ( :SHUTDOWN_SIGNAL , non_block : true )
146
+ @event_queue . push ( :SHUTDOWN_SIGNAL , true )
147
147
rescue ThreadError
148
148
@logger . log ( Logger ::ERROR , 'Error stopping ODP event queue.' )
149
149
return
@@ -175,7 +175,7 @@ def run
175
175
end
176
176
177
177
begin
178
- item = @event_queue . pop ( non_block : true )
178
+ item = @event_queue . pop ( true )
179
179
rescue ThreadError => e
180
180
raise unless e . message == 'queue empty'
181
181
0 commit comments