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

import logging

from ....collections import (
    InMemoryBrokerQueue,
)
from .abc import (
    BrokerPublisherQueue,
)

logger = logging.getLogger(__name__)


[docs]class InMemoryBrokerPublisherQueue(InMemoryBrokerQueue, BrokerPublisherQueue):
    """In Memory Broker Publisher Queue class."""