Function my_iot::core::persistence::thread::process_message

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

Process a message.