Enrich EH stream binder sample with usage of StreamBridge. (Azure#22561)

* * Enrich EH stream binder sample with usage of StreamBridge.

Author: ZhuXiaoBing-cn

sdk/spring/azure-spring-boot-samples/azure-spring-cloud-sample-eventhubs-binder/README.md

@@ -189,18 +189,43 @@ spring:
       region: [region]
 ```
 
+#### Enable sync message
+To enable message sending in a synchronized way with Spring Cloud Stream 3.x, 
+azure-spring-cloud-stream-binder-eventhubs supports the sync producer mode to get responses for sent messages. 
+By enabling following configuration, you could use [StreamBridge][StreamBridge] for the synchronized message producing.
+
+```yaml
+spring:
+  cloud:
+    stream:
+      eventhub:
+        bindings:
+          supply-out-0:
+            producer:
+              sync: true
+```
 
 ## Examples
 
 1.  Run the `mvn spring-boot:run` in the root of the code sample to get the app running.
 
 1.  Send a POST request
-
-        $ curl -X POST http://localhost:8080/messages?message=hello
-
+    
+        $ ### Send messages through imperative.  
+        $ curl -X POST http://localhost:8080/messages/imperative/staticalDestination?message=hello
+        $ curl -X POST http://localhost:8080/messages/imperative/dynamicDestination?message=hello
+    
+        $ ### Send messages through reactive.
+        $ curl -X POST http://localhost:8080/messages/reactive?message=hello
+    
     or when the app runs on App Service or VM
 
-        $ curl -d -X POST https://[your-app-URL]/messages?message=hello
+        $ ### Send messages through imperative.
+        $ curl -d -X POST https://[your-app-URL]/messages/imperative/staticalDestination?message=hello
+        $ curl -d -X POST https://[your-app-URL]/messages/imperative/dynamicDestination?message=hello
+    
+        $ ### Send messages through reactive.
+        $ curl -d -X POST https://[your-app-URL]/messages/reactive?message=hello
 
 1.  Verify in your app’s logs that a similar message was posted:
 
@@ -230,3 +255,4 @@ spring:
 [application-mi.yaml]: https://github.com/Azure/azure-sdk-for-java/blob/main/sdk/spring/azure-spring-boot-samples/azure-spring-cloud-sample-eventhubs-binder/src/main/resources/application-mi.yaml
 [application.yaml]: https://github.com/Azure/azure-sdk-for-java/blob/main/sdk/spring/azure-spring-boot-samples/azure-spring-cloud-sample-eventhubs-binder/src/main/resources/application.yaml
 [application-sp.yaml]: https://github.com/Azure/azure-sdk-for-java/blob/main/sdk/spring/azure-spring-boot-samples/azure-spring-cloud-sample-eventhubs-binder/src/main/resources/application-sp.yaml
+[StreamBridge]: https://docs.spring.io/spring-cloud-stream/docs/3.1.3/reference/html/spring-cloud-stream.html#_sending_arbitrary_data_to_an_output_e_g_foreign_event_driven_sources

sdk/spring/azure-spring-boot-samples/azure-spring-cloud-sample-eventhubs-binder/src/main/java/com/azure/spring/sample/eventhubs/binder/ImperativeEventProducerController.java

@@ -0,0 +1,44 @@
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License.
+
+package com.azure.spring.sample.eventhubs.binder;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.cloud.stream.function.StreamBridge;
+import org.springframework.context.annotation.Profile;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.RestController;
+
+@RestController
+@Profile("manual")
+public class ImperativeEventProducerController {
+
+    private static final Logger LOGGER = LoggerFactory.getLogger(ImperativeEventProducerController.class);
+
+    //TODO Add output destination
+    private String bindingName = "<output-destination>";
+
+    @Autowired
+    private StreamBridge streamBridge;
+
+    @PostMapping("/messages/imperative/staticalDestination")
+    public ResponseEntity<String> sendMessageToStaticalDestination(@RequestParam String message) {
+        LOGGER.info("Imperative method to send message: {} to static destination.", message);
+        streamBridge.send("supply-out-0", message);
+        LOGGER.info("Sent {}.", message);
+        return ResponseEntity.ok(message);
+    }
+
+    @PostMapping("/messages/imperative/dynamicDestination")
+    public ResponseEntity<String> syncSendMessageToDynamicDestination(@RequestParam String message) {
+        LOGGER.info("Imperative method to send message: {} to dynamic destination.", message);
+        streamBridge.send(bindingName, message);
+        LOGGER.info("Sent {}.", message);
+        return ResponseEntity.ok(message);
+    }
+
+}

…hubs/binder/EventProducerController.java …der/ReactiveEventProducerController.javasdk/spring/azure-spring-boot-samples/azure-spring-cloud-sample-eventhubs-binder/src/main/java/com/azure/spring/sample/eventhubs/binder/EventProducerController.java renamed to sdk/spring/azure-spring-boot-samples/azure-spring-cloud-sample-eventhubs-binder/src/main/java/com/azure/spring/sample/eventhubs/binder/ReactiveEventProducerController.java sdk/spring/azure-spring-boot-samples/azure-spring-cloud-sample-eventhubs-binder/src/main/java/com/azure/spring/sample/eventhubs/binder/EventProducerController.java renamed to sdk/spring/azure-spring-boot-samples/azure-spring-cloud-sample-eventhubs-binder/src/main/java/com/azure/spring/sample/eventhubs/binder/ReactiveEventProducerController.java

@@ -21,16 +21,16 @@
  */
 @RestController
 @Profile("manual")
-public class EventProducerController {
+public class ReactiveEventProducerController {
 
-    private static final Logger LOGGER = LoggerFactory.getLogger(EventHubBinderApplication.class);
+    private static final Logger LOGGER = LoggerFactory.getLogger(ReactiveEventProducerController.class);
 
     @Autowired
     private Sinks.Many<Message<String>> many;
 
-    @PostMapping("/messages")
-    public ResponseEntity<String> sendMessage(@RequestParam String message) {
-        LOGGER.info("Going to add message {} to sendMessage.", message);
+    @PostMapping("/messages/reactive")
+    public ResponseEntity<String> reactiveSendMessage(@RequestParam String message) {
+        LOGGER.info("Reactive method to send message: {} to destination.", message);
         many.emitNext(MessageBuilder.withPayload(message).build(), Sinks.EmitFailureHandler.FAIL_FAST);
         return ResponseEntity.ok(message);
     }

sdk/spring/azure-spring-boot-samples/azure-spring-cloud-sample-eventhubs-binder/src/main/resources/application-mi.yaml

@@ -37,4 +37,3 @@ spring:
       poller:
         initial-delay: 0
         fixed-delay: 1000
-

sdk/spring/azure-spring-boot-samples/azure-spring-cloud-sample-eventhubs-binder/src/main/resources/application-sp.yaml

@@ -38,4 +38,3 @@ spring:
       poller:
         initial-delay: 0
         fixed-delay: 1000
-

sdk/spring/azure-spring-cloud-stream-binder-eventhubs/src/main/java/com/azure/spring/eventhub/stream/binder/properties/EventHubProducerProperties.java

@@ -12,7 +12,7 @@ public class EventHubProducerProperties {
      * If true, the producer will wait for a response from Event Hub after a send operation before sending next message.
      * If false, the producer will keep sending without waiting response
      * <p>
-     * Default: true
+     * Default: false
      */
     private boolean sync;