natsio/subject/queue.go

package subject

import "fmt"

func getQueueValue(val string) string {
	return fmt.Sprintf("%s.%s", prefixes.Queue, val)
}

var Queue = struct {
	ScheduleTask string
}{
	ScheduleTask: getQueueValue("schedule_task"),
}