Fix and test TokenCredential bean name resolution in Stream Binder

Co-authored-by: rujche <[email protected]>

Author: Copilot

sdk/spring/spring-cloud-azure-stream-binder-eventhubs/src/main/java/com/azure/spring/cloud/stream/binder/eventhubs/implementation/config/EventHubsBinderConfiguration.java

@@ -119,11 +119,13 @@ EventHubsMessageChannelBinder eventHubBinder(EventHubsChannelProvisioner channel
     @ConditionalOnMissingBean
     EventHubsProducerFactoryCustomizer defaultEventHubsProducerFactoryCustomizer(
         AzureTokenCredentialResolver azureTokenCredentialResolver,
-        AzureEventHubsProperties eventHubsProperties,
+        ObjectProvider<AzureEventHubsProperties> eventHubsProperties,
         @Qualifier(DEFAULT_TOKEN_CREDENTIAL_BEAN_NAME) TokenCredential defaultAzureCredential,
         ObjectProvider<AzureServiceClientBuilderCustomizer<EventHubClientBuilder>> clientBuilderCustomizers) {
 
-        TokenCredential tokenCredential = azureTokenCredentialResolver.resolve(eventHubsProperties);
+        TokenCredential tokenCredential = eventHubsProperties.getIfAvailable() != null
+            ? azureTokenCredentialResolver.resolve(eventHubsProperties.getIfAvailable())
+            : null;
         TokenCredential credential = tokenCredential != null ? tokenCredential : defaultAzureCredential;
         return new DefaultProducerFactoryCustomizer(credential, azureTokenCredentialResolver, clientBuilderCustomizers);
     }
@@ -132,11 +134,13 @@ EventHubsProducerFactoryCustomizer defaultEventHubsProducerFactoryCustomizer(
     @ConditionalOnMissingBean
     EventHubsProcessorFactoryCustomizer defaultEventHubsProcessorFactoryCustomizer(
         AzureTokenCredentialResolver azureTokenCredentialResolver,
-        AzureEventHubsProperties eventHubsProperties,
+        ObjectProvider<AzureEventHubsProperties> eventHubsProperties,
         @Qualifier(DEFAULT_TOKEN_CREDENTIAL_BEAN_NAME) TokenCredential defaultCredential,
         ObjectProvider<AzureServiceClientBuilderCustomizer<EventProcessorClientBuilder>> processorClientBuilderCustomizers) {
 
-        TokenCredential tokenCredential = azureTokenCredentialResolver.resolve(eventHubsProperties);
+        TokenCredential tokenCredential = eventHubsProperties.getIfAvailable() != null
+            ? azureTokenCredentialResolver.resolve(eventHubsProperties.getIfAvailable())
+            : null;
         TokenCredential credential = tokenCredential != null ? tokenCredential : defaultCredential;
         return new DefaultProcessorFactoryCustomizer(credential, azureTokenCredentialResolver, processorClientBuilderCustomizers);
     }

sdk/spring/spring-cloud-azure-stream-binder-servicebus/src/main/java/com/azure/spring/cloud/stream/binder/servicebus/implementation/config/ServiceBusBinderConfiguration.java

@@ -120,12 +120,14 @@ ServiceBusMessageChannelBinder serviceBusBinder(ServiceBusChannelProvisioner cha
     @ConditionalOnMissingBean
     ServiceBusProducerFactoryCustomizer defaultServiceBusProducerFactoryCustomizer(
         AzureTokenCredentialResolver azureTokenCredentialResolver,
-        AzureServiceBusProperties serviceBusProperties,
+        ObjectProvider<AzureServiceBusProperties> serviceBusProperties,
         @Qualifier(DEFAULT_TOKEN_CREDENTIAL_BEAN_NAME) TokenCredential defaultAzureCredential,
         ObjectProvider<AzureServiceClientBuilderCustomizer<ServiceBusClientBuilder>> clientBuilderCustomizers,
         ObjectProvider<AzureServiceClientBuilderCustomizer<ServiceBusClientBuilder.ServiceBusSenderClientBuilder>> senderClientBuilderCustomizers) {
 
-        TokenCredential tokenCredential = azureTokenCredentialResolver.resolve(serviceBusProperties);
+        TokenCredential tokenCredential = serviceBusProperties.getIfAvailable() != null
+            ? azureTokenCredentialResolver.resolve(serviceBusProperties.getIfAvailable())
+            : null;
         TokenCredential credential = tokenCredential != null ? tokenCredential : defaultAzureCredential;
         return new DefaultProducerFactoryCustomizer(credential, azureTokenCredentialResolver,
             clientBuilderCustomizers,
@@ -136,13 +138,15 @@ ServiceBusProducerFactoryCustomizer defaultServiceBusProducerFactoryCustomizer(
     @ConditionalOnMissingBean
     ServiceBusProcessorFactoryCustomizer defaultServiceBusProcessorFactoryCustomizer(
         AzureTokenCredentialResolver azureTokenCredentialResolver,
-        AzureServiceBusProperties serviceBusProperties,
+        ObjectProvider<AzureServiceBusProperties> serviceBusProperties,
         @Qualifier(DEFAULT_TOKEN_CREDENTIAL_BEAN_NAME) TokenCredential defaultAzureCredential,
         ObjectProvider<AzureServiceClientBuilderCustomizer<ServiceBusClientBuilder>> clientBuilderCustomizers,
         ObjectProvider<AzureServiceClientBuilderCustomizer<ServiceBusClientBuilder.ServiceBusProcessorClientBuilder>> processorClientBuilderCustomizers,
         ObjectProvider<AzureServiceClientBuilderCustomizer<ServiceBusClientBuilder.ServiceBusSessionProcessorClientBuilder>> sessionProcessorClientBuilderCustomizers) {
 
-        TokenCredential tokenCredential = azureTokenCredentialResolver.resolve(serviceBusProperties);
+        TokenCredential tokenCredential = serviceBusProperties.getIfAvailable() != null
+            ? azureTokenCredentialResolver.resolve(serviceBusProperties.getIfAvailable())
+            : null;
         TokenCredential credential = tokenCredential != null ? tokenCredential : defaultAzureCredential;
         return new DefaultProcessorFactoryCustomizer(credential, azureTokenCredentialResolver,
             clientBuilderCustomizers,