@Test public void testWorkflow_HasInterceptor() throws Exception { Channel channel = createChannel(); RequestReplyWorkflow workflow = (RequestReplyWorkflow) channel.getWorkflowList().get(0); MockMessageProducer replier = (MockMessageProducer) workflow.getReplyProducer(); MockRequestReplyProducer requestor = (MockRequestReplyProducer) workflow.getProducer(); createChannel(); MockWorkflowInterceptor interceptor = new MockWorkflowInterceptor(); workflow.addInterceptor(interceptor); try { start(channel); submitMessages(workflow, 1); doDefaultAssertions(requestor, replier); AdaptrisMessage replyMsg = replier.getMessages().get(0); assertTrue("Request Metadata", replyMsg.headersContainsKey(REQUEST_METADATA_KEY)); assertEquals(1, interceptor.messageCount()); } finally { stop(channel); } }
public AdaptrisMessageProducer getReplyProducer() { return replyProducer; }
RequestReplyWorkflow extends StandardWorkflow { public AdaptrisMessageProducer getReplyProducer() { return replyProducer; } }
RequestReplyWorkflow extends StandardWorkflow { public AdaptrisMessageProducer getReplyProducer() { return replyProducer; } RequestReplyWorkflow(); }
RequestReplyWorkflow extends StandardWorkflow { public AdaptrisMessageProducer getReplyProducer() { return replyProducer; } 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(); }
RequestReplyWorkflow extends StandardWorkflow { public AdaptrisMessageProducer getReplyProducer() { return replyProducer; } 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();  }