danderson/ofborg
0
0
Fork 0
forked from the-distro/ofborg
Code Pull requests Activity

make messages persistent

Browse source 
Should ensure we don't loose pending builds or evaluations when rabbitmq
restarts.
This commit is contained in:
Daiderd Jordan 2020-04-30 19:50:34 +02:00
parent 7d1014f1c2
commit 3223f32f5c
No known key found for this signature in database
GPG key ID: D02435D05B810C96
3 changed files with 9 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
ofborg/src/easylapin.rs
View file

@ -190,13 +190,19 @@ async fn action_deliver(
let key = msg.routing_key.take().unwrap_or_else(|| "".to_owned());
log::debug!("action publish {}", exch);
let mut props = BasicProperties::default().with_delivery_mode(2); // persistent.
if let Some(s) = msg.content_type {
props = props.with_content_type(s.into());
}
let _confirmaton = chan
.basic_publish(
&exch,
&key,
BasicPublishOptions::default(),
msg.content,
BasicProperties::default(),
props,
)
.await?
.await?;

1
ofborg/src/notifyworker.rs
View file

@ -82,6 +82,7 @@ impl<'a> NotificationReceiver for ChannelNotificationReceiver<'a> {
let props = BasicProperties {
content_type: msg.content_type,
delivery_mode: Some(2), // persistent
..Default::default()
};
self.channel

1
ofborg/src/worker.rs
View file

@ -104,6 +104,7 @@ impl<T: SimpleWorker + Send> amqp::Consumer for Worker<T> {
let props = BasicProperties {
content_type: msg.content_type,
delivery_mode: Some(2), // persistent
..Default::default()
};
channel