add clientOptions for EventHubClientBuilder (#17519)

- add clientOptions for EventHubClientBuilder
Azure · Nov 12, 2020 · 050fd75 · 050fd75
1 parent bc930bc
commit 050fd75
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/...main/java/com/azure/spring/integration/eventhub/factory/DefaultEventHubClientFactory.java b/...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();
     }