@Test
public void testQueue() throws Exception {

  destinationType = JMSDestinationType.QUEUE;
  when(session.createQueue(destinationName)).thenReturn(queue);
  consumer = create();
  List<Event> events = consumer.take();
  assertEquals(batchSize, events.size());
  assertBodyIsExpected(events);
  verify(session, never()).createTopic(anyString());
}