You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2021/04/16 05:55:36 UTC

[camel-examples] 03/04: Camel-Azure-Eventhubs: Changed the event message

This is an automated email from the ASF dual-hosted git repository.

acosentino pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel-examples.git

commit 93cb89ecbda5d7a2154bd139c613dd940bfc0d12
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Fri Apr 16 07:53:02 2021 +0200

    Camel-Azure-Eventhubs: Changed the event message
---
 .../src/main/java/org/apache/camel/example/MyRouteBuilder.java          | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/examples/azure-eventhubs/src/main/java/org/apache/camel/example/MyRouteBuilder.java b/examples/azure-eventhubs/src/main/java/org/apache/camel/example/MyRouteBuilder.java
index bbab81a..cfa6066 100644
--- a/examples/azure-eventhubs/src/main/java/org/apache/camel/example/MyRouteBuilder.java
+++ b/examples/azure-eventhubs/src/main/java/org/apache/camel/example/MyRouteBuilder.java
@@ -33,7 +33,7 @@ public class MyRouteBuilder extends EndpointRouteBuilder {
         from(azureEventhubs("{{namespaceName}}/{{eventhubName}}").sharedAccessKey("{{sharedAccessKey}}").sharedAccessName("{{sharedAccessName}}").blobAccessKey("{{blobAccessKey}}").blobAccountName("{{blobAccountName}}").blobContainerName("{{blobContainerName}}"))
                 .log("The content is ${body}");
 
-        from(timer("tick").period(1000)).setBody(constant("ciao"))
+        from(timer("tick").period(1000)).setBody(constant("Event Test"))
                 .to(azureEventhubs("{{namespaceName}}/{{eventhubName}}").sharedAccessName("{{sharedAccessName}}").sharedAccessKey("{{sharedAccessKey}}"));
     }
 }