Data cleaning and publishing

Consume data from an MQTT-Broker and do some cleaning, at the end republish this data.

    def topic_in = 'my/topic/in'
    def topic_out = 'my/topic/out'
    def host = ''


    %% here is were we clean data

        lambda: int("u_length" * 1000),
        lambda: int("u_width" * 1000),
        lambda: int("lc_quantity"),
        lambda: int("pcs_lost")
    %% overwrite the original fields 


    % publish the resulting message 


Note: If topic_in = topic_out we create a loop using the mqtt broker, something we do not want normally.