lib/basquiat/adapters/rabbitmq/configuration.rb in basquiat-1.3.6 vs lib/basquiat/adapters/rabbitmq/configuration.rb in basquiat-1.4.0
- old
+ new
@@ -20,10 +20,10 @@
exchange: {
name: Basquiat.configuration.exchange_name,
durable: true,
options: {}
},
- publisher: { confirm: true, persistent: false },
+ publisher: { confirm: true, persistent: false, session_pool: { size: 1, timeout: 5 } },
consumer: { prefetch: 1000, manual_ack: true },
requeue: { enabled: false } }
end
def base_options