fc06c863ac
Fixed a few spelling errors. Removed unnecessary timeout argument from some connections. Removed on_return callback from send.pl. Modified rpc_client to allow parameter passing. Added autoflush, $|++, to allow for automated testing.
63 lines
1.1 KiB
Perl
63 lines
1.1 KiB
Perl
#!/usr/bin/perl
|
|
|
|
use strict;
|
|
use warnings;
|
|
|
|
$|++;
|
|
use AnyEvent;
|
|
use Net::RabbitFoot;
|
|
|
|
my $conn = Net::RabbitFoot->new()->load_xml_spec()->connect(
|
|
host => 'localhost',
|
|
port => 5672,
|
|
user => 'guest',
|
|
pass => 'guest',
|
|
vhost => '/',
|
|
);
|
|
|
|
my $channel = $conn->open_channel();
|
|
|
|
$channel->declare_queue(queue => 'rpc_queue');
|
|
|
|
sub fib {
|
|
my $n = shift;
|
|
if ($n == 0) {
|
|
return 0;
|
|
} elsif ($n == 1) {
|
|
return 1;
|
|
} else {
|
|
return fib($n-1) + fib($n-2);
|
|
}
|
|
}
|
|
|
|
sub on_request {
|
|
my $var = shift;
|
|
my $body = $var->{body}->{payload};
|
|
my $props = $var->{header};
|
|
|
|
my $n = $body;
|
|
print " [.] fib($n)\n";
|
|
my $response = fib($n);
|
|
|
|
$channel->publish(
|
|
exchange => '',
|
|
routing_key => $props->{reply_to},
|
|
header => {
|
|
correlation_id => $props->{correlation_id},
|
|
},
|
|
body => $response,
|
|
);
|
|
|
|
$channel->ack();
|
|
}
|
|
|
|
$channel->qos(prefetch_count => 1);
|
|
$channel->consume(
|
|
on_consume => \&on_request,
|
|
);
|
|
|
|
print " [x] Awaiting RPC requests\n";
|
|
|
|
# Wait forever
|
|
AnyEvent->condvar->recv;
|