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