StandaloneRequestor extends StandaloneProducer { @Override public void doService(AdaptrisMessage m) throws ServiceException { try { AdaptrisMessage reply; if (timeoutOverrideMs() == -1L) { reply = getProducer().request(m); } else { reply = getProducer().request(m, timeoutOverrideMs()); } if (reply != null && m != null && reply != m) { log.trace("Copying reply message into original message"); copy(reply, m); } } catch (Exception e) { throw ExceptionHelper.wrapServiceException(e); } } StandaloneRequestor();  StandaloneRequestor(AdaptrisMessageProducer p);  StandaloneRequestor(AdaptrisConnection c, AdaptrisMessageProducer p);  StandaloneRequestor(AdaptrisConnection c, AdaptrisMessageProducer p, TimeInterval timeout); @Override void doService(AdaptrisMessage m); TimeInterval getReplyTimeout(); void setReplyTimeout(TimeInterval timeoutOverride);  }
@Test public void testNullMessage() throws Exception { StandaloneRequestor service = new StandaloneRequestor(); service.doService(null); }