public void startContainer()

in rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/support/RocketMQMessageListenerContainerRegistrar.java [110:121]

• 12 lines of code
• 4 McCabe index (conditional complexity)

    public void startContainer() {
        for (DefaultRocketMQListenerContainer container : containers) {
            if (!container.isRunning()) {
                try {
                    container.start();
                } catch (Exception e) {
                    log.error("Started container failed. {}", container, e);
                    throw new RuntimeException(e);
                }
            }
        }
    }