default PulsarComponentBuilderFactory.PulsarComponentBuilder |
PulsarComponentBuilderFactory.PulsarComponentBuilder.ackGroupTimeMillis(long ackGroupTimeMillis) |
Group the consumer acknowledgments for the specified time in
milliseconds - defaults to 100.
|
default PulsarComponentBuilderFactory.PulsarComponentBuilder |
PulsarComponentBuilderFactory.PulsarComponentBuilder.ackTimeoutMillis(long ackTimeoutMillis) |
Timeout for unacknowledged messages in milliseconds - defaults to
10000.
|
default PulsarComponentBuilderFactory.PulsarComponentBuilder |
PulsarComponentBuilderFactory.PulsarComponentBuilder.allowManualAcknowledgement(boolean allowManualAcknowledgement) |
Whether to allow manual message acknowledgements.
|
default PulsarComponentBuilderFactory.PulsarComponentBuilder |
PulsarComponentBuilderFactory.PulsarComponentBuilder.autoConfiguration(org.apache.camel.component.pulsar.utils.AutoConfiguration autoConfiguration) |
The pulsar auto configuration.
|
default PulsarComponentBuilderFactory.PulsarComponentBuilder |
PulsarComponentBuilderFactory.PulsarComponentBuilder.autowiredEnabled(boolean autowiredEnabled) |
Whether autowiring is enabled.
|
default PulsarComponentBuilderFactory.PulsarComponentBuilder |
PulsarComponentBuilderFactory.PulsarComponentBuilder.batcherBuilder(org.apache.pulsar.client.api.BatcherBuilder batcherBuilder) |
Control batching method used by the producer.
|
default PulsarComponentBuilderFactory.PulsarComponentBuilder |
PulsarComponentBuilderFactory.PulsarComponentBuilder.batchingEnabled(boolean batchingEnabled) |
Control whether automatic batching of messages is enabled for the
producer.
|
default PulsarComponentBuilderFactory.PulsarComponentBuilder |
PulsarComponentBuilderFactory.PulsarComponentBuilder.batchingMaxMessages(int batchingMaxMessages) |
The maximum size to batch messages.
|
default PulsarComponentBuilderFactory.PulsarComponentBuilder |
PulsarComponentBuilderFactory.PulsarComponentBuilder.batchingMaxPublishDelayMicros(long batchingMaxPublishDelayMicros) |
The maximum time period within which the messages sent will be
batched if batchingEnabled is true.
|
default PulsarComponentBuilderFactory.PulsarComponentBuilder |
PulsarComponentBuilderFactory.PulsarComponentBuilder.blockIfQueueFull(boolean blockIfQueueFull) |
Whether to block the producing thread if pending messages queue is
full or to throw a ProducerQueueIsFullError.
|
default PulsarComponentBuilderFactory.PulsarComponentBuilder |
PulsarComponentBuilderFactory.PulsarComponentBuilder.bridgeErrorHandler(boolean bridgeErrorHandler) |
Allows for bridging the consumer to the Camel routing Error Handler,
which mean any exceptions occurred while the consumer is trying to
pickup incoming messages, or the likes, will now be processed as a
message and handled by the routing Error Handler.
|
default PulsarComponentBuilderFactory.PulsarComponentBuilder |
PulsarComponentBuilderFactory.PulsarComponentBuilder.compressionType(org.apache.pulsar.client.api.CompressionType compressionType) |
Compression type to use.
|
default PulsarComponentBuilderFactory.PulsarComponentBuilder |
PulsarComponentBuilderFactory.PulsarComponentBuilder.configuration(org.apache.camel.component.pulsar.PulsarConfiguration configuration) |
Allows to pre-configure the Pulsar component with common options that
the endpoints will reuse.
|
default PulsarComponentBuilderFactory.PulsarComponentBuilder |
PulsarComponentBuilderFactory.PulsarComponentBuilder.consumerName(String consumerName) |
Name of the consumer when subscription is EXCLUSIVE.
|
default PulsarComponentBuilderFactory.PulsarComponentBuilder |
PulsarComponentBuilderFactory.PulsarComponentBuilder.consumerNamePrefix(String consumerNamePrefix) |
Prefix to add to consumer names when a SHARED or FAILOVER
subscription is used.
|
default PulsarComponentBuilderFactory.PulsarComponentBuilder |
PulsarComponentBuilderFactory.PulsarComponentBuilder.consumerQueueSize(int consumerQueueSize) |
Size of the consumer queue - defaults to 10.
|
default PulsarComponentBuilderFactory.PulsarComponentBuilder |
PulsarComponentBuilderFactory.PulsarComponentBuilder.deadLetterTopic(String deadLetterTopic) |
Name of the topic where the messages which fail maxRedeliverCount
times will be sent.
|
default PulsarComponentBuilderFactory.PulsarComponentBuilder |
PulsarComponentBuilderFactory.PulsarComponentBuilder.initialSequenceId(long initialSequenceId) |
The first message published will have a sequence Id of
initialSequenceId 1.
|
default PulsarComponentBuilderFactory.PulsarComponentBuilder |
PulsarComponentBuilderFactory.PulsarComponentBuilder.lazyStartProducer(boolean lazyStartProducer) |
Whether the producer should be started lazy (on the first message).
|
default PulsarComponentBuilderFactory.PulsarComponentBuilder |
PulsarComponentBuilderFactory.PulsarComponentBuilder.maxPendingMessages(int maxPendingMessages) |
Size of the pending massages queue.
|
default PulsarComponentBuilderFactory.PulsarComponentBuilder |
PulsarComponentBuilderFactory.PulsarComponentBuilder.maxPendingMessagesAcrossPartitions(int maxPendingMessagesAcrossPartitions) |
The maximum number of pending messages for partitioned topics.
|
default PulsarComponentBuilderFactory.PulsarComponentBuilder |
PulsarComponentBuilderFactory.PulsarComponentBuilder.maxRedeliverCount(Integer maxRedeliverCount) |
Maximum number of times that a message will be redelivered before
being sent to the dead letter queue.
|
default PulsarComponentBuilderFactory.PulsarComponentBuilder |
PulsarComponentBuilderFactory.PulsarComponentBuilder.messageRouter(org.apache.pulsar.client.api.MessageRouter messageRouter) |
Custom Message Router to use.
|
default PulsarComponentBuilderFactory.PulsarComponentBuilder |
PulsarComponentBuilderFactory.PulsarComponentBuilder.messageRoutingMode(org.apache.pulsar.client.api.MessageRoutingMode messageRoutingMode) |
Message Routing Mode to use.
|
default PulsarComponentBuilderFactory.PulsarComponentBuilder |
PulsarComponentBuilderFactory.PulsarComponentBuilder.negativeAckRedeliveryDelayMicros(long negativeAckRedeliveryDelayMicros) |
Set the negative acknowledgement delay.
|
default PulsarComponentBuilderFactory.PulsarComponentBuilder |
PulsarComponentBuilderFactory.PulsarComponentBuilder.numberOfConsumers(int numberOfConsumers) |
Number of consumers - defaults to 1.
|
default PulsarComponentBuilderFactory.PulsarComponentBuilder |
PulsarComponentBuilderFactory.PulsarComponentBuilder.producerName(String producerName) |
Name of the producer.
|
static PulsarComponentBuilderFactory.PulsarComponentBuilder |
PulsarComponentBuilderFactory.pulsar() |
Pulsar (camel-pulsar)
Send and receive messages from/to Apache Pulsar messaging system.
|
default PulsarComponentBuilderFactory.PulsarComponentBuilder |
PulsarComponentBuilderFactory.PulsarComponentBuilder.pulsarClient(org.apache.pulsar.client.api.PulsarClient pulsarClient) |
The pulsar client.
|
default PulsarComponentBuilderFactory.PulsarComponentBuilder |
PulsarComponentBuilderFactory.PulsarComponentBuilder.pulsarMessageReceiptFactory(org.apache.camel.component.pulsar.PulsarMessageReceiptFactory pulsarMessageReceiptFactory) |
Provide a factory to create an alternate implementation of
PulsarMessageReceipt.
|
default PulsarComponentBuilderFactory.PulsarComponentBuilder |
PulsarComponentBuilderFactory.PulsarComponentBuilder.readCompacted(boolean readCompacted) |
Enable compacted topic reading.
|
default PulsarComponentBuilderFactory.PulsarComponentBuilder |
PulsarComponentBuilderFactory.PulsarComponentBuilder.sendTimeoutMs(int sendTimeoutMs) |
Send timeout in milliseconds.
|
default PulsarComponentBuilderFactory.PulsarComponentBuilder |
PulsarComponentBuilderFactory.PulsarComponentBuilder.subscriptionInitialPosition(org.apache.camel.component.pulsar.utils.consumers.SubscriptionInitialPosition subscriptionInitialPosition) |
Control the initial position in the topic of a newly created
subscription.
|
default PulsarComponentBuilderFactory.PulsarComponentBuilder |
PulsarComponentBuilderFactory.PulsarComponentBuilder.subscriptionName(String subscriptionName) |
Name of the subscription to use.
|
default PulsarComponentBuilderFactory.PulsarComponentBuilder |
PulsarComponentBuilderFactory.PulsarComponentBuilder.subscriptionTopicsMode(org.apache.pulsar.client.api.RegexSubscriptionMode subscriptionTopicsMode) |
Determines to which topics this consumer should be subscribed to -
Persistent, Non-Persistent, or both.
|
default PulsarComponentBuilderFactory.PulsarComponentBuilder |
PulsarComponentBuilderFactory.PulsarComponentBuilder.subscriptionType(org.apache.camel.component.pulsar.utils.consumers.SubscriptionType subscriptionType) |
Type of the subscription EXCLUSIVESHAREDFAILOVERKEY_SHARED, defaults
to EXCLUSIVE.
|
default PulsarComponentBuilderFactory.PulsarComponentBuilder |
PulsarComponentBuilderFactory.PulsarComponentBuilder.topicsPattern(boolean topicsPattern) |
Whether the topic is a pattern (regular expression) that allows the
consumer to subscribe to all matching topics in the namespace.
|