lib/railway_ipc/server.rb in railway-ipc-0.1.2 vs lib/railway_ipc/server.rb in railway-ipc-0.1.3

- old
+ new

@@ -14,10 +14,10 @@ super @exchange = channel.default_exchange end def run - @queue = channel.queue(self.class.queue_name, auto_delete: true) + @queue = channel.queue(self.class.queue_name, durable: true) subscribe_to_queue end def work(payload) super