Method RemoveProcessor

subscriber/common/job/driver.go:207–212

RemoveProcessor will remove a processor from driver.

(ID int)

// RemoveProcessor will remove a processor from driver.
func (d *Driver) RemoveProcessor(ID int) bool {
	d.Lock()
	defer d.Unlock()

	return d.removeProcessor(ID)
}

func (d *Driver) removeProcessor(ID int) bool {
	// if no processors running, nothing to remove