Source code for minos.networks.brokers.publishers.queued.queues.database

from __future__ import (
    annotations,
)

import logging
from abc import (
    ABC,
)

from ....collections import (
    BrokerQueueDatabaseOperationFactory,
    DatabaseBrokerQueue,
)
from .abc import (
    BrokerPublisherQueue,
)

logger = logging.getLogger(__name__)


[docs]class BrokerPublisherQueueDatabaseOperationFactory(BrokerQueueDatabaseOperationFactory, ABC):
    """Broker Publisher Queue Database Operation Factory class."""


[docs]class DatabaseBrokerPublisherQueue(
    DatabaseBrokerQueue[BrokerPublisherQueueDatabaseOperationFactory], BrokerPublisherQueue
):
    """Database Broker Publisher Queue class."""