RequestReplyWorkflow extends StandardWorkflow { public void setReplyTimeout(TimeInterval replyTimeout) { this.replyTimeout = replyTimeout; } RequestReplyWorkflow(); @Override void doProduce(AdaptrisMessage msg); @Override void registerChannel(Channel c); void setReplyServiceCollection(ServiceCollection services); ServiceCollection getReplyServiceCollection(); void setReplyProducer(AdaptrisMessageProducer producer); AdaptrisMessageProducer getReplyProducer(); TimeInterval getReplyTimeout(); void setReplyTimeout(TimeInterval replyTimeout); void setRetainUniqueId(Boolean b); Boolean getRetainUniqueId();  }
@Test public void testSetReplyTimeout() throws Exception { TimeInterval defaultInterval = new TimeInterval(30L, TimeUnit.SECONDS); TimeInterval interval = new TimeInterval(60L, TimeUnit.SECONDS); RequestReplyWorkflow workflow = new RequestReplyWorkflow(); assertNull(workflow.getReplyTimeout()); assertEquals(defaultInterval.toMilliseconds(), workflow.replyTimeout()); workflow.setReplyTimeout(interval); assertEquals(interval, workflow.getReplyTimeout()); assertEquals(interval.toMilliseconds(), workflow.replyTimeout()); workflow.setReplyTimeout(null); assertNull(workflow.getReplyTimeout()); assertEquals(defaultInterval.toMilliseconds(), workflow.replyTimeout()); }