Function newQueue

common/persistence/sql/queue.go:24–36

(
	db sqlplugin.DB,
	logger log.Logger,
	queueType persistence.QueueType,
	serializer serialization.Serializer,
)

)

func newQueue(
	db sqlplugin.DB,
	logger log.Logger,
	queueType persistence.QueueType,
	serializer serialization.Serializer,
) (persistence.Queue, error) {
	queue := &sqlQueue{
		SqlStore:  NewSQLStore(db, logger, serializer),
		queueType: queueType,
		logger:    logger,
	}
	return queue, nil
}

func (q *sqlQueue) Init(
	ctx context.Context,