# File lib/raindrops/aggregate/pmq.rb, line 199 def flush if q = @local_queue && ! q.empty? mq_send q q.clear end nil end