Watch a pipe for files and publish messages to RabbitMQ