public synchronized void stop()

in core/src/main/java/org/apache/rocketmq/streams/core/running/WorkerThread.java [274:294]

• 17 lines of code
• 3 McCabe index (conditional complexity)

        public synchronized void stop() {
            if (this.stop) {
                return;
            }

            this.stop = true;

            try {
                this.unionConsumer.shutdown();

                this.stateStore.close();
                this.idleWindowScaner.close();

                this.producer.shutdown();
                this.mqAdmin.shutdown();
                logger.info("shutdown engine success, thread:{}, jobId:{}", WorkerThread.this.getName(), jobId);
            } catch (Throwable e) {
                logger.error("error when stop engin.", e);
                throw new RStreamsException(e);
            }
        }