@Test
public void testSendingToCorrectQueue() {

    prepareDefaultMockAnswers(SELECTIVE_HARVEST_CHANNEL, jobMock, false);
    jobDispatcher.submitNextNewJob(SELECTIVE_HARVEST_CHANNEL);
    verify(jmsConnection).send(crawlMessageCaptor.capture());
    assertTrue(jobMock == crawlMessageCaptor.getValue().getJob());
    assertEquals(HarvesterChannels.getHarvestJobChannelId(SELECTIVE_HARVEST_CHANNEL), crawlMessageCaptor.getValue()
            .getTo());
    reset(jmsConnection);
    Job snapshotJob = createJob(2);
    prepareDefaultMockAnswers(SNAPSHOT, snapshotJob, false);
    jobDispatcher.submitNextNewJob(SNAPSHOT);
    verify(jmsConnection).send(crawlMessageCaptor.capture());
    assertTrue(snapshotJob == crawlMessageCaptor.getValue().getJob());
    assertEquals(HarvesterChannels.getHarvestJobChannelId(SNAPSHOT), crawlMessageCaptor.getValue().getTo());
}