@Test
public void testTopic() throws Exception {

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