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

Class PulsarDevServicesProcessor

java.lang.Object

io.quarkus.smallrye.reactivemessaging.pulsar.deployment.PulsarDevServicesProcessor

public class PulsarDevServicesProcessor
extends Object

Starts a Pulsar broker as dev service if needed. It uses https://hub.docker.com/r/apachepulsar/pulsar as image.

Field Summary

Fields

Modifier and Type	Field	Description
(package private) static io.quarkus.smallrye.reactivemessaging.pulsar.deployment.PulsarDevServicesProcessor.PulsarDevServiceCfg	cfg
(package private) static final String	DEV_SERVICE_PULSAR
(package private) static io.quarkus.deployment.builditem.DevServicesResultBuildItem.RunningDevService	devService
(package private) static boolean	first

Constructor Summary

Constructors

Constructor	Description
PulsarDevServicesProcessor()

Method Summary

Modifier and Type	Method	Description
io.quarkus.deployment.builditem.DevServicesResultBuildItem	startPulsarDevService(io.quarkus.deployment.builditem.DockerStatusBuildItem dockerStatusBuildItem, io.quarkus.deployment.builditem.DevServicesComposeProjectBuildItem composeProjectBuildItem, io.quarkus.deployment.builditem.LaunchModeBuildItem launchMode, PulsarBuildTimeConfig pulsarClientBuildTimeConfig, List<io.quarkus.deployment.builditem.DevServicesSharedNetworkBuildItem> devServicesSharedNetworkBuildItem, Optional<io.quarkus.deployment.console.ConsoleInstalledBuildItem> consoleInstalledBuildItem, io.quarkus.deployment.builditem.CuratedApplicationShutdownBuildItem closeBuildItem, io.quarkus.deployment.logging.LoggingSetupBuildItem loggingSetupBuildItem, io.quarkus.deployment.dev.devservices.DevServicesConfig devServicesConfig)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

DEV_SERVICE_PULSAR

static final String DEV_SERVICE_PULSAR

See Also:

• Constant Field Values

devService

static volatile io.quarkus.deployment.builditem.DevServicesResultBuildItem.RunningDevService devService

cfg

static volatile io.quarkus.smallrye.reactivemessaging.pulsar.deployment.PulsarDevServicesProcessor.PulsarDevServiceCfg cfg

first

static volatile boolean first

Constructor Details

PulsarDevServicesProcessor

public PulsarDevServicesProcessor()

Method Details

startPulsarDevService

public io.quarkus.deployment.builditem.DevServicesResultBuildItem startPulsarDevService(io.quarkus.deployment.builditem.DockerStatusBuildItem dockerStatusBuildItem,
 io.quarkus.deployment.builditem.DevServicesComposeProjectBuildItem composeProjectBuildItem,
 io.quarkus.deployment.builditem.LaunchModeBuildItem launchMode,
 PulsarBuildTimeConfig pulsarClientBuildTimeConfig,
 List<io.quarkus.deployment.builditem.DevServicesSharedNetworkBuildItem> devServicesSharedNetworkBuildItem,
 Optional<io.quarkus.deployment.console.ConsoleInstalledBuildItem> consoleInstalledBuildItem,
 io.quarkus.deployment.builditem.CuratedApplicationShutdownBuildItem closeBuildItem,
 io.quarkus.deployment.logging.LoggingSetupBuildItem loggingSetupBuildItem,
 io.quarkus.deployment.dev.devservices.DevServicesConfig devServicesConfig)