(self, recv_once=False, recv_queue=None)
Constructor

        Args:
            recv_once : Receive a single message and stop
            recv_queue : Queue to mirror (store) the saved/serialized messages

        Note:
            The constructor options are useful for testing but are not
            necessary in production code.
Constructor
Constructor
def __init__(self, recv_once=False, recv_queue=None):
        """Constructor

        Args:
            recv_once : Receive a single message and stop
            recv_queue : Queue to mirror (store) the saved/serialized messages

        Note:
            The constructor options are useful for testing but are not
            necessary in production code.

        """
        self.enabled = True
        self.recv_once = recv_once
        assert (recv_queue is None or isinstance(recv_queue, queue.Queue))
        self.recv_queue = recv_queue
def __init__ ( self , recv_once = False , recv_queue = None ) : self . enabled = True self . recv_once = recv_once assert ( recv_queue is None or isinstance ( recv_queue , queue . Queue ) ) self . recv_queue = recv_queue