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

update amqp to avoid self-destruction from heartbeats

Browse source
This commit is contained in:
Graham Christensen 2018-01-28 23:21:51 -05:00
parent 851f73092f
commit 07f3d265f9
No known key found for this signature in database
GPG key ID: ACA1C1D120C83D5C
3 changed files with 4 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
nix/ofborg-carnix.nix
View file

@ -49,8 +49,8 @@ let kernel = buildPlatform.parsed.kernel.name;
authors = [ "Andrii Dmytrenko <andrey@reevoo.com>" ]; authors = [ "Andrii Dmytrenko <andrey@reevoo.com>" ];
src = fetchgit { src = fetchgit {
url = "https://github.com/grahamc/rust-amqp.git"; url = "https://github.com/grahamc/rust-amqp.git";
rev = "be492890a30884be391b2effc0a6dfb3d02f74f6"; rev = "f35e2c17de69038c4593621346b4ec6d64cfeaf4";
sha256 = "1why8dw6g73s40n1h8lyv7qkckc06bgn22ny4m2f3lrlvkn9gv02"; sha256 = "0b4c6alvd4ivv0s73nr8lqkiz27lcgszlkv8nb9alcmpy71x8hqd";
}; };
inherit dependencies buildDependencies features; inherit dependencies buildDependencies features;
}; };

2
ofborg/Cargo.lock generated
View file

@ -30,7 +30,7 @@ dependencies = [
[[package]] [[package]]
name = "amqp" name = "amqp"
version = "0.1.0" version = "0.1.0"
source = "git+https://github.com/grahamc/rust-amqp.git#be492890a30884be391b2effc0a6dfb3d02f74f6" source = "git+https://github.com/grahamc/rust-amqp.git#f35e2c17de69038c4593621346b4ec6d64cfeaf4"
dependencies = [ dependencies = [
"amq-proto 0.1.0 (registry+https://github.com/rust-lang/crates.io-index)", "amq-proto 0.1.0 (registry+https://github.com/rust-lang/crates.io-index)",
"env_logger 0.3.5 (registry+https://github.com/rust-lang/crates.io-index)", "env_logger 0.3.5 (registry+https://github.com/rust-lang/crates.io-index)",

2
php/poster.php
View file

@ -86,7 +86,7 @@ function outrunner($msg) {
} }
$consumerTag = 'consumer' . getmypid(); $consumerTag = 'poster-' . getmypid();
$channel->basic_consume($queueName, $consumerTag, false, false, false, false, 'outrunner'); $channel->basic_consume($queueName, $consumerTag, false, false, false, false, 'outrunner');
while(count($channel->callbacks)) { while(count($channel->callbacks)) {
$channel->wait(); $channel->wait();