Function my_iot::persistence::process_message

fn process_message(
    message: Message, 
    db: &Arc<Mutex<Db>>, 
    tx: &Sender<Message>
) -> Result<(), Error>

Process a message.