@Test
public void testConnectionCorrectlyClosed() throws InterruptedException{

	
	mockThread.join();
//	expectLastCall().once();
	
	expect(mockConnection.isClosed()).andReturn(true).once();
	replay(mockConnection, mockLogger, mockThread);
	testClass.run();
	verify(mockConnection, mockLogger, mockThread);
}