@Test
public void testQueueProcessor() {

  ContextProcessor queueProcessor = new QueueProcessor();
  ApplicationId app = ApplicationId.newInstance(123456, 111);
  ApplicationSubmissionContext applicationSubmissionContext =
      mock(ApplicationSubmissionContext.class);
  when(applicationSubmissionContext.getApplicationId()).thenReturn(app);
  queueProcessor.process("host.cluster2.com", "queue1",
      app, applicationSubmissionContext);
  verify(applicationSubmissionContext, times(1)).setQueue("queue1");
}