start stopping manager

src/main.rs

@@ -31,7 +31,7 @@ fn main() {
     checker.launch_workers::<Job, CheckHandler>(5, Arc::new(check_handler));
     checker.subscribe(receiver);
 
-    for i in 0..5000 {
+    for i in 0..500 {
         let message = Message::new(i, Subject::Action(JobAction::Deploy));
         deployer.put_message(message);
     }

src/message/message.rs

@@ -1,6 +1,6 @@
 use crate::model::JobAction;
 
-#[derive(Debug, Clone, Copy)]
+#[derive(Debug, Clone, Copy, PartialEq)]
 pub enum Subject {
     Action(JobAction),
     StopManager,

src/model/job.rs

@@ -4,7 +4,7 @@ use super::{Runner, RunnerStatus, Storer};
 use crate::error::{MessageError, RunnerError, StorerError};
 use crate::message::{Message, Subject};
 
-#[derive(Debug, Clone, Copy)]
+#[derive(Debug, Clone, Copy, PartialEq)]
 pub enum JobAction {
     Deploy,
     Check,