- SEQUENCE_ID - Static variable in interface org.apache.camel.component.pulsar.utils.message.PulsarMessageHeaders
-
- serialize(Object) - Static method in class org.apache.camel.component.pulsar.utils.message.PulsarMessageUtils
-
- setAckGroupTimeMillis(long) - Method in class org.apache.camel.component.pulsar.configuration.PulsarConfiguration
-
Group the consumer acknowledgments for the specified time in milliseconds - defaults to 100
- setAckTimeoutMillis(long) - Method in class org.apache.camel.component.pulsar.configuration.PulsarConfiguration
-
Timeout for unacknowledged messages in milliseconds - defaults to 10000
- setAllowManualAcknowledgement(boolean) - Method in class org.apache.camel.component.pulsar.configuration.PulsarConfiguration
-
Whether to allow manual message acknowledgements.
- setAllowManualAcknowledgement(boolean) - Method in class org.apache.camel.component.pulsar.PulsarComponent
-
Whether to allow manual message acknowledgements.
- setAutoConfiguration(AutoConfiguration) - Method in class org.apache.camel.component.pulsar.PulsarComponent
-
The pulsar autoconfiguration
- setBatchingEnabled(boolean) - Method in class org.apache.camel.component.pulsar.configuration.PulsarConfiguration
-
Control whether automatic batching of messages is enabled for the producer.
- setBatchingMaxMessages(int) - Method in class org.apache.camel.component.pulsar.configuration.PulsarConfiguration
-
Set the maximum number of messages permitted in a batch.
- setBatchingMaxPublishDelayMicros(long) - Method in class org.apache.camel.component.pulsar.configuration.PulsarConfiguration
-
Set the time period within which the messages sent will be batched if batch messages are
enabled.
- setBlockIfQueueFull(boolean) - Method in class org.apache.camel.component.pulsar.configuration.PulsarConfiguration
-
Set whether the send and asyncSend operations should block when the outgoing message queue is full.
- setCompressionType(String) - Method in class org.apache.camel.component.pulsar.configuration.PulsarConfiguration
-
Set the compression type for the producer.
- setConsumerName(String) - Method in class org.apache.camel.component.pulsar.configuration.PulsarConfiguration
-
Name of the consumer when subscription is EXCLUSIVE
- setConsumerNamePrefix(String) - Method in class org.apache.camel.component.pulsar.configuration.PulsarConfiguration
-
Prefix to add to consumer names when a SHARED or FAILOVER subscription is
used
- setConsumerQueueSize(int) - Method in class org.apache.camel.component.pulsar.configuration.PulsarConfiguration
-
Size of the consumer queue - defaults to 10
- setInitialSequenceId(long) - Method in class org.apache.camel.component.pulsar.configuration.PulsarConfiguration
-
Set the baseline for the sequence ids for messages published by the producer.
- setMaxPendingMessages(int) - Method in class org.apache.camel.component.pulsar.configuration.PulsarConfiguration
-
Set the max size of the queue holding the messages pending to receive an acknowledgment from the broker.
- setMaxPendingMessagesAcrossPartitions(int) - Method in class org.apache.camel.component.pulsar.configuration.PulsarConfiguration
-
Set the number of max pending messages across all the partitions.
- setNumberOfConsumers(int) - Method in class org.apache.camel.component.pulsar.configuration.PulsarConfiguration
-
Number of consumers - defaults to 1
- setProducerName(String) - Method in class org.apache.camel.component.pulsar.configuration.PulsarConfiguration
-
Name of the producer, if unset lets Pulsar select a unique identifier
- setPulsarClient(PulsarClient) - Method in class org.apache.camel.component.pulsar.PulsarComponent
-
The pulsar client
- setPulsarMessageReceiptFactory(PulsarMessageReceiptFactory) - Method in class org.apache.camel.component.pulsar.PulsarComponent
-
- setSendTimeoutMs(int) - Method in class org.apache.camel.component.pulsar.configuration.PulsarConfiguration
-
Send timeout in milliseconds.
- setSubscriptionName(String) - Method in class org.apache.camel.component.pulsar.configuration.PulsarConfiguration
-
Name of the subscription to use
- setSubscriptionType(SubscriptionType) - Method in class org.apache.camel.component.pulsar.configuration.PulsarConfiguration
-
Type of the subscription [EXCLUSIVE|SHARED|FAILOVER], defaults to
EXCLUSIVE
- SharedConsumerStrategy - Class in org.apache.camel.component.pulsar.utils.consumers
-
- stopConsumers(Queue<Consumer<byte[]>>) - Static method in class org.apache.camel.component.pulsar.utils.PulsarUtils
-
- SubscriptionType - Enum in org.apache.camel.component.pulsar.utils.consumers
-