{
private final ConsumerTaskExecutor infoChannelConsumerTaskExecutor;
private final ConsumerTaskExecutor dataChannelConsumerTaskExecutor;
+ private final InfoChannel infoChannel;
public void executeConsumerTasks()
{
dataChannelConsumerTaskExecutor.executeConsumerTask();
}
- public void joinConsumerTasks()
+ public void joinConsumerTasks() throws InterruptedException
{
dataChannelConsumerTaskExecutor.joinConsumerTaskJob();
+ while (infoChannel.isLoadInProgress())
+ {
+ log.info("Waiting for {} to finish loading...", infoChannel);
+ Thread.sleep(1000);
+ }
infoChannelConsumerTaskExecutor.joinConsumerTaskJob();
}
}