|
@@ -609,7 +609,8 @@ func deleteNode(w http.ResponseWriter, r *http.Request) {
|
|
|
|
|
|
func runUpdates(node *models.Node, nodeUpdate bool) error {
|
|
func runUpdates(node *models.Node, nodeUpdate bool) error {
|
|
//don't publish to server node
|
|
//don't publish to server node
|
|
- if nodeUpdate && !isServer(node) {
|
|
|
|
|
|
+
|
|
|
|
+ if nodeUpdate && !isServer(node) && servercfg.IsMessageQueueBackend() {
|
|
if err := mq.NodeUpdate(node); err != nil {
|
|
if err := mq.NodeUpdate(node); err != nil {
|
|
logger.Log(1, "error publishing node update", err.Error())
|
|
logger.Log(1, "error publishing node update", err.Error())
|
|
return err
|
|
return err
|