This is an automated email from the ASF dual-hosted git repository. dfoulks pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel-examples.git
commit 93cb89ecbda5d7a2154bd139c613dd940bfc0d12 Author: Andrea Cosentino <anco...@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}}")); } }