the-distro/ofborg
2
0
Fork 1
Code Issues 1 Pull requests 1 Packages Projects Releases Wiki Activity

Correct the consume queue name, and don't panic on deeserialize errorss

Browse source
This commit is contained in:
Graham Christensen 2018-01-31 19:38:09 -05:00
parent 5e2c57790e
commit 5d24478710
No known key found for this signature in database
GPG key ID: ACA1C1D120C83D5C
2 changed files with 6 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
ofborg/src/bin/github-comment-poster.rs
View file

@ -67,7 +67,7 @@ fn main() {
cfg.github(), cfg.github(),
)), )),
easyamqp::ConsumeConfig { easyamqp::ConsumeConfig {
queue: "build-inputs".to_owned(), queue: "build-results".to_owned(),
consumer_tag: format!("{}-github-comment-poster", cfg.whoami()), consumer_tag: format!("{}-github-comment-poster", cfg.whoami()),
no_local: false, no_local: false,
no_ack: false, no_ack: false,

10
ofborg/src/tasks/githubcommentposter.rs
View file

@ -31,11 +31,11 @@ impl worker::SimpleWorker for GitHubCommentPoster {
return match serde_json::from_slice(body) { return match serde_json::from_slice(body) {
Ok(e) => Ok(e), Ok(e) => Ok(e),
Err(e) => { Err(e) => {
println!( Err(format!(
"Failed to deserialize BuildResult: {:?}", "Failed to deserialize BuildResult: {:?}, err: {:}",
String::from_utf8(body.clone()) String::from_utf8_lossy(&body.clone()),
); e
panic!("{:?}", e); ))
} }
}; };
} }