queue

type QueueDI interface {
	NewServ() (QueueServ, error)
}

type QueueServ interface {
	RegisterTasks(workers ...Worker) error
	StartWorker() error
	SendTask(taskName string, args []tasks.Arg) (*tasks.TaskState, error)
}

type RabbitMQConf struct {
	*amqpConf.Config `yaml:",inline"`
}

type Worker interface {
	Register(tasks map[string]interface{})
	Enable() bool
}