AddTaskToQueue adds a task to the specified queue using the RabbitMQ client. It calls the addTask method with the configuration's QueueRunPipe queue name and the provided message. Returns an error if the task addition fails.
(message types.Process)
| 175 | // It calls the addTask method with the configuration's QueueRunPipe queue name and the provided message. |
| 176 | // Returns an error if the task addition fails. |
| 177 | func (q *queue) AddTaskToQueue(message types.Process) error { |
| 178 | return q.addTask(q.configuration.QueueRunPipe, message) |
| 179 | } |
| 180 | |
| 181 | // AddTaskAsSuccess adds a task to the specified queue as a successful task using the RabbitMQ client. |
| 182 | // It calls the addTask method with the configuration's QueueTaskSucceed queue name and the provided message. |