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}}"));
}
}