| 201 | } |
| 202 | |
| 203 | func (q *SQLiteQueue) GetQueue(tenantId int64, queueName string) (models.QueueProperties, error) { |
| 204 | queue := models.QueueProperties{} |
| 205 | |
| 206 | properties, err := q.getQueue(tenantId, queueName) |
| 207 | if err != nil { |
| 208 | return queue, err |
| 209 | } |
| 210 | |
| 211 | queue.Name = properties.Name |
| 212 | queue.RateLimit = properties.RateLimit |
| 213 | queue.MaxRetries = properties.MaxRetries |
| 214 | queue.VisibilityTimeout = properties.VisibilityTimeout |
| 215 | |
| 216 | return queue, nil |
| 217 | } |
| 218 | |
| 219 | func (q *SQLiteQueue) DeleteQueue(tenantId int64, queueName string) error { |
| 220 | // Delete all messages with the queue, and then the queue itself |