@Override
        public void consume(@NlsSafe String message) {
          context.processMessage(new ProgressMessage(message));
        }
@Override
        public void consume(@NlsSafe String message)