From e38a8611f184228f21b69555d0f4b0bab0d0208b Mon Sep 17 00:00:00 2001
From: rmanach <romain.manach@intercloud.com>
Date: Wed, 19 Apr 2023 11:56:46 +0200
Subject: [PATCH] start stopping manager

---
 src/main.rs            | 2 +-
 src/message/message.rs | 2 +-
 src/model/job.rs       | 2 +-
 3 files changed, 3 insertions(+), 3 deletions(-)

diff --git a/src/main.rs b/src/main.rs
index a1d651d..098c56d 100644
--- a/src/main.rs
+++ b/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);
     }
diff --git a/src/message/message.rs b/src/message/message.rs
index 62d0195..700bab4 100644
--- a/src/message/message.rs
+++ b/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,
diff --git a/src/model/job.rs b/src/model/job.rs
index c045e3b..df644e8 100644
--- a/src/model/job.rs
+++ b/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,