def METHOD_NAME(self):
    """One process test, one subscriber, one publisher."""
    queue = self.pubsub.subscribe("a.b.c")
    self.pubsub.publish("test message", "a.b.c")
    # expected message to receive
    msg = PubSubMessage("test message", "a.b.c")
    got = queue.get()
    self.assertTrue(queue._queue.empty())
    queue = self.pubsub.unsubscribe(queue)
    self.assertEqual(str(got), str(msg))