Package io.quarkus.smallrye.reactivemessaging.pulsar.deployment

Class PulsarContainer

java.lang.Object

org.testcontainers.containers.GenericContainer<PulsarContainer>

io.quarkus.smallrye.reactivemessaging.pulsar.deployment.PulsarContainer

All Implemented Interfaces:

AutoCloseable, org.testcontainers.containers.Container<PulsarContainer>, org.testcontainers.containers.ContainerState, org.testcontainers.containers.traits.LinkableContainer, org.testcontainers.containers.wait.strategy.WaitStrategyTarget, org.testcontainers.lifecycle.Startable

public class PulsarContainer
extends org.testcontainers.containers.GenericContainer<PulsarContainer>

Nested Class Summary

Nested classes/interfaces inherited from interface org.testcontainers.containers.Container

org.testcontainers.containers.Container.ExecResult

Field Summary

Fields

Modifier and Type	Field	Description
static final int	BROKER_HTTP_PORT
static final int	BROKER_PORT
static final org.testcontainers.utility.DockerImageName	PULSAR_IMAGE
static final String	STARTER_SCRIPT

Fields inherited from class org.testcontainers.containers.GenericContainer

CONTAINER_RUNNING_TIMEOUT_SEC, dependencies, dockerClient, INTERNAL_HOST_HOSTNAME, waitStrategy

Fields inherited from interface org.testcontainers.containers.ContainerState

STATE_HEALTHY

Constructor Summary

Constructors

Constructor	Description
PulsarContainer()
PulsarContainer(org.testcontainers.utility.DockerImageName imageName, String defaultNetworkId, boolean useSharedNetwork)

Method Summary

Modifier and Type	Method	Description
protected void	containerIsStarting(com.github.dockerjava.api.command.InspectContainerResponse containerInfo, boolean reused)
String	getHttpServiceUrl()
String	getPulsarBrokerUrl()
protected String	runStarterScript()
PulsarContainer	withPort(int fixedPort)

Methods inherited from class org.testcontainers.containers.GenericContainer

addEnv, addExposedPort, addExposedPorts, addFileSystemBind, addFixedExposedPort, addFixedExposedPort, addLink, canBeReused, configure, containerIsCreated, containerIsStarted, containerIsStarted, containerIsStarting, containerIsStopped, containerIsStopping, copyFileFromContainer, createVolumeDirectory, dependsOn, dependsOn, dependsOn, doStart, equals, getBinds, getCommandParts, getContainerId, getContainerInfo, getContainerName, getCopyToFileContainerPathMap, getCreateContainerCmdModifiers, getDependencies, getDockerClient, getDockerImageName, getEnv, getEnvMap, getExposedPorts, getExtraHosts, getImage, getIpAddress, getLabels, getLinkedContainers, getLivenessCheckPort, getLivenessCheckPortNumbers, getLivenessCheckPorts, getLogConsumers, getNetwork, getNetworkAliases, getNetworkMode, getPortBindings, getShmSize, getStartupAttempts, getStartupCheckStrategy, getTestHostIpAddress, getTmpFsMapping, getVolumesFroms, getWaitStrategy, getWorkingDirectory, hashCode, isHostAccessible, isPrivilegedMode, isShouldBeReused, logger, setBinds, setCommand, setCommand, setCommandParts, setContainerDef, setCopyToFileContainerPathMap, setDockerImageName, setEnv, setExposedPorts, setExtraHosts, setHostAccessible, setImage, setLabels, setLinkedContainers, setLogConsumers, setNetwork, setNetworkAliases, setNetworkMode, setPortBindings, setPrivilegedMode, setShmSize, setStartupAttempts, setStartupCheckStrategy, setTmpFsMapping, setVolumesFroms, setWaitStrategy, setWorkingDirectory, start, stop, toString, waitingFor, waitUntilContainerStarted, withAccessToHost, withClasspathResourceMapping, withClasspathResourceMapping, withCommand, withCommand, withCopyFileToContainer, withCopyToContainer, withCreateContainerCmdModifier, withEnv, withEnv, withExposedPorts, withExtraHost, withFileSystemBind, withImagePullPolicy, withLabel, withLabels, withLogConsumer, withMinimumRunningDuration, withNetwork, withNetworkAliases, withNetworkMode, withPrivilegedMode, withReuse, withSharedMemorySize, withStartupAttempts, withStartupCheckStrategy, withStartupTimeout, withTmpFs, withVolumesFrom, withWorkingDirectory

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.testcontainers.containers.Container

addFileSystemBind, followOutput, followOutput, self, withEnv, withFileSystemBind

Methods inherited from interface org.testcontainers.containers.ContainerState

copyFileFromContainer, copyFileToContainer, copyFileToContainer, execInContainer, execInContainer, execInContainer, execInContainer, execInContainerWithUser, execInContainerWithUser, getBoundPortNumbers, getContainerIpAddress, getCurrentContainerInfo, getFirstMappedPort, getHost, getLogs, getLogs, getMappedPort, isCreated, isHealthy, isRunning

Methods inherited from interface org.testcontainers.lifecycle.Startable

close

Field Details

PULSAR_IMAGE

public static final org.testcontainers.utility.DockerImageName PULSAR_IMAGE

STARTER_SCRIPT

public static final String STARTER_SCRIPT

See Also:

• Constant Field Values

BROKER_PORT

public static final int BROKER_PORT

See Also:

• Constant Field Values

BROKER_HTTP_PORT

public static final int BROKER_HTTP_PORT

See Also:

• Constant Field Values

Constructor Details

PulsarContainer

public PulsarContainer()

PulsarContainer

public PulsarContainer(org.testcontainers.utility.DockerImageName imageName,
 String defaultNetworkId,
 boolean useSharedNetwork)

Method Details

runStarterScript

protected String runStarterScript()

containerIsStarting

protected void containerIsStarting(com.github.dockerjava.api.command.InspectContainerResponse containerInfo,
 boolean reused)

Overrides:

containerIsStarting in class org.testcontainers.containers.GenericContainer<PulsarContainer>

withPort

public PulsarContainer withPort(int fixedPort)

getPulsarBrokerUrl

public String getPulsarBrokerUrl()

getHttpServiceUrl

public String getHttpServiceUrl()