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 2020/12/08 09:49:35 UTC
[camel-kafka-connector] branch master updated: Fix example
CamelAmqpSourceConnector using sink instead of source property #767
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-kafka-connector.git
The following commit(s) were added to refs/heads/master by this push:
new 373f5bf Fix example CamelAmqpSourceConnector using sink instead of source property #767
373f5bf is described below
commit 373f5bf9c494c974e58dbcb3b801c5861d5a7b82
Author: Aurélien Pupier <ap...@redhat.com>
AuthorDate: Tue Dec 8 10:45:13 2020 +0100
Fix example CamelAmqpSourceConnector using sink instead of source property #767
Signed-off-by: Aurélien Pupier <ap...@redhat.com>
---
examples/CamelAmqpSourceConnector.properties | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/examples/CamelAmqpSourceConnector.properties b/examples/CamelAmqpSourceConnector.properties
index 2ed871b..fe9ca91 100644
--- a/examples/CamelAmqpSourceConnector.properties
+++ b/examples/CamelAmqpSourceConnector.properties
@@ -20,8 +20,8 @@ topics=mytopic
tasks.max=1
connector.class=org.apache.camel.kafkaconnector.amqp.CamelAmqpSourceConnector
-camel.sink.path.destinationType=queue
-camel.sink.path.destinationName=test-queue
+camel.source.path.destinationType=queue
+camel.source.path.destinationName=test-queue
camel.component.amqp.includeAmqpAnnotations=true
camel.component.amqp.connectionFactory=#class:org.apache.qpid.jms.JmsConnectionFactory