@Override @Test public void getQueueOutName() throws Exception { assertThat(tested.getQueueOutName(), is("AET.comparatorJobs")); }
@Override protected String getQueueOutName() { return QueuesConstant.COMPARATOR.getJobsQueueName(); }
CollectionResultsRouter extends StepManager implements TaskFinishPoint { @Override protected String getQueueOutName() { return QueuesConstant.COMPARATOR.getJobsQueueName(); } }
CollectionResultsRouter extends StepManager implements TaskFinishPoint { @Override protected String getQueueOutName() { return QueuesConstant.COMPARATOR.getJobsQueueName(); } CollectionResultsRouter(TimeoutWatch timeoutWatch, JmsConnection jmsConnection,
      RunnerConfiguration runnerConfiguration,
      CollectorJobSchedulerService collectorJobScheduler, RunIndexWrapper runIndexWrapper); }
CollectionResultsRouter extends StepManager implements TaskFinishPoint { @Override protected String getQueueOutName() { return QueuesConstant.COMPARATOR.getJobsQueueName(); } CollectionResultsRouter(TimeoutWatch timeoutWatch, JmsConnection jmsConnection,
      RunnerConfiguration runnerConfiguration,
      CollectorJobSchedulerService collectorJobScheduler, RunIndexWrapper runIndexWrapper); @Override void onMessage(Message message); void addChangeObserver(ChangeObserver observer); @Override boolean isFinished(); }
CollectionResultsRouter extends StepManager implements TaskFinishPoint { @Override protected String getQueueOutName() { return QueuesConstant.COMPARATOR.getJobsQueueName(); } CollectionResultsRouter(TimeoutWatch timeoutWatch, JmsConnection jmsConnection,
      RunnerConfiguration runnerConfiguration,
      CollectorJobSchedulerService collectorJobScheduler, RunIndexWrapper runIndexWrapper); @Override void onMessage(Message message); void addChangeObserver(ChangeObserver observer); @Override boolean isFinished();  }