@Test public void testSetStandaloneProducers() { MultiProducerWorkflow wf = new MultiProducerWorkflow(); wf.setStandaloneProducers(Arrays.asList(new StandaloneProducer[] { new StandaloneProducer() })); assertEquals(1, wf.getStandaloneProducers().size()); try { wf.setStandaloneProducers(null); fail(); } catch (IllegalArgumentException e) { } assertEquals(1, wf.getStandaloneProducers().size()); }
public void setStandaloneProducers(List<StandaloneProducer> l) { standaloneProducers = Args.notNull(l, "standaloneProducers"); }
MultiProducerWorkflow extends StandardWorkflow { public void setStandaloneProducers(List<StandaloneProducer> l) { standaloneProducers = Args.notNull(l, "standaloneProducers"); } }
MultiProducerWorkflow extends StandardWorkflow { public void setStandaloneProducers(List<StandaloneProducer> l) { standaloneProducers = Args.notNull(l, "standaloneProducers"); } MultiProducerWorkflow(); }
MultiProducerWorkflow extends StandardWorkflow { public void setStandaloneProducers(List<StandaloneProducer> l) { standaloneProducers = Args.notNull(l, "standaloneProducers"); } MultiProducerWorkflow(); @Override synchronized void onAdaptrisMessage(AdaptrisMessage msg, Consumer<AdaptrisMessage> success, Consumer<AdaptrisMessage> failure); void addStandaloneProducer(StandaloneProducer producer); List<StandaloneProducer> getStandaloneProducers(); void setStandaloneProducers(List<StandaloneProducer> l); void setUseProcessedMessage(Boolean useProc); Boolean getUseProcessedMessage(); }
MultiProducerWorkflow extends StandardWorkflow { public void setStandaloneProducers(List<StandaloneProducer> l) { standaloneProducers = Args.notNull(l, "standaloneProducers"); } MultiProducerWorkflow(); @Override synchronized void onAdaptrisMessage(AdaptrisMessage msg, Consumer<AdaptrisMessage> success, Consumer<AdaptrisMessage> failure); void addStandaloneProducer(StandaloneProducer producer); List<StandaloneProducer> getStandaloneProducers(); void setStandaloneProducers(List<StandaloneProducer> l); void setUseProcessedMessage(Boolean useProc); Boolean getUseProcessedMessage();  }