@Test public void testDoServiceNoTimeout() throws Exception { MockRequestReplyProducer m = new MockRequestReplyProducer(); StandaloneRequestor service = new StandaloneRequestor(m); service.setReplyTimeout(null); AdaptrisMessage msg = AdaptrisMessageFactory.getDefaultInstance().newMessage("XYZ"); execute(service, msg); assertTrue(msg.containsKey(MockRequestReplyProducer.REPLY_METADATA_KEY)); assertEquals(MockRequestReplyProducer.REPLY_METADATA_VALUE, msg.getMetadataValue(MockRequestReplyProducer.REPLY_METADATA_KEY)); assertEquals(1, m.getProducedMessages().size()); }
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);  }