public @NotNull HiveMQContainer waitForExtension(final @NotNull String extensionName) {
        final String regEX = "(.*)Extension \"" + extensionName + "\" version (.*) started successfully(.*)";
        waitStrategy.withStrategy(Wait.forLogMessage(regEX, 1));
        return self();
    }
&&";
            } else {
                removeCommand =
                    prepackagedExtensionsToRemove
                        .stream()
                        .map(extensionId -> "rm -rf /opt/hivemq/extensions/" + extensionId + "&&")
                        .collect(Collectors.joining());
            }
        } else {
            removeCommand = "";
        }
        setCommand(
            "-c",
            removeCommand +
            "cp -r '/opt/hivemq/temp-extensions/'* /opt/hivemq/extensions/ ; " +
            "chmod -R 777 /opt/hivemq/extensions ; " +
            "/opt/docker-entrypoint.sh /opt/hivemq/bin/run.sh"
        );
    }

    protected void containerIsStarted(final @NotNull InspectContainerResponse containerInfo) {
        if (controlCenterEnabled) {
            LOGGER.info(
                "The HiveMQ Control Center is reachable under: http://{}:{}",
                getHost(),
                getMappedPort(CONTROL_CENTER_PORT)
            );
        }
    }

    /**
Adds a wait condition for the extension with this name.
<p>
Must be called before the container is started.

@param extensionName the extension to wait for
@return self
modules/hivemq/src/main/java/org/testcontainers/hivemq/HiveMQContainer.java