@Test
public void testClose() throws Exception {

  doThrow(new JMSException("")).when(session).close();
  consumer = create();
  consumer.close();
  verify(session, times(1)).close();
  verify(connection, times(1)).close();
}