#!/opt/bin/perl

use AnyEvent;
use AnyEvent::MP;

configure nodeid => "eg_receiver/%u", binds => ["*:4041"];

my $port = port;
db_set eg_receivers => $port;

rcv $port, test => sub {
   my ($data, $reply_port) = @_;

   print "Received data: " . $data . "\n";
};

AnyEvent->condvar->recv;