This is an automated email from the ASF dual-hosted git repository.
lburgazzoli pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel-k.git
The following commit(s) were added to refs/heads/master by this push:
new dbdfd56 examples with camel-amqp and connection factory
dbdfd56 is described below
commit dbdfd56c6cb0c92cba23c7335aa7a8bdd1ced122
Author: Hugo Guerrero <1001939+hguerr...@users.noreply.github.com>
AuthorDate: Wed Nov 20 14:32:37 2019 -0500
examples with camel-amqp and connection factory
---
examples/AMQPBindToRegistry.java | 41 ++++++++++++++++++++++++++++++++++++++++
examples/amqp.groovy | 37 ++++++++++++++++++++++++++++++++++++
examples/amqp.js | 31 ++++++++++++++++++++++++++++++
3 files changed, 109 insertions(+)
diff --git a/examples/AMQPBindToRegistry.java b/examples/AMQPBindToRegistry.java
new file mode 100644
index 0000000..76b239a
--- /dev/null
+++ b/examples/AMQPBindToRegistry.java
@@ -0,0 +1,41 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+//
+// To run this integrations use:
+//
+// kamel run -e
BROKER_URL=event-bus-amqp-0-svc.messaging.svc.cluster.local -d camel-amqp
examples/amqp-bind-to-registry.java
+//
+import org.apache.camel.BindToRegistry;
+
+public class AMQPBindToRegistry extends org.apache.camel.builder.RouteBuilder {
+
+ @BindToRegistry
+ public javax.jms.ConnectionFactory connectionFactory() {
+ return new org.apache.qpid.jms.JmsConnectionFactory("amqp://" +
java.lang.System.getenv("BROKER_URL"));
+ }
+
+ @Override
+ public void configure() throws Exception {
+
+ from("timer:js?period=1s")
+ .setBody()
+ .simple("Hello Camel K")
+ .to("amqp:topic:example?exchangePattern=InOnly");
+
+ }
+}
\ No newline at end of file
diff --git a/examples/amqp.groovy b/examples/amqp.groovy
new file mode 100644
index 0000000..39860d2
--- /dev/null
+++ b/examples/amqp.groovy
@@ -0,0 +1,37 @@
+// camel-k: language=groovy
+// Licensed to the Apache Software Foundation (ASF) under one or more
+// contributor license agreements. See the NOTICE file distributed with
+// this work for additional information regarding copyright ownership.
+// The ASF licenses this file to You under the Apache License, Version 2.0
+// (the "License"); you may not use this file except in compliance with
+// the License. You may obtain a copy of the License at
+//
+// http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+//
+// To run this integrations use:
+//
+// kamel run -e
BROKER_URL=event-bus-amqp-0-svc.messaging.svc.cluster.local -d camel-amqp
examples/amqp.groovy
+//
+
+camel {
+ components {
+ amqp {
+ connectionFactory = new org.apache.qpid.jms.JmsConnectionFactory(
+ new URI('amqp://' + System.getenv('BROKER_URL'))
+ )
+ }
+ }
+}
+
+from('timer:js?period=1s')
+ .routeId('js')
+ .setBody()
+ .simple('Hello Camel K')
+ .to('amqp:topic:example?exchangePattern=InOnly')
\ No newline at end of file
diff --git a/examples/amqp.js b/examples/amqp.js
new file mode 100644
index 0000000..d04412c
--- /dev/null
+++ b/examples/amqp.js
@@ -0,0 +1,31 @@
+// camel-k: language=js
+// Licensed to the Apache Software Foundation (ASF) under one or more
+// contributor license agreements. See the NOTICE file distributed with
+// this work for additional information regarding copyright ownership.
+// The ASF licenses this file to You under the Apache License, Version 2.0
+// (the "License"); you may not use this file except in compliance with
+// the License. You may obtain a copy of the License at
+//
+// http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+//
+// To run this integrations use:
+//
+// kamel run -e
BROKER_URL=event-bus-amqp-0-svc.messaging.svc.cluster.local -d camel-amqp
examples/amqp.js
+//
+components.get('amqp')
+ .setConnectionFactory(
+ new org.apache.qpid.jms.JmsConnectionFactory('amqp://' +
java.lang.System.getenv('BROKER_URL'))
+ );
+
+from('timer:js?period=1s')
+ .routeId('js')
+ .setBody()
+ .simple('Hello Camel K')
+ .to('amqp:topic:example?exchangePattern=InOnly')
\ No newline at end of file
