diff --git a/src/database/etcd.js b/src/database/etcd.js
index 26859f2..40167c8 100644
--- a/src/database/etcd.js
+++ b/src/database/etcd.js
@@ -16,13 +16,13 @@ class EtcdServer {
     this.client = null;
     this.watchers = new Map();
     this.hosts = [`${ETCD_HOST}:${ETCD_PORT}`];
-    logger.debug(`EtcdServer constructor: hosts set to ${JSON.stringify(this.hosts)}`);
+    logger.trace(`EtcdServer constructor: hosts set to ${JSON.stringify(this.hosts)}`);
   }
 
   async connect() {
     if (!this.client) {
       logger.info('Connecting to Etcd...');
-      logger.debug(`Creating Etcd client with hosts ${JSON.stringify(this.hosts)}`);
+      logger.trace(`Creating Etcd client with hosts ${JSON.stringify(this.hosts)}`);
       this.client = new Etcd3({
         hosts: this.hosts,
       });
@@ -30,16 +30,16 @@ class EtcdServer {
       // Test connection
       try {
         await this.client.get('test-connection').string();
-        logger.debug('Etcd client connected successfully.');
+        logger.trace('Etcd client connected successfully.');
       } catch (error) {
         if (error.code === 'NOT_FOUND') {
-          logger.debug('Etcd client connected successfully (test key not found as expected).');
+          logger.trace('Etcd client connected successfully (test key not found as expected).');
         } else {
           throw error;
         }
       }
     } else {
-      logger.debug('Etcd client already exists, skipping connection.');
+      logger.trace('Etcd client already exists, skipping connection.');
     }
     return this.client;
   }
@@ -47,7 +47,7 @@ class EtcdServer {
   async getClient() {
     logger.trace('Checking if Etcd client exists.');
     if (!this.client) {
-      logger.debug('No client found, calling connect().');
+      logger.trace('No client found, calling connect().');
       await this.connect();
     }
     logger.trace('Returning Etcd client.');
@@ -60,7 +60,7 @@ class EtcdServer {
     const stringValue = typeof value === 'string' ? value : JSON.stringify(value);
 
     await client.put(key).value(stringValue);
-    logger.debug(`Set key: ${key}, value: ${stringValue}`);
+    logger.trace(`Set key: ${key}, value: ${stringValue}`);
     return true;
   }
 
@@ -69,7 +69,7 @@ class EtcdServer {
 
     try {
       const value = await client.get(key).string();
-      logger.debug(`Retrieved key: ${key}, value: ${value}`);
+      logger.trace(`Retrieved key: ${key}, value: ${value}`);
 
       // Try to parse as JSON, fallback to string
       try {
@@ -79,7 +79,7 @@ class EtcdServer {
       }
     } catch (error) {
       if (error.code === 'NOT_FOUND') {
-        logger.debug(`Key not found: ${key}`);
+        logger.trace(`Key not found: ${key}`);
         return null;
       }
       throw error;
@@ -91,7 +91,7 @@ class EtcdServer {
 
     // Stop all watchers
     for (const [key, watcher] of this.watchers) {
-      logger.debug(`Stopping watcher: ${key}`);
+      logger.trace(`Stopping watcher: ${key}`);
       watcher.removeAllListeners();
       await watcher.close();
     }
diff --git a/src/utils.js b/src/utils.js
index 9c52295..cda9411 100644
--- a/src/utils.js
+++ b/src/utils.js
@@ -1,6 +1,7 @@
 import { ObjectId } from 'mongodb';
 import { auditLogModel } from './schemas/management/auditlog.schema.js';
 import { etcdServer } from './database/etcd.js';
+import { natsServer } from './database/nats.js';
 
 function parseFilter(property, value) {
   if (typeof value === 'string') {
@@ -383,11 +384,15 @@ async function getAuditLogs(idOrIds) {
 }
 
 async function distributeUpdate(value, id, type) {
-  await etcdServer.setKey(`/${type}s/${id}/object`, value);
+  await natsServer.publish(`${type}s.${id}.object`, value);
 }
 
-async function distributeNew(id, type) {
-  await etcdServer.setKey(`/${type}s/new`, id);
+async function distributeNew(value, type) {
+  await natsServer.publish(`${type}s.new`, value);
+}
+
+async function distributeDelete(value, type) {
+  await natsServer.publish(`${type}s.delete`, value);
 }
 
 function flatternObjectIds(object) {
@@ -487,6 +492,7 @@ export {
   expandObjectIds,
   distributeUpdate,
   distributeNew,
+  distributeDelete,
   getFilter, // <-- add here
   convertPropertiesString,
 };