Package | Description |
---|---|
org.apache.camel.component.pulsar | |
org.apache.camel.component.pulsar.utils.consumers |
Modifier and Type | Method and Description |
---|---|
static PulsarEndpoint |
PulsarEndpoint.create(String uri,
String path,
PulsarConfiguration pulsarConfiguration,
PulsarComponent component,
org.apache.pulsar.client.api.PulsarClient pulsarClient) |
Constructor and Description |
---|
PulsarConsumer(PulsarEndpoint pulsarEndpoint,
org.apache.camel.Processor processor) |
PulsarMessageListener(PulsarEndpoint endpoint,
org.apache.camel.spi.ExceptionHandler exceptionHandler,
org.apache.camel.Processor processor) |
PulsarProducer(PulsarEndpoint pulsarEndpoint) |
Modifier and Type | Method and Description |
---|---|
Collection<org.apache.pulsar.client.api.Consumer<byte[]>> |
SharedConsumerStrategy.create(PulsarEndpoint pulsarEndpoint) |
Collection<org.apache.pulsar.client.api.Consumer<byte[]>> |
FailoverConsumerStrategy.create(PulsarEndpoint pulsarEndpoint) |
Collection<org.apache.pulsar.client.api.Consumer<byte[]>> |
ExclusiveConsumerStrategy.create(PulsarEndpoint pulsarEndpoint) |
Collection<org.apache.pulsar.client.api.Consumer<byte[]>> |
ConsumerCreationStrategy.create(PulsarEndpoint pulsarEndpoint) |
static org.apache.pulsar.client.api.ConsumerBuilder<byte[]> |
CommonCreationStrategyImpl.create(String name,
PulsarEndpoint pulsarEndpoint,
PulsarConsumer pulsarConsumer) |
Apache Camel