From 7648b68b8658b5ca3fbd407de70c3640f22e8e86 Mon Sep 17 00:00:00 2001 From: Moary Chen Date: Wed, 4 Dec 2024 16:07:12 +0800 Subject: [PATCH] Resolve comment --- .../eventhubs-client/README.md | 3 +++ .../sample/eventhubs/client/EventHubClientApplication.java | 2 +- 2 files changed, 4 insertions(+), 1 deletion(-) diff --git a/eventhubs/spring-cloud-azure-starter-eventhubs/eventhubs-client/README.md b/eventhubs/spring-cloud-azure-starter-eventhubs/eventhubs-client/README.md index 3d40c6c3f..82feccfc4 100644 --- a/eventhubs/spring-cloud-azure-starter-eventhubs/eventhubs-client/README.md +++ b/eventhubs/spring-cloud-azure-starter-eventhubs/eventhubs-client/README.md @@ -172,6 +172,9 @@ You can debug your sample by adding the saved output values to the tool's enviro 1. Verify in your app’s logs that similar messages were posted: ```shell +Sending message using Event Hub producer client. +Sent message to Event Hub. +Receiving message using Event Hub consumer client. Received message: Test event ``` diff --git a/eventhubs/spring-cloud-azure-starter-eventhubs/eventhubs-client/src/main/java/com/azure/spring/sample/eventhubs/client/EventHubClientApplication.java b/eventhubs/spring-cloud-azure-starter-eventhubs/eventhubs-client/src/main/java/com/azure/spring/sample/eventhubs/client/EventHubClientApplication.java index fb8886cb5..b197ce6a1 100644 --- a/eventhubs/spring-cloud-azure-starter-eventhubs/eventhubs-client/src/main/java/com/azure/spring/sample/eventhubs/client/EventHubClientApplication.java +++ b/eventhubs/spring-cloud-azure-starter-eventhubs/eventhubs-client/src/main/java/com/azure/spring/sample/eventhubs/client/EventHubClientApplication.java @@ -46,7 +46,7 @@ public void run(String... args) throws Exception { producerClient.close(); TimeUnit.SECONDS.sleep(3); - LOGGER.info("Receive message using Event Hub consumer client."); + LOGGER.info("Receiving message using Event Hub consumer client."); String PARTITION_ID = "0"; IterableStream partitionEvents = consumerClient.receiveFromPartition(PARTITION_ID, 1, EventPosition.earliest());