From ba1bb157918aab78acd70d5f28203dd563bebb74 Mon Sep 17 00:00:00 2001 From: zhihaoguo Date: Thu, 12 Nov 2020 13:28:11 +0800 Subject: [PATCH] add clientOptions for EventHubClientBuilder --- .../eventhub/factory/DefaultEventHubClientFactory.java | 3 +++ 1 file changed, 3 insertions(+) diff --git a/sdk/spring/azure-spring-integration-eventhubs/src/main/java/com/azure/spring/integration/eventhub/factory/DefaultEventHubClientFactory.java b/sdk/spring/azure-spring-integration-eventhubs/src/main/java/com/azure/spring/integration/eventhub/factory/DefaultEventHubClientFactory.java index 99fe364db0aeb..9da55f6a58d63 100644 --- a/sdk/spring/azure-spring-integration-eventhubs/src/main/java/com/azure/spring/integration/eventhub/factory/DefaultEventHubClientFactory.java +++ b/sdk/spring/azure-spring-integration-eventhubs/src/main/java/com/azure/spring/integration/eventhub/factory/DefaultEventHubClientFactory.java @@ -4,6 +4,7 @@ package com.azure.spring.integration.eventhub.factory; import com.azure.core.http.policy.HttpLogOptions; +import com.azure.core.util.ClientOptions; import com.azure.messaging.eventhubs.EventProcessorClientBuilder; import com.azure.messaging.eventhubs.EventHubClientBuilder; import com.azure.messaging.eventhubs.EventHubProducerAsyncClient; @@ -70,12 +71,14 @@ private EventHubConsumerAsyncClient createEventHubClient(String eventHubName, St return new EventHubClientBuilder() .connectionString(connectionStringProvider.getConnectionString(), eventHubName) .consumerGroup(consumerGroup) + .clientOptions(new ClientOptions().setApplicationId(SPRING_EVENT_HUB_APPLICATION_ID)) .buildAsyncConsumerClient(); } private EventHubProducerAsyncClient createProducerClient(String eventHubName) { return new EventHubClientBuilder() .connectionString(connectionStringProvider.getConnectionString(), eventHubName) + .clientOptions(new ClientOptions().setApplicationId(SPRING_EVENT_HUB_APPLICATION_ID)) .buildAsyncProducerClient(); }