def METHOD_NAME(self):
    ctx = zmq.asyncio.Context().instance()
    loop = asyncio.get_event_loop()
    self.start_publisher()
    self.async_sleep(1)
    sub = ctx.socket(zmq.SUB)
    sub.setsockopt(zmq.SUBSCRIBE, b'')
    sub.bind('tcp://127.0.0.1:19080')
    asyncio.ensure_future(sub.poll(timeout=1))
    self.async_sleep(1)
    message_str = 'testing'
    self.publisher.publish_message_str(message_str)
    self.async_sleep(1)
    event = 0
    while not event:
        event = loop.run_until_complete(sub.poll(timeout=50))
        self.async_sleep(1)
    res = loop.run_until_complete(sub.recv_multipart())
    sub.close(linger=10)
    message_received = res[0].decode('UTF-8')
    self.assertEqual(message_str, message_received)