@Override public void transportInterupted() {
    checkResult = INTERRUPTION;
  }
JMS contract is one session per thread: we need a new session up to our concurrency level.
zipkin-collector/activemq/src/main/java/zipkin2/collector/activemq/ActiveMQSpanConsumer.java