@Override @Test public void getQueueInName() throws Exception { assertThat(tested.getQueueInName(), is("AET.collectorResults")); }
@Override protected String getQueueInName() { return QueuesConstant.COLLECTOR.getResultsQueueName(); }
CollectionResultsRouter extends StepManager implements TaskFinishPoint { @Override protected String getQueueInName() { return QueuesConstant.COLLECTOR.getResultsQueueName(); } }
CollectionResultsRouter extends StepManager implements TaskFinishPoint { @Override protected String getQueueInName() { return QueuesConstant.COLLECTOR.getResultsQueueName(); } CollectionResultsRouter(TimeoutWatch timeoutWatch, JmsConnection jmsConnection,
      RunnerConfiguration runnerConfiguration,
      CollectorJobSchedulerService collectorJobScheduler, RunIndexWrapper runIndexWrapper); }
CollectionResultsRouter extends StepManager implements TaskFinishPoint { @Override protected String getQueueInName() { return QueuesConstant.COLLECTOR.getResultsQueueName(); } 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 getQueueInName() { return QueuesConstant.COLLECTOR.getResultsQueueName(); } CollectionResultsRouter(TimeoutWatch timeoutWatch, JmsConnection jmsConnection,
      RunnerConfiguration runnerConfiguration,
      CollectorJobSchedulerService collectorJobScheduler, RunIndexWrapper runIndexWrapper); @Override void onMessage(Message message); void addChangeObserver(ChangeObserver observer); @Override boolean isFinished();  }