File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change 11name : placeos-driver
2- version : 7.17.4
2+ version : 7.17.5
33
44dependencies :
55 action-controller :
Original file line number Diff line number Diff line change @@ -126,7 +126,6 @@ class PlaceOS::Driver
126126 max_interval: 5 .seconds,
127127 randomise: 500 .milliseconds
128128 ) do
129- puts " \n\n START SUBSCRIPTION MONITORING\n\n "
130129 return if terminated?
131130 monitor_count += 1
132131 subscribe_count = monitor_count
@@ -141,7 +140,6 @@ class PlaceOS::Driver
141140 # NOTE:: sending an empty array errors
142141 keys = mutex.synchronize { subscriptions.keys }
143142 if keys.size > 0
144- puts " \n\n FOUND #{ keys.size } EXISTING SUBSCRIPTIONS\n\n "
145143 redis.subscribe(keys)
146144 end
147145
@@ -181,22 +179,17 @@ class PlaceOS::Driver
181179 spawn(same_thread: true ) do
182180 instance = monitor_count
183181 wait.close
184- puts " \n\n\n NEW SUBSCRIPTION LOOP!!!! #{ monitor_count } \n\n\n "
185182 loop do
186183 sleep 1 .second
187- puts " PING SUBSCRIPTION REDIS: #{ monitor_count } == #{ instance } "
188184 break if instance != monitor_count
189185 subscription_channel.send({true , SYSTEM_ORDER_UPDATE })
190- rescue error
191- puts " \n\n ERROR PINGING REDIS: #{ error.inspect_with_backtrace } \n\n "
192186 end
193187 end
194188 end
195189
196190 raise " no subscriptions, restarting loop" unless terminated?
197191 rescue e
198192 Log .warn(exception: e) { " redis subscription loop exited" }
199- puts " \n\n ERROR SUBSCRIPTION MONITORING: #{ e.message } \n\n "
200193 raise e
201194 ensure
202195 wait.close
You can’t perform that action at this time.
0 commit comments