$connection->on(each_message => sub {
my ($conn, $message) = @_;
+ my $now = [Time::HiRes::gettimeofday];
print STDERR "Message: $message->{'body'}\n";
my $json = JSON::XS::decode_json($message->{'body'});
eval {
if (exists($json->{'payload'}{'event'})) {
+ if (exists($json->{'payload'}{'event'}{'event_ts'}) &&
+ $json->{'payload'}{'event'}{'event_ts'} =~ /(\d+)\.(\d+)/) {
+ my $elapsed = Time::HiRes::tv_interval([$1, $2], $now);
+ printf STDERR "Message used %.1f ms to reach us.\n", 1e3 * $elapsed;
+ }
handle_event($json->{'payload'}{'event'});
}
};