This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel.git
commit 3978e75b453c5c9eb5c0f2366d0759f9279647eb Author: Sherman Richard <sherm...@thehutgroup.com> AuthorDate: Tue Aug 13 15:25:19 2019 +0100 Fix checkstyle issues --- .../org/apache/camel/component/pulsar/PulsarProducer.java | 4 ++-- .../component/pulsar/configuration/PulsarConfiguration.java | 12 +++++++----- 2 files changed, 9 insertions(+), 7 deletions(-) diff --git a/components/camel-pulsar/src/main/java/org/apache/camel/component/pulsar/PulsarProducer.java b/components/camel-pulsar/src/main/java/org/apache/camel/component/pulsar/PulsarProducer.java index 140f0c7..2b4eaf3 100644 --- a/components/camel-pulsar/src/main/java/org/apache/camel/component/pulsar/PulsarProducer.java +++ b/components/camel-pulsar/src/main/java/org/apache/camel/component/pulsar/PulsarProducer.java @@ -16,6 +16,8 @@ */ package org.apache.camel.component.pulsar; +import java.util.concurrent.TimeUnit; + import org.apache.camel.Exchange; import org.apache.camel.Message; import org.apache.camel.NoTypeConversionAvailableException; @@ -26,8 +28,6 @@ import org.apache.camel.support.DefaultProducer; import org.apache.pulsar.client.api.Producer; import org.apache.pulsar.client.api.ProducerBuilder; -import java.util.concurrent.TimeUnit; - public class PulsarProducer extends DefaultProducer { private final PulsarEndpoint pulsarEndpoint; diff --git a/components/camel-pulsar/src/main/java/org/apache/camel/component/pulsar/configuration/PulsarConfiguration.java b/components/camel-pulsar/src/main/java/org/apache/camel/component/pulsar/configuration/PulsarConfiguration.java index b2099d3..388460c 100644 --- a/components/camel-pulsar/src/main/java/org/apache/camel/component/pulsar/configuration/PulsarConfiguration.java +++ b/components/camel-pulsar/src/main/java/org/apache/camel/component/pulsar/configuration/PulsarConfiguration.java @@ -16,13 +16,13 @@ */ package org.apache.camel.component.pulsar.configuration; +import java.util.concurrent.TimeUnit; + import org.apache.camel.component.pulsar.utils.consumers.SubscriptionType; import org.apache.camel.spi.UriParam; import org.apache.camel.spi.UriParams; import org.apache.pulsar.client.api.CompressionType; -import java.util.concurrent.TimeUnit; - import static org.apache.camel.component.pulsar.utils.consumers.SubscriptionType.EXCLUSIVE; @UriParams @@ -51,10 +51,12 @@ public class PulsarConfiguration { @UriParam(label = "producer", description = "Send timeout in milliseconds", defaultValue = "30000") private int sendTimeoutMs = 30000; @UriParam(label = "producer", description = "Whether to block the producing thread if pending messages queue is full or to throw a ProducerQueueIsFullError", defaultValue = "false") - private boolean blockIfQueueFull = false; - @UriParam(label = "producer", description = "Size of the pending massages queue. When the queue is full, by default, any further sends will fail unless blockIfQueueFull=true", defaultValue = "1000") + private boolean blockIfQueueFull; + @UriParam(label = "producer", description = "Size of the pending massages queue. When the queue is full, by default, any further sends will fail unless blockIfQueueFull=true", + defaultValue = "1000") private int maxPendingMessages = 1000; - @UriParam(label = "producer", description = "The maximum number of pending messages for partitioned topics. The maxPendingMessages value will be reduced if (number of partitions * maxPendingMessages) exceeds this value. Partitioned topics have a pending message queue for each partition.", defaultValue = "50000") + @UriParam(label = "producer", description = "The maximum number of pending messages for partitioned topics. The maxPendingMessages value will be reduced if " + + "(number of partitions * maxPendingMessages) exceeds this value. Partitioned topics have a pending message queue for each partition.", defaultValue = "50000") private int maxPendingMessagesAcrossPartitions = 50000; @UriParam(label = "producer", description = "The maximum time period within which the messages sent will be batched if batchingEnabled is true.", defaultValue = "1000") private long batchingMaxPublishDelayMicros = TimeUnit.MILLISECONDS.toMicros(1);