    def get_publisher_queue(self):
        """Get the queue used by the publisher.

        Returns:
            a :class:`multiprocessing.Queue`.
        """

        return self.publisher_queue
Get the queue used by the publisher.

Returns:
a :class:`multiprocessing.Queue`.
bigchaindb/events.py