mule-file-mqtt-blink1.xml

<flow name="fileToMqttBridge">
    <file:inbound-endpoint path="/tmp/mule/in" />

    <object-to-string-transformer />

    <!-- extract attendee info and transform to JSON payload -->
    <expression-transformer
        expression="#[extractAttendeeData(message.payload, '${boothId}')]" />
    <json:object-to-json-transformer />

    <mqtt:publish topicName="scans/booths" />

    <blink1:start-pattern deviceId="${blink1.device.id}" />

    <logger level="INFO"
        message="Booth ${boothId} has scanned attendee #[attendeeId]" />

    <expression-component>Thread.sleep(1000);</expression-component>

    <blink1:stop-pattern deviceId="${blink1.device.id}" />
    <blink1:set-color deviceId="${blink1.device.id}" color="off" />
</flow>