[Excution] - base function accomplish - 4

agent-go/rabbitmq/OctopusMessage.go

@@ -22,6 +22,8 @@ type OctopusMsgHandler interface {
 
 type OctopusMsgSender interface {
 	Send(rabbitQueue *RabbitQueue, msg []byte)
+
+	SendToOctopusServer()
 }
 
 type OctopusMsgBuilder interface {
@@ -47,6 +49,20 @@ func (om *OctopusMessage) Send(rabbitQueue *RabbitQueue, msg []byte) {
 	rabbitQueue.Send(msg)
 }
 
+// SendToOctopusServer send octopus message back to octopusToServer queue
+func (om *OctopusMessage) SendToOctopusServer() {
+
+	// write the octopus message to bytes
+	octopusMessageReplayBytes, err := json.Marshal(om)
+	if err != nil {
+		log.ErrorF("replay octopus message write error => %v", err)
+	}
+
+	// Send back the result to queue
+	OctopusToServerQueue.Send(octopusMessageReplayBytes)
+
+}
+
 func (om *OctopusMessage) Build(omType string, content interface{}) *OctopusMessage {
 
 	// 当前时间
@@ -111,7 +127,19 @@ func executorOMHandler(octopusMessage *OctopusMessage) {
 	}
 
 	// 交给后端的实际处理器处理， 再次策略
-	executor.Execute(executionMessage)
+	resultLog, err := executor.Execute(executionMessage)
+	if err != nil {
+		octopusMessage.ResultCode = "200"
+	} else {
+		octopusMessage.ResultCode = "300"
+	}
+
+	//  send back the result log
+	octopusMessage.Result = resultLog
+	octopusMessage.ACTime = utils.ParseISOLocalDateTime()
+
+	// Send
+	octopusMessage.SendToOctopusServer()
 }
 
 func statusOMHandler(octopusMessage *OctopusMessage) {