@Test public void testProducerFailsFirstTimeOnlyAsService() { StaticCounterFailFirstMockMessageProducer producer = new StaticCounterFailFirstMockMessageProducer(); producer.setFailUntilCount(0); producer.resetCount(); service.setProducer(producer); try { service.doService(AdaptrisMessageFactory.getDefaultInstance().newMessage()); } catch (Exception e) { fail(); } }
@Override public void doService(AdaptrisMessage msg) throws ServiceException { try { this.produce(msg); } catch (ProduceException e) { throw new ServiceException(e); } }
RetryOnceStandaloneProducer extends StandaloneProducer { @Override public void doService(AdaptrisMessage msg) throws ServiceException { try { this.produce(msg); } catch (ProduceException e) { throw new ServiceException(e); } } }
RetryOnceStandaloneProducer extends StandaloneProducer { @Override public void doService(AdaptrisMessage msg) throws ServiceException { try { this.produce(msg); } catch (ProduceException e) { throw new ServiceException(e); } } RetryOnceStandaloneProducer(); }
RetryOnceStandaloneProducer extends StandaloneProducer { @Override public void doService(AdaptrisMessage msg) throws ServiceException { try { this.produce(msg); } catch (ProduceException e) { throw new ServiceException(e); } } RetryOnceStandaloneProducer(); @Override void doService(AdaptrisMessage msg); @Override void produce(AdaptrisMessage msg); @Override void produce(AdaptrisMessage msg, ProduceDestination dest); TimeInterval getWaitBeforeRetry(); void setWaitBeforeRetry(TimeInterval waitBeforeRetry); }
RetryOnceStandaloneProducer extends StandaloneProducer { @Override public void doService(AdaptrisMessage msg) throws ServiceException { try { this.produce(msg); } catch (ProduceException e) { throw new ServiceException(e); } } RetryOnceStandaloneProducer(); @Override void doService(AdaptrisMessage msg); @Override void produce(AdaptrisMessage msg); @Override void produce(AdaptrisMessage msg, ProduceDestination dest); TimeInterval getWaitBeforeRetry(); void setWaitBeforeRetry(TimeInterval waitBeforeRetry);  }