@Override
    public void close() {
        try {
            this.messageConsumer.shutdown();
        }
        catch (final MetaClientException e) {
            log.error("Shutdown consumer failed", e);
        }
        try {
            this.sessionFactory.shutdown();
        }
        catch (final MetaClientException e) {
            log.error("Shutdown session factory failed", e);
        }

    }
Time in milliseconds to wait for a message from the queue if there is no
message ready when the topology requests a tuple (via
{@link #nextTuple()}).
metamorphosis-storm-spout/src/main/java/com/taobao/metamorphosis/storm/spout/MetaSpout.java