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

fixup signatures

Browse source
This commit is contained in:
Graham Christensen 2018-01-13 12:07:31 -05:00
parent f717f7f962
commit 960e9766d4
No known key found for this signature in database
GPG key ID: ACA1C1D120C83D5C
1 changed files with 2 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
ofborg/src/bin/test.rs
View file

@ -44,7 +44,7 @@ impl TestWorker {
};
}
pub fn tick(event: str) -> worker::Action {
pub fn tick(&self, event: &str) -> worker::Action {
worker::Action::Publish(worker::QueueMsg{
exchange: Some(String::from("stats")),
routing_key: None,
@ -55,7 +55,7 @@ impl TestWorker {
})
}
pub fn say_hi() -> worker::Action {
pub fn say_hi(&self) -> worker::Action {
worker::Action::Publish(worker::QueueMsg{
exchange: None,
routing_key: Some(String::from("test-notify-worker")),