}
                if let Err(err) =
                    Self::process(&stopping, &data_receiver, &db, &store, &socket_path)
                {
                    warn!("{}", err)

            }

            while !data_receiver.is_empty() {