### Question:
MessageQueueHealthManager { public void markQueueHealthy(MessageQueue mq) { if (faultMap.containsKey(mq)) { LOGGER.info("mark queue healthy. {}", mq); faultMap.remove(mq); } } MessageQueueHealthManager(long isoTime); void markQueueFault(MessageQueue mq); void markQueueHealthy(MessageQueue mq); boolean isQueueFault(MessageQueue mq); boolean isQueueHealthy(MessageQueue mq); static final Logger LOGGER; final ConcurrentHashMap<MessageQueue, Long/*isolate expire timestamp*/> faultMap; }### Answer:
@Test public void testMarkQueueHealthy() throws Exception { MessageQueue mq = new MessageQueue("topic1", "brokerName1", 0); messageQueueHealthManager.markQueueFault(mq); assertTrue(messageQueueHealthManager.isQueueFault(mq)); messageQueueHealthManager.markQueueHealthy(mq); assertTrue(messageQueueHealthManager.isQueueHealthy(mq)); }