lib/belated/queue.rb in belated-0.8.2 vs lib/belated/queue.rb in belated-0.8.3

@@ -19,10 +19,10 @@
 
     def initialize(queue: Thread::Queue.new, future_jobs: SortedSet.new)
       @queue = queue
       @mutex = Mutex.new
       self.future_jobs = future_jobs
-      self.future_jobs_db = PStore.new('future_jobs.pstore', true) # pass true for thread safety
+      self.future_jobs_db = PStore.new("future_jobs_#{Belated.environment}.pstore", true) # pass true for thread safety
     end
 
     def enqueue_future_jobs
       loop do
         job = future_jobs.min