### Question:
DelayedMessageScheduler extends MessageScheduler { @Override protected long getNextScheduleTime(String queueName, Long value) { long currentTime = System.currentTimeMillis(); if (value == null) { return currentTime + rqueueSchedulerConfig.getDelayedMessageTimeInterval(); } if (value < currentTime) { return currentTime; } return currentTime + rqueueSchedulerConfig.getDelayedMessageTimeInterval(); }    }### Answer:
@Test public void getNextScheduleTime() { long currentTime = System.currentTimeMillis(); doReturn(5000L).when(rqueueSchedulerConfig).getDelayedMessageTimeInterval(); assertThat( messageScheduler.getNextScheduleTime(slowQueue, null), greaterThanOrEqualTo(currentTime + 5000L)); assertThat( messageScheduler.getNextScheduleTime(fastQueue, currentTime + 1000L), greaterThanOrEqualTo(currentTime + 5000L)); }