Method getQueue

queue/sqlite/sqlite.go:264–271

(tenantId int64, queueName string)

}

func (q *SQLiteQueue) getQueue(tenantId int64, queueName string) (*Queue, error) {
	rc := &Queue{}
	res := q.DBG.Where("tenant_id = ? AND name = ?", tenantId, queueName).First(rc)
	if res.RowsAffected != 1 {
		return nil, errors.New("Queue not found")
	}
	return rc, res.Error
}

func (q *SQLiteQueue) Enqueue(tenantId int64, queueName string, message string, kv map[string]string, delay int) (int64, error) {
	messageSnow := q.snow.Generate()