Skip navigation links
Camel :: Pulsar 2.23.2.fuse-7_10_1-00008-redhat-00001
A C D E F G I K M N O P R S T U V 

A

acknowledge() - Method in class org.apache.camel.component.pulsar.DefaultPulsarMessageReceipt
 
acknowledge() - Method in interface org.apache.camel.component.pulsar.PulsarMessageReceipt
Acknowledge receipt of this message synchronously.
acknowledgeAsync() - Method in class org.apache.camel.component.pulsar.DefaultPulsarMessageReceipt
 
acknowledgeAsync() - Method in interface org.apache.camel.component.pulsar.PulsarMessageReceipt
Acknowledge receipt of this message asynchronously.
acknowledgeCumulative() - Method in class org.apache.camel.component.pulsar.DefaultPulsarMessageReceipt
 
acknowledgeCumulative() - Method in interface org.apache.camel.component.pulsar.PulsarMessageReceipt
Acknowledge receipt of all of the messages in the stream up to and including this message synchronously.
acknowledgeCumulativeAsync() - Method in class org.apache.camel.component.pulsar.DefaultPulsarMessageReceipt
 
acknowledgeCumulativeAsync() - Method in interface org.apache.camel.component.pulsar.PulsarMessageReceipt
Acknowledge receipt of all of the messages in the stream up to and including this message asynchronously.
AutoConfiguration - Class in org.apache.camel.component.pulsar.utils
Automatically create Pulsar tenant and namespace if enabled
AutoConfiguration(PulsarAdmin, Set<String>) - Constructor for class org.apache.camel.component.pulsar.utils.AutoConfiguration
 

C

CommonCreationStrategyImpl - Class in org.apache.camel.component.pulsar.utils.consumers
 
ConsumerCreationStrategy - Interface in org.apache.camel.component.pulsar.utils.consumers
 
ConsumerCreationStrategyFactory - Class in org.apache.camel.component.pulsar.utils.consumers
 
create(String, String, PulsarConfiguration, PulsarComponent, PulsarClient) - Static method in class org.apache.camel.component.pulsar.PulsarEndpoint
 
create(String, PulsarEndpoint, PulsarConsumer) - Static method in class org.apache.camel.component.pulsar.utils.consumers.CommonCreationStrategyImpl
 
create(PulsarEndpoint) - Method in interface org.apache.camel.component.pulsar.utils.consumers.ConsumerCreationStrategy
 
create(PulsarConsumer) - Static method in class org.apache.camel.component.pulsar.utils.consumers.ConsumerCreationStrategyFactory
 
create(PulsarEndpoint) - Method in class org.apache.camel.component.pulsar.utils.consumers.ExclusiveConsumerStrategy
 
create(PulsarEndpoint) - Method in class org.apache.camel.component.pulsar.utils.consumers.FailoverConsumerStrategy
 
create(PulsarEndpoint) - Method in class org.apache.camel.component.pulsar.utils.consumers.SharedConsumerStrategy
 
createConsumer(Processor) - Method in class org.apache.camel.component.pulsar.PulsarEndpoint
 
createEndpoint(String, String, Map<String, Object>) - Method in class org.apache.camel.component.pulsar.PulsarComponent
 
createExchange() - Method in class org.apache.camel.component.pulsar.PulsarEndpoint
 
createProducer() - Method in class org.apache.camel.component.pulsar.PulsarEndpoint
 

D

DefaultPulsarMessageReceipt - Class in org.apache.camel.component.pulsar
 
DefaultPulsarMessageReceipt(Consumer, MessageId) - Constructor for class org.apache.camel.component.pulsar.DefaultPulsarMessageReceipt
 
DefaultPulsarMessageReceiptFactory - Class in org.apache.camel.component.pulsar
 
DefaultPulsarMessageReceiptFactory() - Constructor for class org.apache.camel.component.pulsar.DefaultPulsarMessageReceiptFactory
 
doResume() - Method in class org.apache.camel.component.pulsar.PulsarConsumer
 
doStart() - Method in class org.apache.camel.component.pulsar.PulsarConsumer
 
doStart() - Method in class org.apache.camel.component.pulsar.PulsarProducer
 
doStop() - Method in class org.apache.camel.component.pulsar.PulsarConsumer
 
doStop() - Method in class org.apache.camel.component.pulsar.PulsarProducer
 
doSuspend() - Method in class org.apache.camel.component.pulsar.PulsarConsumer
 

E

ensureNameSpaceAndTenant(String) - Method in class org.apache.camel.component.pulsar.utils.AutoConfiguration
 
EVENT_TIME - Static variable in interface org.apache.camel.component.pulsar.utils.message.PulsarMessageHeaders
 
EVENT_TIME_OUT - Static variable in interface org.apache.camel.component.pulsar.utils.message.PulsarMessageHeaders
 
ExclusiveConsumerStrategy - Class in org.apache.camel.component.pulsar.utils.consumers
 

F

FailoverConsumerStrategy - Class in org.apache.camel.component.pulsar.utils.consumers
 

G

getAckGroupTimeMillis() - Method in class org.apache.camel.component.pulsar.configuration.PulsarConfiguration
 
getAckTimeoutMillis() - Method in class org.apache.camel.component.pulsar.configuration.PulsarConfiguration
 
getAutoConfiguration() - Method in class org.apache.camel.component.pulsar.PulsarComponent
 
getBatchingMaxMessages() - Method in class org.apache.camel.component.pulsar.configuration.PulsarConfiguration
 
getBatchingMaxPublishDelayMicros() - Method in class org.apache.camel.component.pulsar.configuration.PulsarConfiguration
 
getComponent() - Method in class org.apache.camel.component.pulsar.PulsarEndpoint
 
getCompressionType() - Method in class org.apache.camel.component.pulsar.configuration.PulsarConfiguration
 
getConsumer() - Method in class org.apache.camel.component.pulsar.DefaultPulsarMessageReceipt
 
getConsumerName() - Method in class org.apache.camel.component.pulsar.configuration.PulsarConfiguration
 
getConsumerNamePrefix() - Method in class org.apache.camel.component.pulsar.configuration.PulsarConfiguration
 
getConsumerQueueSize() - Method in class org.apache.camel.component.pulsar.configuration.PulsarConfiguration
 
getInitialSequenceId() - Method in class org.apache.camel.component.pulsar.configuration.PulsarConfiguration
 
getMaxPendingMessages() - Method in class org.apache.camel.component.pulsar.configuration.PulsarConfiguration
 
getMaxPendingMessagesAcrossPartitions() - Method in class org.apache.camel.component.pulsar.configuration.PulsarConfiguration
 
getMessageId() - Method in class org.apache.camel.component.pulsar.DefaultPulsarMessageReceipt
 
getNamespace() - Method in class org.apache.camel.component.pulsar.utils.PulsarPath
 
getNumberOfConsumers() - Method in class org.apache.camel.component.pulsar.configuration.PulsarConfiguration
 
getProducerName() - Method in class org.apache.camel.component.pulsar.configuration.PulsarConfiguration
 
getPulsarClient() - Method in class org.apache.camel.component.pulsar.PulsarComponent
 
getPulsarClient() - Method in class org.apache.camel.component.pulsar.PulsarEndpoint
 
getPulsarConfiguration() - Method in class org.apache.camel.component.pulsar.PulsarEndpoint
 
getPulsarMessageReceiptFactory() - Method in class org.apache.camel.component.pulsar.PulsarComponent
 
getSendTimeoutMs() - Method in class org.apache.camel.component.pulsar.configuration.PulsarConfiguration
 
getStrategy(SubscriptionType) - Method in class org.apache.camel.component.pulsar.utils.consumers.ConsumerCreationStrategyFactory
 
getSubscriptionName() - Method in class org.apache.camel.component.pulsar.configuration.PulsarConfiguration
 
getSubscriptionType() - Method in class org.apache.camel.component.pulsar.configuration.PulsarConfiguration
 
getTenant() - Method in class org.apache.camel.component.pulsar.utils.PulsarPath
 
getTopicUri() - Method in class org.apache.camel.component.pulsar.PulsarEndpoint
 

I

isAllowManualAcknowledgement() - Method in class org.apache.camel.component.pulsar.configuration.PulsarConfiguration
 
isAllowManualAcknowledgement() - Method in class org.apache.camel.component.pulsar.PulsarComponent
 
isAutoConfigurable() - Method in class org.apache.camel.component.pulsar.utils.AutoConfiguration
 
isAutoConfigurable() - Method in class org.apache.camel.component.pulsar.utils.PulsarPath
 
isBatchingEnabled() - Method in class org.apache.camel.component.pulsar.configuration.PulsarConfiguration
 
isBlockIfQueueFull() - Method in class org.apache.camel.component.pulsar.configuration.PulsarConfiguration
 
isSingleton() - Method in class org.apache.camel.component.pulsar.PulsarEndpoint
 

K

KEY - Static variable in interface org.apache.camel.component.pulsar.utils.message.PulsarMessageHeaders
 
KEY_BYTES - Static variable in interface org.apache.camel.component.pulsar.utils.message.PulsarMessageHeaders
 
KEY_OUT - Static variable in interface org.apache.camel.component.pulsar.utils.message.PulsarMessageHeaders
 

M

MESSAGE_ID - Static variable in interface org.apache.camel.component.pulsar.utils.message.PulsarMessageHeaders
 
MESSAGE_RECEIPT - Static variable in interface org.apache.camel.component.pulsar.utils.message.PulsarMessageHeaders
 

N

negativeAcknowledge() - Method in class org.apache.camel.component.pulsar.DefaultPulsarMessageReceipt
 
negativeAcknowledge() - Method in interface org.apache.camel.component.pulsar.PulsarMessageReceipt
Acknowledge the failure to process this message.
newInstance(Exchange, Message, Consumer) - Method in class org.apache.camel.component.pulsar.DefaultPulsarMessageReceiptFactory
 
newInstance(Exchange, Message, Consumer) - Method in interface org.apache.camel.component.pulsar.PulsarMessageReceiptFactory
Creates a new instance of PulsarMessageReceipt.

O

org.apache.camel.component.pulsar - package org.apache.camel.component.pulsar
 
org.apache.camel.component.pulsar.configuration - package org.apache.camel.component.pulsar.configuration
 
org.apache.camel.component.pulsar.utils - package org.apache.camel.component.pulsar.utils
 
org.apache.camel.component.pulsar.utils.consumers - package org.apache.camel.component.pulsar.utils.consumers
 
org.apache.camel.component.pulsar.utils.message - package org.apache.camel.component.pulsar.utils.message
 

P

process(Exchange) - Method in class org.apache.camel.component.pulsar.PulsarProducer
 
PRODUCER_NAME - Static variable in interface org.apache.camel.component.pulsar.utils.message.PulsarMessageHeaders
 
PROPERTIES - Static variable in interface org.apache.camel.component.pulsar.utils.message.PulsarMessageHeaders
 
PROPERTIES_OUT - Static variable in interface org.apache.camel.component.pulsar.utils.message.PulsarMessageHeaders
 
PUBLISH_TIME - Static variable in interface org.apache.camel.component.pulsar.utils.message.PulsarMessageHeaders
 
PulsarComponent - Class in org.apache.camel.component.pulsar
 
PulsarComponent() - Constructor for class org.apache.camel.component.pulsar.PulsarComponent
 
PulsarComponent(CamelContext) - Constructor for class org.apache.camel.component.pulsar.PulsarComponent
 
PulsarConfiguration - Class in org.apache.camel.component.pulsar.configuration
 
PulsarConfiguration() - Constructor for class org.apache.camel.component.pulsar.configuration.PulsarConfiguration
 
PulsarConsumer - Class in org.apache.camel.component.pulsar
 
PulsarConsumer(PulsarEndpoint, Processor) - Constructor for class org.apache.camel.component.pulsar.PulsarConsumer
 
PulsarEndpoint - Class in org.apache.camel.component.pulsar
 
PulsarEndpoint(String, String, PulsarConfiguration, PulsarComponent, PulsarClient) - Constructor for class org.apache.camel.component.pulsar.PulsarEndpoint
 
PulsarMessageHeaders - Interface in org.apache.camel.component.pulsar.utils.message
 
PulsarMessageListener - Class in org.apache.camel.component.pulsar
 
PulsarMessageListener(PulsarEndpoint, ExceptionHandler, Processor) - Constructor for class org.apache.camel.component.pulsar.PulsarMessageListener
 
PulsarMessageReceipt - Interface in org.apache.camel.component.pulsar
Acknowledge the receipt of a message using the Pulsar consumer.
PulsarMessageReceiptFactory - Interface in org.apache.camel.component.pulsar
Factory to create a new PulsarMessageReceipt to store on the Exchange.
PulsarMessageUtils - Class in org.apache.camel.component.pulsar.utils.message
 
PulsarPath - Class in org.apache.camel.component.pulsar.utils
 
PulsarPath(String) - Constructor for class org.apache.camel.component.pulsar.utils.PulsarPath
 
PulsarProducer - Class in org.apache.camel.component.pulsar
 
PulsarProducer(PulsarEndpoint) - Constructor for class org.apache.camel.component.pulsar.PulsarProducer
 
PulsarUtils - Class in org.apache.camel.component.pulsar.utils
 

R

received(Consumer<byte[]>, Message<byte[]>) - Method in class org.apache.camel.component.pulsar.PulsarMessageListener
 

S

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
Provide a factory to create an alternate implementation of PulsarMessageReceipt.
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
 

T

TOPIC_NAME - Static variable in interface org.apache.camel.component.pulsar.utils.message.PulsarMessageHeaders
 

U

updateExchange(Message<byte[]>, Exchange) - Static method in class org.apache.camel.component.pulsar.utils.message.PulsarMessageUtils
 
updateExchangeWithException(Exception, Exchange) - Static method in class org.apache.camel.component.pulsar.utils.message.PulsarMessageUtils
 

V

valueOf(String) - Static method in enum org.apache.camel.component.pulsar.utils.consumers.SubscriptionType
Returns the enum constant of this type with the specified name.
values() - Static method in enum org.apache.camel.component.pulsar.utils.consumers.SubscriptionType
Returns an array containing the constants of this enum type, in the order they are declared.
A C D E F G I K M N O P R S T U V 
Skip navigation links
Camel :: Pulsar 2.23.2.fuse-7_10_1-00008-redhat-00001

Apache Camel