protected void prepareBlockCleanup(final Exchange exchange){
  if (executor.isShutdown()) {
    LOGGER.info("Endpoint is being destroyed: skipping block clean-up");
    return;
  }
  BlockCleanupTask task=new BlockCleanupTask(exchange);
  ScheduledFuture<?> f=executor.schedule(task,block_timeout,TimeUnit.MILLISECONDS);
  exchange.setBlockCleanupHandle(f);
}

protected void prepareBlockCleanup ( final Exchange exchange ) { if ( executor . isShutdown ( ) ) { LOGGER . info ( "Endpoint is being destroyed: skipping block clean-up" ) ; return ; } BlockCleanupTask task = new BlockCleanupTask ( exchange ) ; ScheduledFuture < ? > f = executor . schedule ( task , block_timeout , TimeUnit . MILLISECONDS ) ; exchange . setBlockCleanupHandle ( f ) ; }
schedules a clean - up task . use the blockwise_status_lifetime config property to set the timeout .
