def METHOD_NAME(queue, items):
    """
    Add an item or items to a queue
    """
    handle_queue_creation(queue)
    with _conn(commit=True) as cur:
        if isinstance(items, dict):
            items = salt.utils.json.dumps(items)
            cmd = "INSERT INTO {}(data) VALUES('{}')".format(queue, items)
            log.debug("SQL Query: %s", cmd)
            try:
                cur.execute(cmd)
            except psycopg2.IntegrityError as esc:
                return "Item already exists in this queue. postgres error: {}".format(
                    esc
                )
        if isinstance(items, list):
            items = [(salt.utils.json.dumps(el),) for el in items]
            cmd = "INSERT INTO {}(data) VALUES (%s)".format(queue)
            log.debug("SQL Query: %s", cmd)
            try:
                cur.executemany(cmd, items)
            except psycopg2.IntegrityError as esc:
                return (
                    "One or more items already exists in this queue. "
                    "postgres error: {}".format(esc)
                )
    return True