def METHOD_NAME(self):
    queue = self.pubsub.subscribe("a.b.c", predicate_contains_hello)
    self.pubsub.publish("bonjour ici", "a.b.c") # should not be received
    self.pubsub.publish("hello there", "a.b.c") # should be received
    # expected message to receive
    msg = PubSubMessage("hello there", "a.b.c")
    got = queue.get()
    self.assertTrue(queue._queue.empty()) # should only receive one message
    queue = self.pubsub.unsubscribe(queue)
    self.assertEqual(str(got), str(msg))