This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel.git
commit 6edab8f88511c8e53f4ee00aa1d65aeee7f69426 Author: Kévin Lacire <[email protected]> AuthorDate: Fri Apr 15 09:37:39 2022 +0200 :art: fixing checkstyle errors --- .../component/azure/eventhubs/EventHubsConstants.java | 16 ++++------------ 1 file changed, 4 insertions(+), 12 deletions(-) diff --git a/components/camel-azure/camel-azure-eventhubs/src/main/java/org/apache/camel/component/azure/eventhubs/EventHubsConstants.java b/components/camel-azure/camel-azure-eventhubs/src/main/java/org/apache/camel/component/azure/eventhubs/EventHubsConstants.java index f1f07ea567a..3cad12dbc79 100644 --- a/components/camel-azure/camel-azure-eventhubs/src/main/java/org/apache/camel/component/azure/eventhubs/EventHubsConstants.java +++ b/components/camel-azure/camel-azure-eventhubs/src/main/java/org/apache/camel/component/azure/eventhubs/EventHubsConstants.java @@ -20,7 +20,10 @@ import org.apache.camel.Exchange; import org.apache.camel.spi.Metadata; public final class EventHubsConstants { - private static final String HEADER_PREFIX = "CamelAzureEventHubs"; + public static final String HEADER_PREFIX = "CamelAzureEventHubs"; + public static final String COMPLETED_BY_SIZE = "size"; + public static final String COMPLETED_BY_TIMEOUT = "timeout"; + public static final String UNCOMPLETED = "uncompleted"; // common headers, set by consumer and evaluated by producer @Metadata(description = "(producer) Overrides the hashing key to be provided for the batch of events, which instructs the Event Hubs service to map this key to a specific partition.\n" + @@ -60,17 +63,6 @@ public final class EventHubsConstants { javaType = "String") public static final String CHECKPOINT_UPDATED_BY = HEADER_PREFIX + "CheckpointUpdatedBy"; - @Metadata(label = "consumer", - description = "Completion condition header's value for the checkpoint to be updated when batch size is reached", - javaType = "String") - public static final String COMPLETED_BY_SIZE = "size"; - - @Metadata(label = "consumer", - description = "Completion condition header's value for the checkpoint to be updated when batch timeout is reached", - javaType = "String") - public static final String COMPLETED_BY_TIMEOUT = "timeout"; - public static final String UNCOMPLETED = "uncompleted"; - private EventHubsConstants() { } }
