default PulsarEndpointBuilderFactory.PulsarEndpointConsumerBuilder |
PulsarEndpointBuilderFactory.PulsarEndpointConsumerBuilder.ackGroupTimeMillis(long ackGroupTimeMillis) |
Group the consumer acknowledgments for the specified time in
milliseconds - defaults to 100.
|
default PulsarEndpointBuilderFactory.PulsarEndpointConsumerBuilder |
PulsarEndpointBuilderFactory.PulsarEndpointConsumerBuilder.ackGroupTimeMillis(String ackGroupTimeMillis) |
Group the consumer acknowledgments for the specified time in
milliseconds - defaults to 100.
|
default PulsarEndpointBuilderFactory.PulsarEndpointConsumerBuilder |
PulsarEndpointBuilderFactory.PulsarEndpointConsumerBuilder.ackTimeoutMillis(long ackTimeoutMillis) |
Timeout for unacknowledged messages in milliseconds - defaults to
10000.
|
default PulsarEndpointBuilderFactory.PulsarEndpointConsumerBuilder |
PulsarEndpointBuilderFactory.PulsarEndpointConsumerBuilder.ackTimeoutMillis(String ackTimeoutMillis) |
Timeout for unacknowledged messages in milliseconds - defaults to
10000.
|
default PulsarEndpointBuilderFactory.PulsarEndpointConsumerBuilder |
PulsarEndpointBuilderFactory.PulsarEndpointConsumerBuilder.allowManualAcknowledgement(boolean allowManualAcknowledgement) |
Whether to allow manual message acknowledgements.
|
default PulsarEndpointBuilderFactory.PulsarEndpointConsumerBuilder |
PulsarEndpointBuilderFactory.PulsarEndpointConsumerBuilder.allowManualAcknowledgement(String allowManualAcknowledgement) |
Whether to allow manual message acknowledgements.
|
default PulsarEndpointBuilderFactory.PulsarEndpointConsumerBuilder |
PulsarEndpointBuilderFactory.AdvancedPulsarEndpointConsumerBuilder.basic() |
|
default PulsarEndpointBuilderFactory.PulsarEndpointConsumerBuilder |
PulsarEndpointBuilderFactory.PulsarEndpointConsumerBuilder.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 PulsarEndpointBuilderFactory.PulsarEndpointConsumerBuilder |
PulsarEndpointBuilderFactory.PulsarEndpointConsumerBuilder.bridgeErrorHandler(String 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 PulsarEndpointBuilderFactory.PulsarEndpointConsumerBuilder |
PulsarEndpointBuilderFactory.PulsarEndpointConsumerBuilder.consumerName(String consumerName) |
Name of the consumer when subscription is EXCLUSIVE.
|
default PulsarEndpointBuilderFactory.PulsarEndpointConsumerBuilder |
PulsarEndpointBuilderFactory.PulsarEndpointConsumerBuilder.consumerNamePrefix(String consumerNamePrefix) |
Prefix to add to consumer names when a SHARED or FAILOVER
subscription is used.
|
default PulsarEndpointBuilderFactory.PulsarEndpointConsumerBuilder |
PulsarEndpointBuilderFactory.PulsarEndpointConsumerBuilder.consumerQueueSize(int consumerQueueSize) |
Size of the consumer queue - defaults to 10.
|
default PulsarEndpointBuilderFactory.PulsarEndpointConsumerBuilder |
PulsarEndpointBuilderFactory.PulsarEndpointConsumerBuilder.consumerQueueSize(String consumerQueueSize) |
Size of the consumer queue - defaults to 10.
|
default PulsarEndpointBuilderFactory.PulsarEndpointConsumerBuilder |
PulsarEndpointBuilderFactory.PulsarEndpointConsumerBuilder.deadLetterTopic(String deadLetterTopic) |
Name of the topic where the messages which fail maxRedeliverCount
times will be sent.
|
default PulsarEndpointBuilderFactory.PulsarEndpointConsumerBuilder |
PulsarEndpointBuilderFactory.PulsarEndpointConsumerBuilder.maxRedeliverCount(Integer maxRedeliverCount) |
Maximum number of times that a message will be redelivered before
being sent to the dead letter queue.
|
default PulsarEndpointBuilderFactory.PulsarEndpointConsumerBuilder |
PulsarEndpointBuilderFactory.PulsarEndpointConsumerBuilder.maxRedeliverCount(String maxRedeliverCount) |
Maximum number of times that a message will be redelivered before
being sent to the dead letter queue.
|
default PulsarEndpointBuilderFactory.PulsarEndpointConsumerBuilder |
PulsarEndpointBuilderFactory.PulsarEndpointConsumerBuilder.negativeAckRedeliveryDelayMicros(long negativeAckRedeliveryDelayMicros) |
Set the negative acknowledgement delay.
|
default PulsarEndpointBuilderFactory.PulsarEndpointConsumerBuilder |
PulsarEndpointBuilderFactory.PulsarEndpointConsumerBuilder.negativeAckRedeliveryDelayMicros(String negativeAckRedeliveryDelayMicros) |
Set the negative acknowledgement delay.
|
default PulsarEndpointBuilderFactory.PulsarEndpointConsumerBuilder |
PulsarEndpointBuilderFactory.PulsarEndpointConsumerBuilder.numberOfConsumers(int numberOfConsumers) |
Number of consumers - defaults to 1.
|
default PulsarEndpointBuilderFactory.PulsarEndpointConsumerBuilder |
PulsarEndpointBuilderFactory.PulsarEndpointConsumerBuilder.numberOfConsumers(String numberOfConsumers) |
Number of consumers - defaults to 1.
|
default PulsarEndpointBuilderFactory.PulsarEndpointConsumerBuilder |
PulsarEndpointBuilderFactory.PulsarEndpointConsumerBuilder.readCompacted(boolean readCompacted) |
Enable compacted topic reading.
|
default PulsarEndpointBuilderFactory.PulsarEndpointConsumerBuilder |
PulsarEndpointBuilderFactory.PulsarEndpointConsumerBuilder.readCompacted(String readCompacted) |
Enable compacted topic reading.
|
default PulsarEndpointBuilderFactory.PulsarEndpointConsumerBuilder |
PulsarEndpointBuilderFactory.PulsarEndpointConsumerBuilder.subscriptionInitialPosition(String subscriptionInitialPosition) |
Control the initial position in the topic of a newly created
subscription.
|
default PulsarEndpointBuilderFactory.PulsarEndpointConsumerBuilder |
PulsarEndpointBuilderFactory.PulsarEndpointConsumerBuilder.subscriptionInitialPosition(PulsarEndpointBuilderFactory.SubscriptionInitialPosition subscriptionInitialPosition) |
Control the initial position in the topic of a newly created
subscription.
|
default PulsarEndpointBuilderFactory.PulsarEndpointConsumerBuilder |
PulsarEndpointBuilderFactory.PulsarEndpointConsumerBuilder.subscriptionName(String subscriptionName) |
Name of the subscription to use.
|
default PulsarEndpointBuilderFactory.PulsarEndpointConsumerBuilder |
PulsarEndpointBuilderFactory.PulsarEndpointConsumerBuilder.subscriptionTopicsMode(String subscriptionTopicsMode) |
Determines to which topics this consumer should be subscribed to -
Persistent, Non-Persistent, or both.
|
default PulsarEndpointBuilderFactory.PulsarEndpointConsumerBuilder |
PulsarEndpointBuilderFactory.PulsarEndpointConsumerBuilder.subscriptionTopicsMode(PulsarEndpointBuilderFactory.RegexSubscriptionMode subscriptionTopicsMode) |
Determines to which topics this consumer should be subscribed to -
Persistent, Non-Persistent, or both.
|
default PulsarEndpointBuilderFactory.PulsarEndpointConsumerBuilder |
PulsarEndpointBuilderFactory.PulsarEndpointConsumerBuilder.subscriptionType(String subscriptionType) |
Type of the subscription EXCLUSIVESHAREDFAILOVERKEY_SHARED, defaults
to EXCLUSIVE.
|
default PulsarEndpointBuilderFactory.PulsarEndpointConsumerBuilder |
PulsarEndpointBuilderFactory.PulsarEndpointConsumerBuilder.subscriptionType(PulsarEndpointBuilderFactory.SubscriptionType subscriptionType) |
Type of the subscription EXCLUSIVESHAREDFAILOVERKEY_SHARED, defaults
to EXCLUSIVE.
|
default PulsarEndpointBuilderFactory.PulsarEndpointConsumerBuilder |
PulsarEndpointBuilderFactory.PulsarEndpointConsumerBuilder.topicsPattern(boolean topicsPattern) |
Whether the topic is a pattern (regular expression) that allows the
consumer to subscribe to all matching topics in the namespace.
|
default PulsarEndpointBuilderFactory.PulsarEndpointConsumerBuilder |
PulsarEndpointBuilderFactory.PulsarEndpointConsumerBuilder.topicsPattern(String topicsPattern) |
Whether the topic is a pattern (regular expression) that allows the
consumer to subscribe to all matching topics in the namespace.
|