@@ -14,7 +14,7 @@ def initialize(synchronizer, config, splits_repository)
1414
1515 def start
1616 if @running . value
17- @config . logger . debug ( 'splits worker already running.' )
17+ @config . logger . debug ( 'feature_flags_worker already running.' )
1818 return
1919 end
2020
@@ -24,7 +24,7 @@ def start
2424
2525 def stop
2626 unless @running . value
27- @config . logger . debug ( 'splits worker not running.' )
27+ @config . logger . debug ( 'feature_flags_worker not running.' )
2828 return
2929 end
3030
@@ -33,14 +33,14 @@ def stop
3333 end
3434
3535 def add_to_queue ( change_number )
36- @config . logger . debug ( "SplitsWorker add to queue #{ change_number } " )
36+ @config . logger . debug ( "feature_flags_worker add to queue #{ change_number } " )
3737 @queue . push ( change_number )
3838 end
3939
4040 def kill_split ( change_number , split_name , default_treatment )
4141 return if @splits_repository . get_change_number . to_i > change_number
4242
43- @config . logger . debug ( "SplitsWorker kill #{ split_name } , #{ change_number } " )
43+ @config . logger . debug ( "feature_flags_worker kill #{ split_name } , #{ change_number } " )
4444 @splits_repository . kill ( change_number , split_name , default_treatment )
4545 add_to_queue ( change_number )
4646 end
@@ -49,14 +49,14 @@ def kill_split(change_number, split_name, default_treatment)
4949
5050 def perform
5151 while ( change_number = @queue . pop )
52- @config . logger . debug ( "SplitsWorker change_number dequeue #{ change_number } " )
52+ @config . logger . debug ( "feature_flags_worker change_number dequeue #{ change_number } " )
5353 @synchronizer . fetch_splits ( change_number )
5454 end
5555 end
5656
5757 def perform_thread
5858 @config . threads [ :split_update_worker ] = Thread . new do
59- @config . logger . debug ( 'Starting splits worker ...' ) if @config . debug_enabled
59+ @config . logger . debug ( 'starting feature_flags_worker ...' ) if @config . debug_enabled
6060 perform
6161 end
6262 end
0 commit comments