Properly send job results to the job result queue

This commit is contained in:
Graham Christensen 2018-01-24 19:32:47 -05:00
parent 9b672e7d1f
commit 6995551d16
No known key found for this signature in database
GPG key ID: ACA1C1D120C83D5C

View file

@ -174,9 +174,13 @@ impl<'a, 'b> JobActions<'a, 'b> {
success: success, success: success,
}; };
let result_exchange = self.result_exchange.clone();
let result_routing_key = self.result_routing_key.clone();
self.tell(worker::publish_serde_action( self.tell(worker::publish_serde_action(
Some("build-results".to_owned()), result_exchange,
None, result_routing_key,
&msg, &msg,
)); ));
self.tell(worker::Action::Ack); self.tell(worker::Action::Ack);