Use vm id for internal trigger subject construction

synadia-io · Jan 9, 2024 · 8cbe575 · 8cbe575
1 parent 433ff31
commit 8cbe575
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/nex-node/machine_mgr.go b/nex-node/machine_mgr.go
@@ -154,7 +154,7 @@ func (m *MachineManager) DispatchWork(vm *runningFirecracker, workloadName, name
 	} else if request.SupportsTriggerSubjects() {
 		for _, tsub := range request.TriggerSubjects {
 			_, err := m.nc.Subscribe(tsub, func(msg *nats.Msg) {
-				_tsub := fmt.Sprintf("agentint.%s.trigger", msg.Data)
+				_tsub := fmt.Sprintf("agentint.%s.trigger", vm.vmmID)
 				resp, err := m.ncInternal.Request(_tsub, msg.Data, time.Millisecond*10000) // FIXME-- make timeout configurable
 				if err != nil {
 					m.log.WithField("vmid", vm.vmmID).