### Question:
ResponseTimeMessageInvokerInterceptor extends AbstractMessageResponseTimeInterceptor { public void handleMessage(Message message) throws Fault { Exchange ex = message.getExchange(); boolean forceDisabled = Boolean.FALSE.equals(ex.get("org.apache.cxf.management.counter.enabled")); if (!forceDisabled && isServiceCounterEnabled(ex)) { message.getInterceptorChain().add(new ResponseTimeMessageInvokerEndingInteceptor()); } } ResponseTimeMessageInvokerInterceptor(); void handleMessage(Message message); @Override void handleFault(Message message);  }### Answer:
@Test public void testServerOneWayMessageIn() { setupCounterRepository(true, false); setupExchangeForMessage(); setupOperationForMessage(); EasyMock.expect(message.getExchange()).andReturn(exchange); EasyMock.expect(message.get(Message.REQUESTOR_ROLE)).andReturn(Boolean.FALSE).anyTimes(); EasyMock.expect(exchange.getOutMessage()).andReturn(message); MessageHandlingTimeRecorder mhtr = EasyMock.createMock(MessageHandlingTimeRecorder.class); mhtr.setOneWay(true); EasyMock.expectLastCall(); mhtr.endHandling(); EasyMock.expectLastCall(); EasyMock.replay(mhtr); EasyMock.expect(exchange.isOneWay()).andReturn(true); EasyMock.expect(exchange.get(MessageHandlingTimeRecorder.class)).andReturn(mhtr); EasyMock.replay(exchange); EasyMock.replay(message); rtmii.handleMessage(message); EasyMock.verify(message); EasyMock.verify(bus); EasyMock.verify(exchange); EasyMock.verify(mhtr); }