@Override @Test public void getQueueInName() throws Exception { assertThat(tested.getQueueInName(), is("AET.comparatorResults")); }
@Override protected String getQueueInName() { return QueuesConstant.COMPARATOR.getResultsQueueName(); }
ComparisonResultsRouter extends StepManager implements ChangeObserver,
    TaskFinishPoint { @Override protected String getQueueInName() { return QueuesConstant.COMPARATOR.getResultsQueueName(); } }
ComparisonResultsRouter extends StepManager implements ChangeObserver,
    TaskFinishPoint { @Override protected String getQueueInName() { return QueuesConstant.COMPARATOR.getResultsQueueName(); } ComparisonResultsRouter(TimeoutWatch timeoutWatch, JmsConnection jmsConnection,
      RunnerConfiguration runnerConfiguration, RunIndexWrapper runIndexWrapper); }
ComparisonResultsRouter extends StepManager implements ChangeObserver,
    TaskFinishPoint { @Override protected String getQueueInName() { return QueuesConstant.COMPARATOR.getResultsQueueName(); } ComparisonResultsRouter(TimeoutWatch timeoutWatch, JmsConnection jmsConnection,
      RunnerConfiguration runnerConfiguration, RunIndexWrapper runIndexWrapper); @Override void updateAmountToReceive(int additionalCount); @Override void informChangesCompleted(); @Override void onMessage(Message message); @Override boolean isFinished(); void abort(); }
ComparisonResultsRouter extends StepManager implements ChangeObserver,
    TaskFinishPoint { @Override protected String getQueueInName() { return QueuesConstant.COMPARATOR.getResultsQueueName(); } ComparisonResultsRouter(TimeoutWatch timeoutWatch, JmsConnection jmsConnection,
      RunnerConfiguration runnerConfiguration, RunIndexWrapper runIndexWrapper); @Override void updateAmountToReceive(int additionalCount); @Override void informChangesCompleted(); @Override void onMessage(Message message); @Override boolean isFinished(); void abort();  }