Browse Source

added request ack on register

0xdcarns 2 years ago
parent
commit
9103efa88f
1 changed files with 7 additions and 0 deletions
  1. 7 0
      controllers/enrollmentkeys.go

+ 7 - 0
controllers/enrollmentkeys.go

@@ -11,6 +11,7 @@ import (
 	"github.com/gravitl/netmaker/logic"
 	"github.com/gravitl/netmaker/logic/hostactions"
 	"github.com/gravitl/netmaker/models"
+	"github.com/gravitl/netmaker/mq"
 	"github.com/gravitl/netmaker/servercfg"
 )
 
@@ -210,4 +211,10 @@ func checkNetRegAndHostUpdate(networks []string, h *models.Host) {
 			})
 		}
 	}
+	if servercfg.IsMessageQueueBackend() {
+		mq.HostUpdate(&models.HostUpdate{
+			Action: models.RequestAck,
+			Host:   *h,
+		})
+	}
 }