temp

Author: jpraynaud

internal/mithril-dmq/src/consumer/client/pallas.rs

@@ -138,6 +138,12 @@ impl<M: TryFromBytes + Debug + Sync + Send> DmqConsumerClient<M> for DmqConsumer
     }
 }
 
+impl<M: TryFromBytes + Debug> Drop for DmqConsumerClientPallas<M> {
+    fn drop(&mut self) {
+        dbg!("Dropping DMQ consumer client");
+    }
+}
+
 #[cfg(all(test, unix))]
 mod tests {
 

internal/mithril-dmq/src/consumer/server/pallas.rs

@@ -273,6 +273,12 @@ impl DmqConsumerServer for DmqConsumerServerPallas {
     }
 }
 
+impl Drop for DmqConsumerServerPallas {
+    fn drop(&mut self) {
+        dbg!("Dropping DMQ consumer server");
+    }
+}
+
 #[cfg(test)]
 mod tests {
     use std::{sync::Arc, time::Duration};