diff --git a/backend-nest/src/modules/plugins/plugins.service.ts b/backend-nest/src/modules/plugins/plugins.service.ts
index a8f3aec..03308d0 100644
--- a/backend-nest/src/modules/plugins/plugins.service.ts
+++ b/backend-nest/src/modules/plugins/plugins.service.ts
@@ -45,7 +45,21 @@ export class PluginsService {
       is_loaded: false,
     });
 
-    return this.pluginRegistryRepo.save(plugin);
+    const saved = await this.pluginRegistryRepo.save(plugin);
+
+    try {
+      await this.natsService.publish(`corrosion.${licenseId}.cmd.server`, {
+        action: 'plugin_install',
+        plugin_name: dto.plugin_name,
+        umod_slug: dto.umod_slug,
+        timestamp: new Date().toISOString(),
+      });
+      this.logger.log(`Plugin install dispatched for ${dto.plugin_name} on license ${licenseId}`);
+    } catch (err) {
+      this.logger.error(`Failed to dispatch plugin install for ${dto.plugin_name} on license ${licenseId}: ${(err as Error).message}`);
+    }
+
+    return saved;
   }
 
   async uninstallPlugin(licenseId: string, pluginId: string): Promise<void> {
diff --git a/backend-nest/src/modules/servers/servers.service.ts b/backend-nest/src/modules/servers/servers.service.ts
index 6c1417e..5643120 100644
--- a/backend-nest/src/modules/servers/servers.service.ts
+++ b/backend-nest/src/modules/servers/servers.service.ts
@@ -1,4 +1,4 @@
-import { Injectable, NotFoundException } from '@nestjs/common';
+import { Injectable, NotFoundException, InternalServerErrorException, Logger } from '@nestjs/common';
 import { InjectRepository } from '@nestjs/typeorm';
 import { Repository } from 'typeorm';
 import { ServerConnection } from '../../entities/server-connection.entity';
@@ -9,6 +9,8 @@ import { DeployServerDto } from './dto/deploy-server.dto';
 
 @Injectable()
 export class ServersService {
+  private readonly logger = new Logger(ServersService.name);
+
   constructor(
     @InjectRepository(ServerConnection)
     private readonly connectionRepo: Repository<ServerConnection>,
@@ -60,8 +62,14 @@ export class ServersService {
    * Send a console command to the server via NATS
    */
   async sendCommand(licenseId: string, command: string) {
-    await this.natsService.sendServerCommand(licenseId, 'command', { command });
-    return { output: 'Command sent' };
+    try {
+      await this.natsService.sendServerCommand(licenseId, 'command', { command });
+      this.logger.log(`Console command dispatched for license ${licenseId}: ${command}`);
+    } catch (err) {
+      this.logger.error(`Failed to dispatch console command for license ${licenseId}: ${(err as Error).message}`);
+      throw new InternalServerErrorException('Failed to dispatch command to server');
+    }
+    return { success: true, message: 'Command dispatched' };
   }
 
   /**