@UriParams public class PulsarConfiguration extends Object
Constructor and Description |
---|
PulsarConfiguration() |
Modifier and Type | Method and Description |
---|---|
long |
getAckGroupTimeMillis() |
long |
getAckTimeoutMillis() |
int |
getBatchingMaxMessages() |
long |
getBatchingMaxPublishDelayMicros() |
org.apache.pulsar.client.api.CompressionType |
getCompressionType() |
String |
getConsumerName() |
String |
getConsumerNamePrefix() |
int |
getConsumerQueueSize() |
long |
getInitialSequenceId() |
int |
getMaxPendingMessages() |
int |
getMaxPendingMessagesAcrossPartitions() |
int |
getNumberOfConsumers() |
String |
getProducerName() |
int |
getSendTimeoutMs() |
String |
getSubscriptionName() |
SubscriptionType |
getSubscriptionType() |
boolean |
isAllowManualAcknowledgement() |
boolean |
isBatchingEnabled() |
boolean |
isBlockIfQueueFull() |
void |
setAckGroupTimeMillis(long ackGroupTimeMillis)
Group the consumer acknowledgments for the specified time in milliseconds - defaults to 100
|
void |
setAckTimeoutMillis(long ackTimeoutMillis)
Timeout for unacknowledged messages in milliseconds - defaults to 10000
|
void |
setAllowManualAcknowledgement(boolean allowManualAcknowledgement)
Whether to allow manual message acknowledgements.
|
void |
setBatchingEnabled(boolean batchingEnabled)
Control whether automatic batching of messages is enabled for the producer.
|
void |
setBatchingMaxMessages(int batchingMaxMessages)
Set the maximum number of messages permitted in a batch.
|
void |
setBatchingMaxPublishDelayMicros(long batchingMaxPublishDelayMicros)
Set the time period within which the messages sent will be batched if batch messages are
enabled.
|
void |
setBlockIfQueueFull(boolean blockIfQueueFull)
Set whether the send and asyncSend operations should block when the outgoing message queue is full.
|
void |
setCompressionType(String compressionType)
Set the compression type for the producer.
|
void |
setConsumerName(String consumerName)
Name of the consumer when subscription is EXCLUSIVE
|
void |
setConsumerNamePrefix(String consumerNamePrefix)
Prefix to add to consumer names when a SHARED or FAILOVER subscription is
used
|
void |
setConsumerQueueSize(int consumerQueueSize)
Size of the consumer queue - defaults to 10
|
void |
setInitialSequenceId(long initialSequenceId)
Set the baseline for the sequence ids for messages published by the producer.
|
void |
setMaxPendingMessages(int maxPendingMessages)
Set the max size of the queue holding the messages pending to receive an acknowledgment from the broker.
|
void |
setMaxPendingMessagesAcrossPartitions(int maxPendingMessagesAcrossPartitions)
Set the number of max pending messages across all the partitions.
|
void |
setNumberOfConsumers(int numberOfConsumers)
Number of consumers - defaults to 1
|
void |
setProducerName(String producerName)
Name of the producer, if unset lets Pulsar select a unique identifier
|
void |
setSendTimeoutMs(int sendTimeoutMs)
Send timeout in milliseconds.
|
void |
setSubscriptionName(String subscriptionName)
Name of the subscription to use
|
void |
setSubscriptionType(SubscriptionType subscriptionType)
Type of the subscription [EXCLUSIVE|SHARED|FAILOVER], defaults to
EXCLUSIVE
|
public String getSubscriptionName()
public void setSubscriptionName(String subscriptionName)
public SubscriptionType getSubscriptionType()
public void setSubscriptionType(SubscriptionType subscriptionType)
public int getNumberOfConsumers()
public void setNumberOfConsumers(int numberOfConsumers)
public int getConsumerQueueSize()
public void setConsumerQueueSize(int consumerQueueSize)
public String getConsumerName()
public void setConsumerName(String consumerName)
public String getProducerName()
public void setProducerName(String producerName)
public String getConsumerNamePrefix()
public void setConsumerNamePrefix(String consumerNamePrefix)
public boolean isAllowManualAcknowledgement()
public void setAllowManualAcknowledgement(boolean allowManualAcknowledgement)
PulsarMessageReceipt
is stored as a header on the Exchange
.
Messages can then be acknowledged using PulsarMessageReceipt
at any time before the ackTimeout occurs.public long getAckTimeoutMillis()
public void setAckTimeoutMillis(long ackTimeoutMillis)
public long getAckGroupTimeMillis()
public void setAckGroupTimeMillis(long ackGroupTimeMillis)
public void setSendTimeoutMs(int sendTimeoutMs)
public int getSendTimeoutMs()
public void setBlockIfQueueFull(boolean blockIfQueueFull)
public boolean isBlockIfQueueFull()
public void setMaxPendingMessages(int maxPendingMessages)
public int getMaxPendingMessages()
public void setMaxPendingMessagesAcrossPartitions(int maxPendingMessagesAcrossPartitions)
public int getMaxPendingMessagesAcrossPartitions()
public void setBatchingMaxPublishDelayMicros(long batchingMaxPublishDelayMicros)
public long getBatchingMaxPublishDelayMicros()
public void setBatchingMaxMessages(int batchingMaxMessages)
public int getBatchingMaxMessages()
public void setBatchingEnabled(boolean batchingEnabled)
public boolean isBatchingEnabled()
public void setInitialSequenceId(long initialSequenceId)
public long getInitialSequenceId()
public void setCompressionType(String compressionType)
public org.apache.pulsar.client.api.CompressionType getCompressionType()
Apache Camel