   @Test
   public void testWithFakeQueue() throws IOException {

//    String jsonMsg = "{\"version\":1,\"cluster_name\":\"cName\",\"jobtracker\":\"1.2.3.6\",\"instance_num\":4,\"node_groups\":[\"compute\"],\"serengeti_instance\":\"SERENGETI-vApp-xxx\"}";
      File file = new File("/tmp/vhm.json.msg");
      String jsonMsg = FileUtils.readFileToString(file);
      
      VHMInputMessage input = new VHMJsonInputMessage(jsonMsg.getBytes());
      _test.setNumTTVMsForCluster(input);
   }