func()

in internal/queue/eventmesh_queue.go [152:168]

• 16 lines of code
• 2 McCabe index (conditional complexity)

func (q *eventMeshQueue) toEventMeshMessage(task *model.WorkflowTaskInstance) (*sdk_pb.SimpleMessage, error) {
	taskJsonBytes, err := json.Marshal(task)
	if err != nil {
		return nil, err
	}

	message := &sdk_pb.SimpleMessage{
		Header:        sdk.CreateHeader(q.grpcConfig),
		ProducerGroup: q.workflowConfig.EventMesh.ProducerGroup,
		Topic:         q.observeTopic,
		Content:       string(taskJsonBytes),
		Ttl:           gconv.String(q.workflowConfig.EventMesh.TTL),
		UniqueId:      uuid.New().String(),
		SeqNum:        uuid.New().String(),
	}
	return message, nil
}