pub fn notify_deleted(&self, repository_id: &str) {
		let repository =
			Repositories::new(self.connection_manager.clone()).find_by_id(repository_id);
		match repository {
			Some(repository) => {
				info!("Removing queue for repository {}", &repository_id);
				let mut queues = self.queues.write();
				let queue_service = queues.remove(&repository.slug);

				match queue_service {
					Some(queue_service) => {
						info!("Notifying service to clean up repository.");
						queue_service.notify();
					}
					None => {
						warn!(
							"Service for repository {} did not exist. Not cleaning up.",
							&repository.slug
						);
					}
				}
			}
			None => warn!(
				"Could not remove queue for repository {}. Not found.",
				&repository_id
			),
		}
	}
/// Preemptively removes the queue associated with the repository from the queue_manager.
Preemptively removes the queue associated with the repository from the queue_manager.
Preemptively removes the queue associated with the repository from the queue_manager .
pub fn notify_deleted(&self, repository_id: &str) {
		let repository =
			Repositories::new(self.connection_manager.clone()).find_by_id(repository_id);
		match repository {
			Some(repository) => {
				info!("Removing queue for repository {}", &repository_id);
				let mut queues = self.queues.write();
				let queue_service = queues.remove(&repository.slug);
				match queue_service {
					Some(queue_service) => {
						info!("Notifying service to clean up repository.");
						queue_service.notify();
					}
					None => {
						warn!(
							"Service for repository {} did not exist. Not cleaning up.",
							&repository.slug
						);
					}
				}
			}
			None => warn!(
				"Could not remove queue for repository {}. Not found.",
				&repository_id
			),
		}
	}
pub fn notify_deleted ( & self , repository_id : & str ) { let repository = Repositories :: new ( self . connection_manager . clone ( ) ) . find_by_id ( repository_id ) ; match repository { Some ( repository ) => { info ! ( " " repository_id ) ; let mut queues = self . queues . write ( ) ; let queue_service = queues . remove ( & repository . slug ) ; match queue_service { Some ( queue_service ) => { info ! ( " " ) ; queue_service . notify ( ) ; } None => { warn ! ( " " repository slug ) ; } } } None => warn ! ( " " repository_id ) , } }
Preemptively removes the queue associated with the repository from the queue_manager.
Preemptively removes the queue associated with the repository from the queue_manager .
&self
repository_id
&str