@Test public void testConsumerProducer() throws Exception { AdaptrisMessageProducer mp = mock(AdaptrisMessageProducer.class); StandaloneRequestor service = new StandaloneRequestor(mp); service.setReplyTimeout(new TimeInterval(-1L, TimeUnit.MILLISECONDS)); AdaptrisMessage msg = AdaptrisMessageFactory.getDefaultInstance().newMessage("XYZ"); doReturn(msg).when(mp).request(msg); execute(service, msg); }
public void setReplyTimeout(TimeInterval timeoutOverride) { replyTimeout = timeoutOverride; }
StandaloneRequestor extends StandaloneProducer { public void setReplyTimeout(TimeInterval timeoutOverride) { replyTimeout = timeoutOverride; } }
StandaloneRequestor extends StandaloneProducer { public void setReplyTimeout(TimeInterval timeoutOverride) { replyTimeout = timeoutOverride; } StandaloneRequestor();  StandaloneRequestor(AdaptrisMessageProducer p);  StandaloneRequestor(AdaptrisConnection c, AdaptrisMessageProducer p);  StandaloneRequestor(AdaptrisConnection c, AdaptrisMessageProducer p, TimeInterval timeout); }
StandaloneRequestor extends StandaloneProducer { public void setReplyTimeout(TimeInterval timeoutOverride) { replyTimeout = timeoutOverride; } 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); }
StandaloneRequestor extends StandaloneProducer { public void setReplyTimeout(TimeInterval timeoutOverride) { replyTimeout = timeoutOverride; } 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);  }