Rex+MQTT

Rexfile

use strict;
use warnings;

use Rex -feature => [ '1.4', 'exec_autodie' ];
use Net::MQTT::Simple;
use Time::HiRes qw(time);

no_ssh task 'agent', sub {
    my $mqtt = Net::MQTT::Simple->new('localhost');
    $mqtt->run(
        "topic/test" => sub {
            my ( $topic, $message ) = @_;
            run_task 'config',
              params => { topic => $topic, message => $message };
        },
    );
};

task 'config', sub {
    my $params = shift;
    my $time   = time;
    LOCAL {
        file '/tmp/mqtt', content => qq($time [$params->{topic}] $params->{message});
    }
};