KaneAI - World’s First E2E Software Testing Agent.Signup for Private Beta Join TestMu Conference

How to use disableExtension method of org.testcontainers.hivemq.HiveMQContainer class

Best Testcontainers-java code snippet using org.testcontainers.hivemq.HiveMQContainer.disableExtension

Source:HiveMQContainer.java

...373     * @param extensionDirectory the name of the extension's directory374     * @param timeout            the timeout375     * @throws TimeoutException if the extension was not disabled within the configured timeout376     */377    public void disableExtension(378        final @NotNull String extensionName,379        final @NotNull String extensionDirectory,380        final @NotNull Duration timeout381    ) throws TimeoutException {382        final String regEX = "(.*)Extension \"" + extensionName + "\" version (.*) stopped successfully(.*)";383        try {384            final String containerPath =385                "/opt/hivemq/extensions" + PathUtil.prepareInnerPath(extensionDirectory) + "DISABLED";386            final CountDownLatch latch = new CountDownLatch(1);387            containerOutputLatches.put(regEX, latch);388            execInContainer("touch", containerPath);389            LOGGER.info("Putting DISABLED file into container path '{}'", containerPath);390            final boolean await = latch.await(timeout.getSeconds(), TimeUnit.SECONDS);391            if (!await) {392                throw new TimeoutException(393                    "Extension disabling timed out after '" +394                    timeout.getSeconds() +395                    "' seconds. " +396                    "Maybe you are using a HiveMQ Community Edition image, " +397                    "which does not support disabling of extensions"398                );399            }400        } catch (final InterruptedException | IOException e) {401            throw new RuntimeException(e);402        } finally {403            containerOutputLatches.remove(regEX);404        }405    }406    /**407     * Disables the extension with the given name and extension directory name.408     * This method blocks until the HiveMQ log for successful disabling is consumed or it times out after 60 seconds.409     * Note: Disabling Extensions is a HiveMQ Enterprise feature, it will not work when using the HiveMQ Community Edition.410     * <p>411     * This can only be called once the container is started.412     *413     * @param extensionName      the name of the extension to disable414     * @param extensionDirectory the name of the extension's directory415     * @throws TimeoutException if the extension was not disabled within 60 seconds416     */417    public void disableExtension(final @NotNull String extensionName, final @NotNull String extensionDirectory)418        throws TimeoutException {419        disableExtension(extensionName, extensionDirectory, Duration.ofSeconds(60));420    }421    /**422     * Disables the extension.423     * This method blocks until the HiveMQ log for successful disabling is consumed or it times out after {timeOut}.424     * Note: Disabling Extensions is a HiveMQ Enterprise feature, it will not work when using the HiveMQ Community Edition.425     * <p>426     * This can only be called once the container is started.427     *428     * @param hiveMQExtension the extension429     * @param timeout         the timeout430     * @throws TimeoutException if the extension was not disabled within the configured timeout431     */432    public void disableExtension(final @NotNull HiveMQExtension hiveMQExtension, final @NotNull Duration timeout)433        throws TimeoutException {434        disableExtension(hiveMQExtension.getName(), hiveMQExtension.getId(), timeout);435    }436    /**437     * Disables the extension.438     * This method blocks until the HiveMQ log for successful disabling is consumed or it times out after 60 seconds.439     * Note: Disabling Extensions is a HiveMQ Enterprise feature, it will not work when using the HiveMQ Community Edition.440     * <p>441     * This can only be called once the container is started.442     *443     * @param hiveMQExtension the extension444     * @throws TimeoutException if the extension was not disabled within 60 seconds445     */446    public void disableExtension(final @NotNull HiveMQExtension hiveMQExtension) throws TimeoutException {447        disableExtension(hiveMQExtension, Duration.ofSeconds(60));448    }449    /**450     * Enables the extension with the given name and extension directory name.451     * This method blocks until the HiveMQ log for successful enabling is consumed or it times out after {timeOut}.452     * Note: Enabling Extensions is a HiveMQ Enterprise feature, it will not work when using the HiveMQ Community Edition.453     * <p>454     * This can only be called once the container is started.455     *456     * @param extensionName      the name of the extension to disable457     * @param extensionDirectory the name of the extension's directory458     * @param timeout            the timeout459     * @throws TimeoutException if the extension was not enabled within the configured timeout460     */461    public void enableExtension(...

Source:DemoDisableExtensionsIT.java

...46    // hiveRuntimeEnable {47    @Test48    void test_disable_enable_extension() throws Exception {49        hivemq.enableExtension(hiveMQExtension);50        hivemq.disableExtension(hiveMQExtension);51    }52    // }53    // runtimeEnableFilesystem {54    @Test55    void test_disable_enable_extension_from_filesystem() throws Exception {56        hivemqExtensionFromFilesystem.disableExtension("Modifier Extension", "modifier-extension");57        hivemqExtensionFromFilesystem.enableExtension("Modifier Extension", "modifier-extension");58    }59    // }60}...

Source:DisableEnableExtensionFromDirectoryIT.java

...19                .withLogLevel(Level.DEBUG)20        ) {21            hivemq.start();22            TestPublishModifiedUtil.testPublishModified(hivemq.getMqttPort(), hivemq.getHost());23            hivemq.disableExtension("Modifier Extension", "modifier-extension");24            assertThatExceptionOfType(ExecutionException.class)25                .isThrownBy(() -> TestPublishModifiedUtil.testPublishModified(hivemq.getMqttPort(), hivemq.getHost()));26            hivemq.enableExtension("Modifier Extension", "modifier-extension");27            TestPublishModifiedUtil.testPublishModified(hivemq.getMqttPort(), hivemq.getHost());28        }29    }30}

disableExtension

Using AI Code Generation

1package org.testcontainers.hivemq;2import org.testcontainers.containers.GenericContainer;3import org.testcontainers.containers.Network;4import org.testcontainers.containers.output.Slf4jLogConsumer;5import org.testcontainers.hivemq.HiveMQContainer;6import org.testcontainers.utility.DockerImageName;7public class HiveMQContainerTest {8    public static void main(String[] args) {9        Network network = Network.newNetwork();10        HiveMQContainer hiveMQContainer = new HiveMQContainer(DockerImageName.parse("hivemq/hivemq4").withTag("latest"))11                .withNetwork(network)12                .withNetworkAliases("hivemq")13                .withExposedPorts(1883)14                .withLogConsumer(new Slf4jLogConsumer(HiveMQContainerTest.class));15        hiveMQContainer.start();16        GenericContainer<?> mosquittoContainer = new GenericContainer<>(DockerImageName.parse("eclipse-mosquitto").withTag("latest"))17                .withNetwork(network)18                .withNetworkAliases("mosquitto")19                .withExposedPorts(1883)20                .withLogConsumer(new Slf4jLogConsumer(HiveMQContainerTest.class));21        mosquittoContainer.start();22        hiveMQContainer.disableExtension("hivemq-mqtt-web-client-extension");23        hiveMQContainer.enableExtension("hivemq-mqtt-web-client-extension");24        hiveMQContainer.stop();25        mosquittoContainer.stop();26    }27}

disableExtension

Using AI Code Generation

1package org.testcontainers.hivemq;2import org.junit.Test;3import org.junit.runner.RunWith;4import org.testcontainers.containers.BindMode;5import org.testcontainers.containers.output.Slf4jLogConsumer;6import org.testcontainers.containers.wait.strategy.Wait;7import org.testcontainers.junit.jupiter.Container;8import org.testcontainers.junit.jupiter.Testcontainers;9import org.testcontainers.utility.MountableFile;10import java.io.File;11import java.io.IOException;12import java.nio.file.Files;13import java.util.stream.Stream;14import static org.junit.Assert.assertFalse;15import static org.junit.Assert.assertTrue;16@RunWith(org.junit.runners.Parameterized.class)17public class HiveMQContainerTest {18    private HiveMQContainer hiveMQContainer = new HiveMQContainer("hivemq/hivemq4:4.5.1")19            .withCopyFileToContainer(MountableFile.forClasspathResource("extension.zip"), "/opt/hivemq/extensions")20            .withCopyFileToContainer(MountableFile.forClasspathResource("extension.zip"), "/opt/hivemq/extensions2")21            .withExposedPorts(1883)22            .waitingFor(Wait.forLogMessage(".*Started HiveMQ.*\\n", 1))23            .withLogConsumer(new Slf4jLogConsumer(org.slf4j.LoggerFactory.getLogger(HiveMQContainerTest.class)));24    public HiveMQContainerTest(String extension) {25        hiveMQContainer.disableExtension(extension);26    }27    public static Object[] data() {28        return new Object[]{"extension", "extension2"};29    }30    public void testExtensionDisabled() throws IOException {31        Stream<String> extensionFiles = Files.list(new File(hiveMQContainer.getExtensionsFolder()).toPath())32                .map(p -> p.getFileName().toString());33        assertFalse(extensionFiles.anyMatch(f -> f.equals("extension")));34        assertFalse(extensionFiles.anyMatch(f -> f.equals("extension2")));35    }36}37package org.testcontainers.hivemq;38import org.junit.Test;39import org.junit.runner.RunWith;40import org.testcontainers.containers.BindMode;41import org.testcontainers.containers.output.Slf4jLogConsumer;42import org.testcontainers.containers.wait.strategy.Wait;43import org.testcontainers.junit.jupiter.Container;44import org.testcontainers

disableExtension

Using AI Code Generation

1package org.testcontainers.hivemq;2import org.testcontainers.containers.GenericContainer;3public class HiveMQContainer extends GenericContainer<HiveMQContainer> {4    private static final String IMAGE_VERSION = "hivemq/hivemq4";5    private static final int MQTT_PORT = 1883;6    public HiveMQContainer() {7        this(IMAGE_VERSION);8    }9    public HiveMQContainer(final String dockerImageName) {10        super(dockerImageName);11        withExposedPorts(MQTT_PORT);12    }13    protected Integer getLivenessCheckPort() {14        return getMappedPort(MQTT_PORT);15    }16}17package org.testcontainers.hivemq;18import org.junit.Test;19import org.testcontainers.containers.ContainerLaunchException;20import org.testcontainers.containers.GenericContainer;21import org.testcontainers.containers.output.Slf4jLogConsumer;22public class HiveMQContainerTest {23    @Test(expected = ContainerLaunchException.class)24    public void testFailToStartContainer() {25        try (HiveMQContainer container = new HiveMQContainer()) {26                    .withLogConsumer(new Slf4jLogConsumer(org.slf4j.LoggerFactory.getLogger("test")))27                    .withEnv("HIVEMQ_ALLOW_ANONYMOUS", "false")28                    .withEnv("HIVEMQ_AUTHENTICATION_USERNAME", "admin")29                    .withEnv("HIVEMQ_AUTHENTICATION_PASSWORD", "admin")30                    .withEnv("HIVEMQ_AUTHORIZATION_ALLOW_ANONYMOUS", "false")31                    .withEnv("HIVEMQ_AUTHORIZATION_ALLOW_NO_SUBSCRIPTION", "false")32                    .withEnv("HIVEMQ_AUTHORIZATION_ALLOW_NO_PUBLISH", "false")33                    .withEnv("HIVEMQ_AUTHORIZATION_ALLOW_WILDCARD_SUBSCRIPTIONS", "false")34                    .withEnv("HIVEMQ_AUTHORIZATION_ALLOW_SHARED_SUBSCRIPTIONS", "false")35                    .withEnv("HIVEMQ_AUTHORIZATION_ALLOW_SUBSCRIPTION_OVERRIDE", "false")36                    .withEnv("HIVEMQ_AUTHORIZATION_ALLOW_SUBSCRIPTION_DELETE", "false")37                    .withEnv("HIVEMQ_AUTHORIZATION_ALLOW_SUBSCRIPTION_DELETE_OVERRIDE", "false")38                    .withEnv("HIVEMQ_AUTHORIZATION_ALLOW_PUBLISH_OVERRIDE", "false")39                    .withEnv("HIVEMQ_AUTHORIZATION_ALLOW_PUBLISH_DELETE",

disableExtension

Using AI Code Generation

1package org.testcontainers.hivemq;2import org.junit.Test;3import org.testcontainers.containers.Network;4import org.testcontainers.hivemq.HiveMQContainer;5public class TestHiveMQContainer {6    public void testHiveMQContainer() {7        Network network = Network.newNetwork();8        HiveMQContainer hivemq = new HiveMQContainer("hivemq/hivemq4:4.0.2")9                .withNetwork(network)10                .withNetworkAliases("hivemq")11                .withExposedPorts(1883)12                .withEnv("HIVEMQ_ALLOW_ANONYMOUS", "true");13        hivemq.disableExtension("hivemq-bridge-extension");14        hivemq.start();15    }16}17at org.testcontainers.containers.GenericContainer.doStart(GenericContainer.java:320)18at org.testcontainers.containers.GenericContainer.start(GenericContainer.java:302)19at org.testcontainers.hivemq.TestHiveMQContainer.testHiveMQContainer(TestHiveMQContainer.java:22)20at org.rnorth.ducttape.unreliables.Unreliables.retryUntilSuccess(Unreliables.java:81)21at org.testcontainers.containers.GenericContainer.tryStart(GenericContainer.java:506)22at org.testcontainers.containers.GenericContainer.lambda$doStart$0(GenericContainer.java:317)23at org.rnorth.ducttape.unreliables.Unreliables.retryUntilSuccess(Unreliables.java:76)24at org.testcontainers.containers.GenericContainer.tryStart(GenericContainer.java:449)25at org.testcontainers.containers.GenericContainer.tryStart(GenericContainer.java:423)

disableExtension

Using AI Code Generation

1import org.testcontainers.containers.GenericContainer;2import org.testcontainers.hivemq.HiveMQContainer;3import org.testcontainers.utility.DockerImageName;4public class TestHiveMQContainer {5    public static void main(String[] args) {6        HiveMQContainer hivemq = new HiveMQContainer(DockerImageName.parse("hivemq/hivemq4"));7        hivemq.disableExtension("hivemq-mqtt-client");8        hivemq.start();9    }10}11HiveMQContainer hivemq = new HiveMQContainer(DockerImageName.parse("hivemq/hivemq4"));12hivemq.disableExtension("");13hivemq.start();

disableExtension

Using AI Code Generation

1import org.testcontainers.containers.HiveMQContainer;2import org.testcontainers.utility.DockerImageName;3public class HiveMQContainerTest {4    public static void main(String[] args) {5        HiveMQContainer container = new HiveMQContainer(DockerImageName.parse("hivemq/hivemq4"));6        container.disableExtension("hivemq-enterprise-extension");7    }8}9	at org.testcontainers.hivemq.HiveMQContainer.disableExtension(HiveMQContainer.java:212)10	at HiveMQContainerTest.main(HiveMQContainerTest.java:9)

disableExtension

Using AI Code Generation

1package org.testcontainers.hivemq;2import org.junit.Test;3import org.testcontainers.containers.GenericContainer;4import org.testcontainers.containers.Network;5import java.util.Collections;6import static org.junit.Assert.assertTrue;7public class HiveMQContainerTest {8    public void testDisableExtension() {9        Network network = Network.newNetwork();10        GenericContainer<?> hiveMQContainer = new HiveMQContainer()11                .withNetwork(network)12                .withNetworkAliases("hivemq")13                .withExtension("hivemq/hivemq-bridge-extension", "1.0.0")14                .withExtension("hivemq/hivemq-cluster-formation-extension", "1.0.0")15                .withExtension("hivemq/hivemq-mqtt-websocket-extension", "1.0.0")16                .withExtension("hivemq/hivemq-swarm-extension", "1.0.0")17                .withExtension("hivemq/hivemq-wildcard-subscription-extension", "1.0.0")18                .withExtension("hivemq/hivemq-mqtt-client-websocket-extension", "1.0.0")19                .withExtension("hivemq/hivemq-mqtt-websocket-extension", "1.0.0")20                .withExtension("hivemq/hivemq-mqtt-client-websocket-extension", "1.0.0")21                .withExtension("hivemq/hivemq-swarm-extension", "1.0.0")22                .withExtension("hivemq/hivemq-mqtt-websocket-extension", "1.0.0")23                .withExtension("hivemq/hivemq-mqtt-client-websocket-extension", "1.0.0")24                .withExtension("hivemq/hivemq-swarm-extension", "1.0.0")25                .withExtension("hivemq/hivemq-mqtt-websocket-extension", "1.0.0")26                .withExtension("hivemq/hivemq-mqtt-client-websocket-extension", "1.0.0")27                .withExtension("hivemq/hivemq-swarm-extension", "1.0.0")28                .withExtension("hivemq/hivemq-m

disableExtension

Using AI Code Generation

1package org.testcontainers.hivemq;2import org.junit.Test;3import org.testcontainers.containers.GenericContainer;4import org.testcontainers.utility.DockerImageName;5public class ExampleTest {6    public void testExample() {7        try (GenericContainer<?> container = new HiveMQContainer(8                DockerImageName.parse("hivemq/hivemq4").withTag("latest"))) {9            container.start();10        }11    }12}13package org.testcontainers.hivemq;14import org.junit.Test;15import org.testcontainers.containers.GenericContainer;16import org.testcontainers.utility.DockerImageName;17public class ExampleTest {18    public void testExample() {19        try (GenericContainer<?> container = new HiveMQContainer(20                DockerImageName.parse("hivemq/hivemq4").withTag("latest"))) {21            container.disableExtensions("extension1", "extension2");22            container.start();23        }24    }25}26package org.testcontainers.hivemq;27import org.junit.Test;28import org.testcontainers.containers.GenericContainer;29import org.testcontainers.utility.DockerImageName;30import java.util.List;31public class ExampleTest {32    public void testExample() {33        try (GenericContainer<?> container = new HiveMQContainer(34                DockerImageName.parse("hivemq/hivemq4").withTag("latest"))) {35            container.disableExtensions(List.of("extension1", "extension2"));36            container.start();37        }38    }39}

disableExtension

Using AI Code Generation

1import org.testcontainers.hivemq.HiveMQContainer;2import org.testcontainers.utility.MountableFile;3import org.junit.Test;4import org.junit.Before;5import org.junit.After;6import static org.junit.Assert.*;7import java.util.List;8import java.util.ArrayList;9public class ExampleTest {10    private HiveMQContainer hivemq;11    public void before() {12        hivemq = new HiveMQContainer();13    }14    public void after() {15        hivemq.stop();16    }17     * Method: disableExtension(String extensionId)18    public void testDisableExtension() throws Exception {19        String extensionId = "extensionId";20        hivemq.disableExtension(extensionId);21    }22}23import org.testcontainers.hivemq.HiveMQContainer;24import org.testcontainers.utility.MountableFile;25import org.junit.Test;26import org.junit.Before;27import org.junit.After;28import static org.junit.Assert.*;29import java.util.List;30import java.util.ArrayList;31public class ExampleTest {32    private HiveMQContainer hivemq;33    public void before() {34        hivemq = new HiveMQContainer();35    }36    public void after() {37        hivemq.stop();38    }39     * Method: disableExtension(String extensionId)40    public void testDisableExtension() throws Exception {41        String extensionId = "extensionId";42        hivemq.disableExtension(extensionId);43    }44}45import org.testcontainers.hivemq.HiveMQContainer;46import org.testcontainers.utility.MountableFile;47import org.junit.Test;48import org.junit.Before;49import org.junit.After;50import static org.junit.Assert.*;51import java.util.List;52import java.util.ArrayList;53public class ExampleTest {54    private HiveMQContainer hivemq;55    public void before() {56        hivemq = new HiveMQContainer();57    }58    public void after() {

disableExtension

Using AI Code Generation

1package org.testcontainers.hivemq;2import org.junit.Test;3import org.testcontainers.containers.GenericContainer;4import java.util.List;5public class HiveMQContainerTest {6    public void testHiveMQContainer() {7        try (HiveMQContainer hivemqContainer = new HiveMQContainer("hivemq/hivemq4")) {8            hivemqContainer.start();9        }10    }11    public void testHiveMQContainerWithExtension() {12        try (HiveMQContainer hivemqContainer = new HiveMQContainer("hivemq/hivemq4")13                .withExtension("hivemq/hivemq-swarm-extension", "4.4.4")) {14            hivemqContainer.start();15        }16    }17    public void testHiveMQContainerWithExtensionAndDisabledExtension() {18        try (HiveMQContainer hivemqContainer = new HiveMQContainer("hivemq/hivemq4")19                .withExtension("hivemq/hivemq-swarm-extension", "4.4.4")20                .disableExtension("hivemq/hivemq-swarm-extension", "4.4.4")) {21            hivemqContainer.start();22        }23    }24}25package org.testcontainers.hivemq;26import org.junit.Test;27import org.testcontainers.containers.GenericContainer;28import java.util.List;29public class HiveMQContainerTest {30    public void testHiveMQContainer() {31        try (HiveMQContainer hivemqContainer = new HiveMQContainer("hivemq/hivemq4")) {32            hivemqContainer.start();33        }34    }35    public void testHiveMQContainerWithExtension() {36        try (HiveMQContainer hivemqContainer = new HiveMQContainer("hivemq/hivemq4")37                .withExtension("hivemq/hivemq-swarm-extension", "4.4.4")) {38            hivemqContainer.start();39        }40    }

Automation Testing Tutorials

Learn to execute automation testing from scratch with LambdaTest Learning Hub. Right from setting up the prerequisites to run your first automation test, to following best practices and diving deeper into advanced test scenarios. LambdaTest Learning Hubs compile a list of step-by-step guides to help you be proficient with different test automation frameworks i.e. Selenium, Cypress, TestNG etc.