mirror of https://github.com/apache/activemq.git
NO-JIRA: Small test client fix to close threads out faster.
This commit is contained in:
parent
4516c8df3f
commit
a35d23dff7
|
@ -226,7 +226,13 @@ public class AmqpConnection extends AmqpAbstractResource<Connection> implements
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
serializer.shutdown();
|
serializer.shutdownNow();
|
||||||
|
try {
|
||||||
|
if (!serializer.awaitTermination(10, TimeUnit.SECONDS)) {
|
||||||
|
LOG.warn("Serializer didn't shutdown cleanly");
|
||||||
|
}
|
||||||
|
} catch (InterruptedException e) {
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue