@Test
public void testSubscriptionRunner() {

  SessionManager sessionManager = mock(SessionManager.class);
  expiration.startExpiredSessionsTask(sessionManager);
  ArgumentCaptor<NotificationExpirationManagement.SubscriptionRunner> cleanupCapture = ArgumentCaptor.forClass(NotificationExpirationManagement.SubscriptionRunner.class);
  verify(sessionManager).submit((String)isNull(), cleanupCapture.capture());
  cleanupCapture.getValue().run();
  verify(redis).psubscribe(any(RedisFacade.RedisPubSub.class), anyString());
}