diff --git a/src/overlord/minion/handle_websocket.rs b/src/overlord/minion/handle_websocket.rs index 37095c8a..8dbc3d08 100644 --- a/src/overlord/minion/handle_websocket.rs +++ b/src/overlord/minion/handle_websocket.rs @@ -48,7 +48,7 @@ impl Minion { .get_handle_by_id(&subid.0) .unwrap_or_else(|| "_".to_owned()); - let close: bool = &handle[0..5] == "event"; + let close: bool = &handle[0..5] == "temp_"; // Update the matching subscription match self.subscriptions.get_mut_by_id(&subid.0) { diff --git a/src/overlord/minion/mod.rs b/src/overlord/minion/mod.rs index 08983731..b37e065d 100644 --- a/src/overlord/minion/mod.rs +++ b/src/overlord/minion/mod.rs @@ -367,7 +367,7 @@ impl Minion { debug!("{}: Event Filter: {} events", &self.url, filter.ids.len()); // create a handle for ourselves - let handle = format!("events{}", self.next_events_subscription_id); + let handle = format!("temp_events_{}", self.next_events_subscription_id); self.next_events_subscription_id += 1; // save the subscription