diff --git a/src/main/java/com/mongodb/socialite/cli/BenchmarkCommand.java b/src/main/java/com/mongodb/socialite/cli/BenchmarkCommand.java index 8d403dc..78d276f 100644 --- a/src/main/java/com/mongodb/socialite/cli/BenchmarkCommand.java +++ b/src/main/java/com/mongodb/socialite/cli/BenchmarkCommand.java @@ -210,17 +210,24 @@ protected void run(Bootstrap configBootstrap, reporter.start(1,TimeUnit.SECONDS); final List> futures = new ArrayList>(namespace.getInt("concurrency")); - for( int i = 0; i < concurrency; i++ ){ + for( int i = 0; i < concurrency; i++ ) { final Runnable worker = new Runnable() { public void run() { - try{ - model.next(userResource, timers); - } - catch(Exception e){ - logger.error(e.toString()); - e.printStackTrace(); - logger.debug("", e); - } + try { + model.next(userResource, timers); + } + catch(com.mongodb.MongoInterruptedException mie) { + if(logger.isDebugEnabled()) { + logger.debug("", mie); + } + } + catch(Exception e) { + logger.error(e.toString()); + e.printStackTrace(); + if(logger.isDebugEnabled()) { + logger.debug("", e); + } + } } };