def METHOD_NAME(self):
    topic, body, seq = self.socket.recv_multipart()
    # Topic should match the subscriber topic.
    assert_equal(topic, self.topic)
    # Sequence should be incremental.
    assert_equal(struct.unpack('<I', seq)[-1], self.sequence)
    self.sequence += 1
    return body