You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by pp...@apache.org on 2021/01/29 20:06:08 UTC
[camel-quarkus] branch master updated: Azure Event Hubs support
#2079
This is an automated email from the ASF dual-hosted git repository.
ppalaga pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git
The following commit(s) were added to refs/heads/master by this push:
new e07da63 Azure Event Hubs support #2079
e07da63 is described below
commit e07da63a3fbf4cdfd3bee285b0f97caea29750be
Author: Peter Palaga <pp...@redhat.com>
AuthorDate: Fri Jan 29 11:38:00 2021 +0100
Azure Event Hubs support #2079
---
catalog/pom.xml | 26 ++++
.../reference/extensions/azure-eventhubs.adoc | 39 ++++++
.../reference/components/azure-eventhubs.adoc | 14 ++-
.../azure-core}/deployment/pom.xml | 14 ++-
.../deployment/AzureCoreSupportProcessor.java | 70 +++++++++++
extensions-support/{ => azure-core}/pom.xml | 35 ++----
.../{reactor-netty => azure-core}/runtime/pom.xml | 25 ++--
.../main/resources/META-INF/quarkus-extension.yaml | 27 ++++
extensions-support/pom.xml | 1 +
.../deployment/ReactorNettySupportProcessor.java | 17 ++-
extensions-support/reactor-netty/runtime/pom.xml | 12 +-
.../netty/graal/NettySslProviderSubstitutions.java | 50 ++++++++
.../reactor/netty/graal/OpenSslSubstitutions.java | 90 ++++++++++++++
.../netty/graal/SslProviderSubstitutions.java | 42 +++++++
.../deployment/pom.xml | 14 ++-
.../deployment/AzureEventhubsProcessor.java} | 42 +++----
extensions/azure-eventhubs/pom.xml | 39 ++++++
.../runtime/pom.xml | 19 +--
.../main/resources/META-INF/quarkus-extension.yaml | 31 +++++
extensions/azure-storage-blob/deployment/pom.xml | 2 +-
.../blob/deployment/AzureStorageBlobProcessor.java | 13 +-
extensions/azure-storage-blob/runtime/pom.xml | 2 +-
extensions/azure-storage-queue/deployment/pom.xml | 2 +-
.../deployment/AzureStorageQueueProcessor.java | 4 +-
extensions/azure-storage-queue/runtime/pom.xml | 2 +-
extensions/pom.xml | 1 +
integration-tests/azure-eventhubs/README.adoc | 18 +++
integration-tests/azure-eventhubs/pom.xml | 137 +++++++++++++++++++++
.../azure/eventhubs/it/AzureEventhubsResource.java | 83 +++++++++++++
.../azure/eventhubs/it/AzureEventhubsIT.java | 29 +++++
.../azure/eventhubs/it/AzureEventhubsTest.java | 60 +++++++++
integration-tests/pom.xml | 1 +
pom.xml | 10 ++
poms/bom/pom.xml | 86 ++++++++++++-
tooling/scripts/test-categories.yaml | 3 +-
35 files changed, 949 insertions(+), 111 deletions(-)
diff --git a/catalog/pom.xml b/catalog/pom.xml
index da1081a..395d830 100644
--- a/catalog/pom.xml
+++ b/catalog/pom.xml
@@ -712,6 +712,19 @@
</dependency>
<dependency>
<groupId>org.apache.camel.quarkus</groupId>
+ <artifactId>camel-quarkus-azure-eventhubs</artifactId>
+ <version>${project.version}</version>
+ <type>pom</type>
+ <scope>test</scope>
+ <exclusions>
+ <exclusion>
+ <groupId>*</groupId>
+ <artifactId>*</artifactId>
+ </exclusion>
+ </exclusions>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.camel.quarkus</groupId>
<artifactId>camel-quarkus-azure-storage-blob</artifactId>
<version>${project.version}</version>
<type>pom</type>
@@ -3728,6 +3741,19 @@
</dependency>
<dependency>
<groupId>org.apache.camel.quarkus</groupId>
+ <artifactId>camel-quarkus-support-azure-core</artifactId>
+ <version>${project.version}</version>
+ <type>pom</type>
+ <scope>test</scope>
+ <exclusions>
+ <exclusion>
+ <groupId>*</groupId>
+ <artifactId>*</artifactId>
+ </exclusion>
+ </exclusions>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.camel.quarkus</groupId>
<artifactId>camel-quarkus-support-reactor-netty</artifactId>
<version>${project.version}</version>
<type>pom</type>
diff --git a/docs/modules/ROOT/pages/reference/extensions/azure-eventhubs.adoc b/docs/modules/ROOT/pages/reference/extensions/azure-eventhubs.adoc
new file mode 100644
index 0000000..a88f9e0
--- /dev/null
+++ b/docs/modules/ROOT/pages/reference/extensions/azure-eventhubs.adoc
@@ -0,0 +1,39 @@
+// Do not edit directly!
+// This file was generated by camel-quarkus-maven-plugin:update-extension-doc-page
+= Azure Event Hubs
+:cq-artifact-id: camel-quarkus-azure-eventhubs
+:cq-native-supported: true
+:cq-status: Stable
+:cq-description: The azure-eventhubs component that integrates Azure Event Hubs using AMQP protocol. Azure EventHubs is a highly scalable publish-subscribe service that can ingest millions of events per second and stream them to multiple consumers.
+:cq-deprecated: false
+:cq-jvm-since: 1.7.0
+:cq-native-since: 1.7.0
+
+[.badges]
+[.badge-key]##JVM since##[.badge-supported]##1.7.0## [.badge-key]##Native since##[.badge-supported]##1.7.0##
+
+The azure-eventhubs component that integrates Azure Event Hubs using AMQP protocol. Azure EventHubs is a highly scalable publish-subscribe service that can ingest millions of events per second and stream them to multiple consumers.
+
+== What's inside
+
+* xref:{cq-camel-components}::azure-eventhubs-component.adoc[Azure Event Hubs component], URI syntax: `azure-eventhubs:namespace/eventHubName`
+
+Please refer to the above link for usage and configuration details.
+
+== Maven coordinates
+
+[source,xml]
+----
+<dependency>
+ <groupId>org.apache.camel.quarkus</groupId>
+ <artifactId>camel-quarkus-azure-eventhubs</artifactId>
+</dependency>
+----
+
+Check the xref:user-guide/index.adoc[User guide] for more information about writing Camel Quarkus applications.
+
+== SSL in native mode
+
+This extension auto-enables SSL support in native mode. Hence you do not need to add
+`quarkus.ssl.native=true` to your `application.properties` yourself. See also
+https://quarkus.io/guides/native-and-ssl[Quarkus SSL guide].
diff --git a/docs/modules/ROOT/partials/reference/components/azure-eventhubs.adoc b/docs/modules/ROOT/partials/reference/components/azure-eventhubs.adoc
index a509c1d..9cae37d 100644
--- a/docs/modules/ROOT/partials/reference/components/azure-eventhubs.adoc
+++ b/docs/modules/ROOT/partials/reference/components/azure-eventhubs.adoc
@@ -1 +1,13 @@
-// Empty partial for a Camel bit unsupported by Camel Quarkus to avoid warnings when this file is included from a Camel page
+// Do not edit directly!
+// This file was generated by camel-quarkus-maven-plugin:update-extension-doc-page
+:cq-artifact-id: camel-quarkus-azure-eventhubs
+:cq-artifact-id-base: azure-eventhubs
+:cq-native-supported: true
+:cq-status: Stable
+:cq-deprecated: false
+:cq-jvm-since: 1.7.0
+:cq-native-since: 1.7.0
+:cq-camel-part-name: azure-eventhubs
+:cq-camel-part-title: Azure Event Hubs
+:cq-camel-part-description: The azure-eventhubs component that integrates Azure Event Hubs using AMQP protocol. Azure EventHubs is a highly scalable publish-subscribe service that can ingest millions of events per second and stream them to multiple consumers.
+:cq-extension-page-title: Azure Event Hubs
diff --git a/extensions/azure-storage-blob/deployment/pom.xml b/extensions-support/azure-core/deployment/pom.xml
similarity index 82%
copy from extensions/azure-storage-blob/deployment/pom.xml
copy to extensions-support/azure-core/deployment/pom.xml
index 669a51a..9660b4d 100644
--- a/extensions/azure-storage-blob/deployment/pom.xml
+++ b/extensions-support/azure-core/deployment/pom.xml
@@ -21,18 +21,22 @@
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>org.apache.camel.quarkus</groupId>
- <artifactId>camel-quarkus-azure-storage-blob-parent</artifactId>
+ <artifactId>camel-quarkus-support-azure-core-parent</artifactId>
<version>1.7.0-SNAPSHOT</version>
<relativePath>../pom.xml</relativePath>
</parent>
- <artifactId>camel-quarkus-azure-storage-blob-deployment</artifactId>
- <name>Camel Quarkus :: Azure Storage Blob Service :: Deployment</name>
+ <artifactId>camel-quarkus-support-azure-core-deployment</artifactId>
+ <name>Camel Quarkus :: Support :: Azure Core :: Deployment</name>
<dependencies>
<dependency>
+ <groupId>io.quarkus</groupId>
+ <artifactId>quarkus-core-deployment</artifactId>
+ </dependency>
+ <dependency>
<groupId>org.apache.camel.quarkus</groupId>
- <artifactId>camel-quarkus-core-deployment</artifactId>
+ <artifactId>camel-quarkus-support-jackson-dataformat-xml-deployment</artifactId>
</dependency>
<dependency>
<groupId>org.apache.camel.quarkus</groupId>
@@ -40,7 +44,7 @@
</dependency>
<dependency>
<groupId>org.apache.camel.quarkus</groupId>
- <artifactId>camel-quarkus-azure-storage-blob</artifactId>
+ <artifactId>camel-quarkus-support-azure-core</artifactId>
</dependency>
</dependencies>
diff --git a/extensions-support/azure-core/deployment/src/main/java/org/apache/camel/quarkus/support/reactor/netty/deployment/AzureCoreSupportProcessor.java b/extensions-support/azure-core/deployment/src/main/java/org/apache/camel/quarkus/support/reactor/netty/deployment/AzureCoreSupportProcessor.java
new file mode 100644
index 0000000..d771995
--- /dev/null
+++ b/extensions-support/azure-core/deployment/src/main/java/org/apache/camel/quarkus/support/reactor/netty/deployment/AzureCoreSupportProcessor.java
@@ -0,0 +1,70 @@
+/*
+ * 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.
+ */
+package org.apache.camel.quarkus.support.reactor.netty.deployment;
+
+import java.io.IOException;
+import java.util.Set;
+import java.util.stream.Stream;
+
+import com.azure.core.http.HttpClientProvider;
+import io.quarkus.deployment.annotations.BuildProducer;
+import io.quarkus.deployment.annotations.BuildStep;
+import io.quarkus.deployment.builditem.IndexDependencyBuildItem;
+import io.quarkus.deployment.builditem.nativeimage.NativeImageResourceBuildItem;
+import io.quarkus.deployment.builditem.nativeimage.ReflectiveClassBuildItem;
+import io.quarkus.deployment.builditem.nativeimage.ServiceProviderBuildItem;
+import io.quarkus.deployment.util.ServiceUtil;
+
+public class AzureCoreSupportProcessor {
+ static final String FEATURE = "camel-support-azure-core";
+
+ @BuildStep
+ IndexDependencyBuildItem indexDependency() {
+ return new IndexDependencyBuildItem("com.azure", "azure-core");
+ }
+
+ @BuildStep
+ void reflectiveClasses(BuildProducer<ReflectiveClassBuildItem> reflectiveClasses) {
+ reflectiveClasses.produce(new ReflectiveClassBuildItem(false, false, com.azure.core.util.DateTimeRfc1123.class));
+ }
+
+ @BuildStep
+ void nativeResources(BuildProducer<ServiceProviderBuildItem> services,
+ BuildProducer<NativeImageResourceBuildItem> nativeResources) {
+ Stream.of(
+ HttpClientProvider.class.getName(), // TODO move this to a separate camel-quarkus-azure-core extension
+ "reactor.blockhound.integration.BlockHoundIntegration" // TODO: move to reactor extension
+
+ )
+ .forEach(service -> {
+ try {
+ Set<String> implementations = ServiceUtil.classNamesNamedIn(
+ Thread.currentThread().getContextClassLoader(),
+ "META-INF/services/" + service);
+ services.produce(
+ new ServiceProviderBuildItem(service,
+ implementations.toArray(new String[0])));
+
+ } catch (IOException e) {
+ throw new RuntimeException(e);
+ }
+ });
+
+ nativeResources.produce(new NativeImageResourceBuildItem(
+ "azure-core.properties"));
+ }
+}
diff --git a/extensions-support/pom.xml b/extensions-support/azure-core/pom.xml
similarity index 55%
copy from extensions-support/pom.xml
copy to extensions-support/azure-core/pom.xml
index 40bb2d4..1653aae 100644
--- a/extensions-support/pom.xml
+++ b/extensions-support/azure-core/pom.xml
@@ -18,41 +18,20 @@
-->
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
-
+ <modelVersion>4.0.0</modelVersion>
<parent>
<groupId>org.apache.camel.quarkus</groupId>
- <artifactId>camel-quarkus</artifactId>
+ <artifactId>camel-quarkus-build-parent</artifactId>
<version>1.7.0-SNAPSHOT</version>
+ <relativePath>../../poms/build-parent/pom.xml</relativePath>
</parent>
- <modelVersion>4.0.0</modelVersion>
-
- <artifactId>camel-quarkus-extensions-support</artifactId>
- <name>Camel Quarkus :: Extensions :: Support</name>
+ <artifactId>camel-quarkus-support-azure-core-parent</artifactId>
+ <name>Camel Quarkus :: Support :: Azure Core</name>
<packaging>pom</packaging>
<modules>
- <!-- extensions a..z; do not remove this comment, it is important when sorting via mvn process-resources -Pformat -->
- <module>ahc</module>
- <module>aws</module>
- <module>aws2</module>
- <module>bouncycastle</module>
- <module>common</module>
- <module>commons-logging</module>
- <module>consul-client</module>
- <module>debezium</module>
- <module>google-http-client</module>
- <module>httpclient</module>
- <module>jackson-dataformat-xml</module>
- <module>jetty</module>
- <module>mail</module>
- <module>mongodb</module>
- <module>reactor-netty</module>
- <module>retrofit</module>
- <module>spring</module>
- <module>stax</module>
- <module>webhook</module>
- <module>xstream</module>
- <module>xalan</module>
+ <module>deployment</module>
+ <module>runtime</module>
</modules>
</project>
diff --git a/extensions-support/reactor-netty/runtime/pom.xml b/extensions-support/azure-core/runtime/pom.xml
similarity index 76%
copy from extensions-support/reactor-netty/runtime/pom.xml
copy to extensions-support/azure-core/runtime/pom.xml
index 7ac70d8..4dfa921 100644
--- a/extensions-support/reactor-netty/runtime/pom.xml
+++ b/extensions-support/azure-core/runtime/pom.xml
@@ -21,13 +21,13 @@
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>org.apache.camel.quarkus</groupId>
- <artifactId>camel-quarkus-support-reactor-netty-parent</artifactId>
+ <artifactId>camel-quarkus-support-azure-core-parent</artifactId>
<version>1.7.0-SNAPSHOT</version>
<relativePath>../pom.xml</relativePath>
</parent>
- <artifactId>camel-quarkus-support-reactor-netty</artifactId>
- <name>Camel Quarkus :: Support :: Reactor Netty :: Runtime</name>
+ <artifactId>camel-quarkus-support-azure-core</artifactId>
+ <name>Camel Quarkus :: Support :: Azure Core :: Runtime</name>
<properties>
<camel.quarkus.jvmSince>1.7.0</camel.quarkus.jvmSince>
@@ -52,21 +52,16 @@
<artifactId>quarkus-core</artifactId>
</dependency>
<dependency>
- <groupId>io.quarkus</groupId>
- <artifactId>quarkus-netty</artifactId>
+ <groupId>org.apache.camel.quarkus</groupId>
+ <artifactId>camel-quarkus-support-jackson-dataformat-xml</artifactId>
</dependency>
- <!-- As lazy as we are, we prefer not to manage reactor-netty.
- We can afford that because our build items do not actually
- require reactor-netty as a dependency.
- We assume that modules that will depend on this one will have reactor-netty as a dependency
- as a transitive dependency via azure-storage-blob or similar
<dependency>
- <groupId>io.projectreactor.netty</groupId>
- <artifactId>reactor-netty</artifactId>
- </dependency> -->
+ <groupId>org.apache.camel.quarkus</groupId>
+ <artifactId>camel-quarkus-support-reactor-netty</artifactId>
+ </dependency>
<dependency>
- <groupId>io.quarkus</groupId>
- <artifactId>quarkus-micrometer</artifactId>
+ <groupId>com.azure</groupId>
+ <artifactId>azure-core</artifactId>
</dependency>
</dependencies>
diff --git a/extensions-support/azure-core/runtime/src/main/resources/META-INF/quarkus-extension.yaml b/extensions-support/azure-core/runtime/src/main/resources/META-INF/quarkus-extension.yaml
new file mode 100644
index 0000000..10c2476
--- /dev/null
+++ b/extensions-support/azure-core/runtime/src/main/resources/META-INF/quarkus-extension.yaml
@@ -0,0 +1,27 @@
+#
+# 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.
+#
+
+---
+name: "Camel Quarkus Support Azure Core"
+description: "Camel Quarkus Support Azure Core"
+metadata:
+ unlisted: true
+ keywords:
+ - "camel"
+ guide: "https://quarkus.io/guides/camel"
+ categories:
+ - "integration"
diff --git a/extensions-support/pom.xml b/extensions-support/pom.xml
index 40bb2d4..72f8b1e 100644
--- a/extensions-support/pom.xml
+++ b/extensions-support/pom.xml
@@ -36,6 +36,7 @@
<module>ahc</module>
<module>aws</module>
<module>aws2</module>
+ <module>azure-core</module>
<module>bouncycastle</module>
<module>common</module>
<module>commons-logging</module>
diff --git a/extensions-support/reactor-netty/deployment/src/main/java/org/apache/camel/quarkus/support/reactor/netty/deployment/ReactorNettySupportProcessor.java b/extensions-support/reactor-netty/deployment/src/main/java/org/apache/camel/quarkus/support/reactor/netty/deployment/ReactorNettySupportProcessor.java
index 76f4993..d8c4fb8 100644
--- a/extensions-support/reactor-netty/deployment/src/main/java/org/apache/camel/quarkus/support/reactor/netty/deployment/ReactorNettySupportProcessor.java
+++ b/extensions-support/reactor-netty/deployment/src/main/java/org/apache/camel/quarkus/support/reactor/netty/deployment/ReactorNettySupportProcessor.java
@@ -21,6 +21,7 @@ import java.util.stream.Stream;
import io.quarkus.deployment.annotations.BuildProducer;
import io.quarkus.deployment.annotations.BuildStep;
import io.quarkus.deployment.builditem.FeatureBuildItem;
+import io.quarkus.deployment.builditem.nativeimage.ReflectiveClassBuildItem;
import io.quarkus.deployment.builditem.nativeimage.RuntimeInitializedClassBuildItem;
public class ReactorNettySupportProcessor {
@@ -34,10 +35,7 @@ public class ReactorNettySupportProcessor {
@BuildStep
void runtimeInitializedClasses(BuildProducer<RuntimeInitializedClassBuildItem> runtimeInitializedClasses) {
Stream.of(
- // TODO: move these io.netty.* items to Quarkus https://github.com/apache/camel-quarkus/issues/2142
- "io.netty.handler.ssl.OpenSsl",
- "io.netty.internal.tcnative.SSL",
- "io.netty.util.NetUtil",
+ "io.netty.util.NetUtil", // TODO: move this to quarkus-netty https://github.com/apache/camel-quarkus/issues/2142
"reactor.netty.http.client.HttpClient",
"reactor.netty.tcp.TcpClient",
@@ -50,4 +48,15 @@ public class ReactorNettySupportProcessor {
.forEach(runtimeInitializedClasses::produce);
}
+ @BuildStep
+ void reflectiveClasses(BuildProducer<ReflectiveClassBuildItem> reflectiveClasses) {
+
+ reflectiveClasses.produce(new ReflectiveClassBuildItem(true, false,
+ "reactor.netty.channel.BootstrapHandlers$BootstrapInitializerHandler",
+ "reactor.netty.channel.ChannelOperationsHandler",
+ "reactor.netty.resources.PooledConnectionProvider$PooledConnectionAllocator$PooledConnectionInitializer",
+ "reactor.netty.tcp.SslProvider$SslReadHandler"));
+
+ }
+
}
diff --git a/extensions-support/reactor-netty/runtime/pom.xml b/extensions-support/reactor-netty/runtime/pom.xml
index 7ac70d8..e3f9e40 100644
--- a/extensions-support/reactor-netty/runtime/pom.xml
+++ b/extensions-support/reactor-netty/runtime/pom.xml
@@ -55,19 +55,19 @@
<groupId>io.quarkus</groupId>
<artifactId>quarkus-netty</artifactId>
</dependency>
- <!-- As lazy as we are, we prefer not to manage reactor-netty.
- We can afford that because our build items do not actually
- require reactor-netty as a dependency.
- We assume that modules that will depend on this one will have reactor-netty as a dependency
- as a transitive dependency via azure-storage-blob or similar
<dependency>
<groupId>io.projectreactor.netty</groupId>
<artifactId>reactor-netty</artifactId>
- </dependency> -->
+ </dependency>
<dependency>
<groupId>io.quarkus</groupId>
<artifactId>quarkus-micrometer</artifactId>
</dependency>
+ <dependency>
+ <groupId>org.graalvm.nativeimage</groupId>
+ <artifactId>svm</artifactId>
+ <scope>provided</scope>
+ </dependency>
</dependencies>
<build>
diff --git a/extensions-support/reactor-netty/runtime/src/main/java/org/apache/camel/quarkus/support/reactor/netty/graal/NettySslProviderSubstitutions.java b/extensions-support/reactor-netty/runtime/src/main/java/org/apache/camel/quarkus/support/reactor/netty/graal/NettySslProviderSubstitutions.java
new file mode 100644
index 0000000..b3ed96a
--- /dev/null
+++ b/extensions-support/reactor-netty/runtime/src/main/java/org/apache/camel/quarkus/support/reactor/netty/graal/NettySslProviderSubstitutions.java
@@ -0,0 +1,50 @@
+/*
+ * 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.
+ */
+package org.apache.camel.quarkus.support.reactor.netty.graal;
+
+import com.oracle.svm.core.annotate.Alias;
+import com.oracle.svm.core.annotate.Substitute;
+import com.oracle.svm.core.annotate.TargetClass;
+import io.netty.handler.ssl.JdkAlpnApplicationProtocolNegotiator;
+import io.netty.handler.ssl.SslProvider;
+
+//TODO: move this to quarkus-netty https://github.com/apache/camel-quarkus/issues/2142
+@TargetClass(SslProvider.class)
+final class NettySslProviderSubstitutions {
+ @Substitute
+ public static boolean isAlpnSupported(final SslProvider provider) {
+ switch (provider) {
+ case JDK:
+ return JdkAlpnApplicationProtocolNegotiatorSubstitutions.isAlpnSupported();
+ case OPENSSL:
+ case OPENSSL_REFCNT:
+ return false;
+ default:
+ throw new Error("SslProvider unsupported on Quarkus " + provider);
+ }
+ }
+
+}
+
+@TargetClass(JdkAlpnApplicationProtocolNegotiator.class)
+final class JdkAlpnApplicationProtocolNegotiatorSubstitutions {
+ @Alias
+ static boolean isAlpnSupported() {
+ return true;
+ }
+
+}
diff --git a/extensions-support/reactor-netty/runtime/src/main/java/org/apache/camel/quarkus/support/reactor/netty/graal/OpenSslSubstitutions.java b/extensions-support/reactor-netty/runtime/src/main/java/org/apache/camel/quarkus/support/reactor/netty/graal/OpenSslSubstitutions.java
new file mode 100644
index 0000000..ad7d18e
--- /dev/null
+++ b/extensions-support/reactor-netty/runtime/src/main/java/org/apache/camel/quarkus/support/reactor/netty/graal/OpenSslSubstitutions.java
@@ -0,0 +1,90 @@
+/*
+ * 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.
+ */
+package org.apache.camel.quarkus.support.reactor.netty.graal;
+
+import java.util.Collections;
+import java.util.List;
+import java.util.Set;
+
+import com.oracle.svm.core.annotate.Alias;
+import com.oracle.svm.core.annotate.RecomputeFieldValue;
+import com.oracle.svm.core.annotate.RecomputeFieldValue.Kind;
+import com.oracle.svm.core.annotate.Substitute;
+import com.oracle.svm.core.annotate.TargetClass;
+import io.netty.handler.ssl.OpenSsl;
+
+/**
+ * JDK is the only supported SSL provider on Quarkus. We thus substitute the methods of {@link OpenSsl} to the effect
+ * that OpenSSL is not available.
+ */
+//TODO: move this to quarkus-netty https://github.com/apache/camel-quarkus/issues/2142
+@TargetClass(OpenSsl.class)
+final class OpenSslSubstitutions {
+
+ @Alias
+ @RecomputeFieldValue(kind = Kind.FromAlias)
+ private static Throwable UNAVAILABILITY_CAUSE = new RuntimeException("OpenSsl unsupported on Quarkus");
+
+ @Alias
+ @RecomputeFieldValue(kind = Kind.FromAlias)
+ static List<String> DEFAULT_CIPHERS = Collections.emptyList();
+
+ @Alias
+ @RecomputeFieldValue(kind = Kind.FromAlias)
+ static Set<String> AVAILABLE_CIPHER_SUITES = Collections.emptySet();
+
+ @Alias
+ @RecomputeFieldValue(kind = Kind.FromAlias)
+ private static Set<String> AVAILABLE_OPENSSL_CIPHER_SUITES = Collections.emptySet();
+
+ @Alias
+ @RecomputeFieldValue(kind = Kind.FromAlias)
+ private static Set<String> AVAILABLE_JAVA_CIPHER_SUITES = Collections.emptySet();
+
+ @Alias
+ @RecomputeFieldValue(kind = Kind.FromAlias)
+ private static boolean SUPPORTS_KEYMANAGER_FACTORY = false;
+
+ @Alias
+ @RecomputeFieldValue(kind = Kind.FromAlias)
+ private static boolean SUPPORTS_OCSP = false;
+
+ @Alias
+ @RecomputeFieldValue(kind = Kind.FromAlias)
+ static Set<String> SUPPORTED_PROTOCOLS_SET = Collections.emptySet();
+
+ @Substitute
+ public static boolean isAvailable() {
+ return false;
+ }
+
+ @Substitute
+ public static int version() {
+ return -1;
+ }
+
+ @Substitute
+ public static String versionString() {
+ return null;
+ }
+
+ @Substitute
+ public static boolean isCipherSuiteAvailable(String cipherSuite) {
+ return false;
+ }
+
+}
diff --git a/extensions-support/reactor-netty/runtime/src/main/java/org/apache/camel/quarkus/support/reactor/netty/graal/SslProviderSubstitutions.java b/extensions-support/reactor-netty/runtime/src/main/java/org/apache/camel/quarkus/support/reactor/netty/graal/SslProviderSubstitutions.java
new file mode 100644
index 0000000..511a09a
--- /dev/null
+++ b/extensions-support/reactor-netty/runtime/src/main/java/org/apache/camel/quarkus/support/reactor/netty/graal/SslProviderSubstitutions.java
@@ -0,0 +1,42 @@
+/*
+ * 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.
+ */
+package org.apache.camel.quarkus.support.reactor.netty.graal;
+
+import com.oracle.svm.core.annotate.Alias;
+import com.oracle.svm.core.annotate.Substitute;
+import com.oracle.svm.core.annotate.TargetClass;
+import io.netty.handler.ssl.IdentityCipherSuiteFilter;
+import io.netty.handler.ssl.SslContextBuilder;
+import reactor.netty.tcp.SslProvider;
+
+@TargetClass(SslProvider.class)
+//TODO: move this to quarkus-netty https://github.com/apache/camel-quarkus/issues/2142
+public final class SslProviderSubstitutions {
+
+ @Alias
+ SslContextBuilder sslContextBuilder;
+
+ @Substitute
+ void updateDefaultConfiguration() {
+ /* We hardcode the reactor.netty.tcp.SslProvider.DefaultConfigurationType.TCP path from the original method
+ * to avoid requiring io.netty.handler.ssl.OpenSsl */
+ sslContextBuilder.sslProvider(io.netty.handler.ssl.SslProvider.JDK)
+ .ciphers(null, IdentityCipherSuiteFilter.INSTANCE)
+ .applicationProtocolConfig(null);
+ }
+
+}
diff --git a/extensions/azure-storage-blob/deployment/pom.xml b/extensions/azure-eventhubs/deployment/pom.xml
similarity index 78%
copy from extensions/azure-storage-blob/deployment/pom.xml
copy to extensions/azure-eventhubs/deployment/pom.xml
index 669a51a..ade3234 100644
--- a/extensions/azure-storage-blob/deployment/pom.xml
+++ b/extensions/azure-eventhubs/deployment/pom.xml
@@ -17,17 +17,19 @@
limitations under the License.
-->
-<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+ xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+ xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>org.apache.camel.quarkus</groupId>
- <artifactId>camel-quarkus-azure-storage-blob-parent</artifactId>
+ <artifactId>camel-quarkus-azure-eventhubs-parent</artifactId>
<version>1.7.0-SNAPSHOT</version>
<relativePath>../pom.xml</relativePath>
</parent>
- <artifactId>camel-quarkus-azure-storage-blob-deployment</artifactId>
- <name>Camel Quarkus :: Azure Storage Blob Service :: Deployment</name>
+ <artifactId>camel-quarkus-azure-eventhubs-deployment</artifactId>
+ <name>Camel Quarkus :: Azure Event Hubs :: Deployment</name>
<dependencies>
<dependency>
@@ -36,11 +38,11 @@
</dependency>
<dependency>
<groupId>org.apache.camel.quarkus</groupId>
- <artifactId>camel-quarkus-support-reactor-netty-deployment</artifactId>
+ <artifactId>camel-quarkus-azure-storage-blob-deployment</artifactId>
</dependency>
<dependency>
<groupId>org.apache.camel.quarkus</groupId>
- <artifactId>camel-quarkus-azure-storage-blob</artifactId>
+ <artifactId>camel-quarkus-azure-eventhubs</artifactId>
</dependency>
</dependencies>
diff --git a/extensions/azure-storage-queue/deployment/src/main/java/org/apache/camel/quarkus/component/azure/storage/queue/deployment/AzureStorageQueueProcessor.java b/extensions/azure-eventhubs/deployment/src/main/java/org/apache/camel/quarkus/component/azure/eventhubs/deployment/AzureEventhubsProcessor.java
similarity index 62%
copy from extensions/azure-storage-queue/deployment/src/main/java/org/apache/camel/quarkus/component/azure/storage/queue/deployment/AzureStorageQueueProcessor.java
copy to extensions/azure-eventhubs/deployment/src/main/java/org/apache/camel/quarkus/component/azure/eventhubs/deployment/AzureEventhubsProcessor.java
index 643a9c6..b817e72 100644
--- a/extensions/azure-storage-queue/deployment/src/main/java/org/apache/camel/quarkus/component/azure/storage/queue/deployment/AzureStorageQueueProcessor.java
+++ b/extensions/azure-eventhubs/deployment/src/main/java/org/apache/camel/quarkus/component/azure/eventhubs/deployment/AzureEventhubsProcessor.java
@@ -14,9 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.apache.camel.quarkus.component.azure.storage.queue.deployment;
-
-import java.util.stream.Stream;
+package org.apache.camel.quarkus.component.azure.eventhubs.deployment;
import io.quarkus.deployment.annotations.BuildProducer;
import io.quarkus.deployment.annotations.BuildStep;
@@ -24,16 +22,14 @@ import io.quarkus.deployment.builditem.CombinedIndexBuildItem;
import io.quarkus.deployment.builditem.ExtensionSslNativeSupportBuildItem;
import io.quarkus.deployment.builditem.FeatureBuildItem;
import io.quarkus.deployment.builditem.IndexDependencyBuildItem;
-import io.quarkus.deployment.builditem.nativeimage.NativeImageProxyDefinitionBuildItem;
+import io.quarkus.deployment.builditem.nativeimage.NativeImageResourceBuildItem;
import io.quarkus.deployment.builditem.nativeimage.ReflectiveClassBuildItem;
import org.jboss.jandex.ClassInfo;
import org.jboss.jandex.DotName;
-import org.jboss.logging.Logger;
-class AzureStorageQueueProcessor {
+class AzureEventhubsProcessor {
- private static final Logger LOG = Logger.getLogger(AzureStorageQueueProcessor.class);
- private static final String FEATURE = "camel-azure-storage-queue";
+ private static final String FEATURE = "camel-azure-eventhubs";
@BuildStep
FeatureBuildItem feature() {
@@ -46,17 +42,6 @@ class AzureStorageQueueProcessor {
}
@BuildStep
- void proxyDefinitions(BuildProducer<NativeImageProxyDefinitionBuildItem> proxyDefinitions) {
- Stream.of(
- "com.azure.storage.queue.implementation.MessageIdsImpl$MessageIdsService",
- "com.azure.storage.queue.implementation.MessagesImpl$MessagesService",
- "com.azure.storage.queue.implementation.QueuesImpl$QueuesService",
- "com.azure.storage.queue.implementation.ServicesImpl$ServicesService")
- .map(NativeImageProxyDefinitionBuildItem::new)
- .forEach(proxyDefinitions::produce);
- }
-
- @BuildStep
void reflectiveClasses(CombinedIndexBuildItem combinedIndex, BuildProducer<ReflectiveClassBuildItem> reflectiveClasses) {
final String[] modelClasses = combinedIndex
@@ -65,18 +50,25 @@ class AzureStorageQueueProcessor {
.stream()
.map(ClassInfo::name)
.map(DotName::toString)
- .filter(n -> n.startsWith("com.azure.storage.queue.implementation.models.")
- || n.startsWith("com.azure.storage.queue.models."))
+ .filter(n -> n.startsWith("com.azure.messaging.eventhubs.models.")
+ || n.startsWith("com.azure.core.amqp.models."))
.sorted()
.toArray(String[]::new);
- reflectiveClasses.produce(new ReflectiveClassBuildItem(true, true, modelClasses));
-
- reflectiveClasses.produce(new ReflectiveClassBuildItem(false, false, "com.azure.core.util.DateTimeRfc1123"));
+ reflectiveClasses.produce(new ReflectiveClassBuildItem(false, true, modelClasses));
}
@BuildStep
IndexDependencyBuildItem indexDependency() {
- return new IndexDependencyBuildItem("com.azure", "azure-storage-queue");
+ return new IndexDependencyBuildItem("com.azure", "azure-messaging-eventhubs");
}
+
+ @BuildStep
+ void nativeResources(BuildProducer<NativeImageResourceBuildItem> nativeResources) {
+ nativeResources.produce(new NativeImageResourceBuildItem(
+ "azure-messaging-eventhubs.properties",
+ "eventhubs-checkpointstore-blob-messages.properties",
+ "eventhubs-messages.properties"));
+ }
+
}
diff --git a/extensions/azure-eventhubs/pom.xml b/extensions/azure-eventhubs/pom.xml
new file mode 100644
index 0000000..00234b5
--- /dev/null
+++ b/extensions/azure-eventhubs/pom.xml
@@ -0,0 +1,39 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--
+
+ 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.
+
+-->
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+ xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+ xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+ <modelVersion>4.0.0</modelVersion>
+ <parent>
+ <groupId>org.apache.camel.quarkus</groupId>
+ <artifactId>camel-quarkus-build-parent</artifactId>
+ <version>1.7.0-SNAPSHOT</version>
+ <relativePath>../../poms/build-parent/pom.xml</relativePath>
+ </parent>
+
+ <artifactId>camel-quarkus-azure-eventhubs-parent</artifactId>
+ <name>Camel Quarkus :: Azure Event Hubs</name>
+ <packaging>pom</packaging>
+
+ <modules>
+ <module>deployment</module>
+ <module>runtime</module>
+ </modules>
+</project>
diff --git a/extensions/azure-storage-queue/runtime/pom.xml b/extensions/azure-eventhubs/runtime/pom.xml
similarity index 81%
copy from extensions/azure-storage-queue/runtime/pom.xml
copy to extensions/azure-eventhubs/runtime/pom.xml
index 3217c8f..72ae078 100644
--- a/extensions/azure-storage-queue/runtime/pom.xml
+++ b/extensions/azure-eventhubs/runtime/pom.xml
@@ -17,21 +17,23 @@
limitations under the License.
-->
-<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+ xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+ xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>org.apache.camel.quarkus</groupId>
- <artifactId>camel-quarkus-azure-storage-queue-parent</artifactId>
+ <artifactId>camel-quarkus-azure-eventhubs-parent</artifactId>
<version>1.7.0-SNAPSHOT</version>
<relativePath>../pom.xml</relativePath>
</parent>
- <artifactId>camel-quarkus-azure-storage-queue</artifactId>
- <name>Camel Quarkus :: Azure Storage Queue Service :: Runtime</name>
- <description>The azure-storage-queue component is used for storing and retrieving the messages to/from Azure Storage Queue using Azure SDK v12.</description>
+ <artifactId>camel-quarkus-azure-eventhubs</artifactId>
+ <name>Camel Quarkus :: Azure Event Hubs :: Runtime</name>
+ <description>The azure-eventhubs component that integrates Azure Event Hubs using AMQP protocol. Azure EventHubs is a highly scalable publish-subscribe service that can ingest millions of events per second and stream them to multiple consumers.</description>
<properties>
- <camel.quarkus.jvmSince>1.1.0</camel.quarkus.jvmSince>
+ <camel.quarkus.jvmSince>1.7.0</camel.quarkus.jvmSince>
<camel.quarkus.nativeSince>1.7.0</camel.quarkus.nativeSince>
</properties>
@@ -54,11 +56,11 @@
</dependency>
<dependency>
<groupId>org.apache.camel.quarkus</groupId>
- <artifactId>camel-quarkus-support-reactor-netty</artifactId>
+ <artifactId>camel-quarkus-azure-storage-blob</artifactId>
</dependency>
<dependency>
<groupId>org.apache.camel</groupId>
- <artifactId>camel-azure-storage-queue</artifactId>
+ <artifactId>camel-azure-eventhubs</artifactId>
</dependency>
</dependencies>
@@ -84,6 +86,7 @@
</plugins>
</build>
+
<profiles>
<profile>
<id>full</id>
diff --git a/extensions/azure-eventhubs/runtime/src/main/resources/META-INF/quarkus-extension.yaml b/extensions/azure-eventhubs/runtime/src/main/resources/META-INF/quarkus-extension.yaml
new file mode 100644
index 0000000..d688faf
--- /dev/null
+++ b/extensions/azure-eventhubs/runtime/src/main/resources/META-INF/quarkus-extension.yaml
@@ -0,0 +1,31 @@
+#
+# 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.
+#
+
+# This is a generated file. Do not edit directly!
+# To re-generate, run the following command from the top level directory:
+#
+# mvn -N cq:update-quarkus-metadata
+#
+---
+name: "Camel Azure Event Hubs"
+description: "The azure-eventhubs component that integrates Azure Event Hubs using AMQP protocol. Azure EventHubs is a highly scalable publish-subscribe service that can ingest millions of events per second and stream them to multiple consumers"
+metadata:
+ guide: "https://camel.apache.org/camel-quarkus/latest/reference/extensions/azure-eventhubs.html"
+ categories:
+ - "integration"
+ status:
+ - "stable"
diff --git a/extensions/azure-storage-blob/deployment/pom.xml b/extensions/azure-storage-blob/deployment/pom.xml
index 669a51a..a77e270 100644
--- a/extensions/azure-storage-blob/deployment/pom.xml
+++ b/extensions/azure-storage-blob/deployment/pom.xml
@@ -36,7 +36,7 @@
</dependency>
<dependency>
<groupId>org.apache.camel.quarkus</groupId>
- <artifactId>camel-quarkus-support-reactor-netty-deployment</artifactId>
+ <artifactId>camel-quarkus-support-azure-core-deployment</artifactId>
</dependency>
<dependency>
<groupId>org.apache.camel.quarkus</groupId>
diff --git a/extensions/azure-storage-blob/deployment/src/main/java/org/apache/camel/quarkus/component/azure/storage/blob/deployment/AzureStorageBlobProcessor.java b/extensions/azure-storage-blob/deployment/src/main/java/org/apache/camel/quarkus/component/azure/storage/blob/deployment/AzureStorageBlobProcessor.java
index 218a0db..aac88dd 100644
--- a/extensions/azure-storage-blob/deployment/src/main/java/org/apache/camel/quarkus/component/azure/storage/blob/deployment/AzureStorageBlobProcessor.java
+++ b/extensions/azure-storage-blob/deployment/src/main/java/org/apache/camel/quarkus/component/azure/storage/blob/deployment/AzureStorageBlobProcessor.java
@@ -25,6 +25,7 @@ import io.quarkus.deployment.builditem.ExtensionSslNativeSupportBuildItem;
import io.quarkus.deployment.builditem.FeatureBuildItem;
import io.quarkus.deployment.builditem.IndexDependencyBuildItem;
import io.quarkus.deployment.builditem.nativeimage.NativeImageProxyDefinitionBuildItem;
+import io.quarkus.deployment.builditem.nativeimage.NativeImageResourceBuildItem;
import io.quarkus.deployment.builditem.nativeimage.ReflectiveClassBuildItem;
import org.jboss.jandex.ClassInfo;
import org.jboss.jandex.DotName;
@@ -70,9 +71,7 @@ class AzureStorageBlobProcessor {
|| n.startsWith("com.azure.storage.blob.models."))
.sorted()
.toArray(String[]::new);
- reflectiveClasses.produce(new ReflectiveClassBuildItem(true, true, modelClasses));
-
- reflectiveClasses.produce(new ReflectiveClassBuildItem(false, false, "com.azure.core.util.DateTimeRfc1123"));
+ reflectiveClasses.produce(new ReflectiveClassBuildItem(false, true, modelClasses));
}
@@ -81,4 +80,12 @@ class AzureStorageBlobProcessor {
return new IndexDependencyBuildItem("com.azure", "azure-storage-blob");
}
+ @BuildStep
+ void nativeResources(BuildProducer<NativeImageResourceBuildItem> nativeResources) {
+
+ nativeResources.produce(new NativeImageResourceBuildItem(
+ "azure-storage-blob.properties"));
+
+ }
+
}
diff --git a/extensions/azure-storage-blob/runtime/pom.xml b/extensions/azure-storage-blob/runtime/pom.xml
index 1c66c90..80648d4 100644
--- a/extensions/azure-storage-blob/runtime/pom.xml
+++ b/extensions/azure-storage-blob/runtime/pom.xml
@@ -54,7 +54,7 @@
</dependency>
<dependency>
<groupId>org.apache.camel.quarkus</groupId>
- <artifactId>camel-quarkus-support-reactor-netty</artifactId>
+ <artifactId>camel-quarkus-support-azure-core</artifactId>
</dependency>
<dependency>
<groupId>org.apache.camel</groupId>
diff --git a/extensions/azure-storage-queue/deployment/pom.xml b/extensions/azure-storage-queue/deployment/pom.xml
index 8631204..3ac42df 100644
--- a/extensions/azure-storage-queue/deployment/pom.xml
+++ b/extensions/azure-storage-queue/deployment/pom.xml
@@ -36,7 +36,7 @@
</dependency>
<dependency>
<groupId>org.apache.camel.quarkus</groupId>
- <artifactId>camel-quarkus-support-reactor-netty-deployment</artifactId>
+ <artifactId>camel-quarkus-support-azure-core-deployment</artifactId>
</dependency>
<dependency>
<groupId>org.apache.camel.quarkus</groupId>
diff --git a/extensions/azure-storage-queue/deployment/src/main/java/org/apache/camel/quarkus/component/azure/storage/queue/deployment/AzureStorageQueueProcessor.java b/extensions/azure-storage-queue/deployment/src/main/java/org/apache/camel/quarkus/component/azure/storage/queue/deployment/AzureStorageQueueProcessor.java
index 643a9c6..652f127 100644
--- a/extensions/azure-storage-queue/deployment/src/main/java/org/apache/camel/quarkus/component/azure/storage/queue/deployment/AzureStorageQueueProcessor.java
+++ b/extensions/azure-storage-queue/deployment/src/main/java/org/apache/camel/quarkus/component/azure/storage/queue/deployment/AzureStorageQueueProcessor.java
@@ -69,9 +69,7 @@ class AzureStorageQueueProcessor {
|| n.startsWith("com.azure.storage.queue.models."))
.sorted()
.toArray(String[]::new);
- reflectiveClasses.produce(new ReflectiveClassBuildItem(true, true, modelClasses));
-
- reflectiveClasses.produce(new ReflectiveClassBuildItem(false, false, "com.azure.core.util.DateTimeRfc1123"));
+ reflectiveClasses.produce(new ReflectiveClassBuildItem(false, true, modelClasses));
}
diff --git a/extensions/azure-storage-queue/runtime/pom.xml b/extensions/azure-storage-queue/runtime/pom.xml
index 3217c8f..f364d37 100644
--- a/extensions/azure-storage-queue/runtime/pom.xml
+++ b/extensions/azure-storage-queue/runtime/pom.xml
@@ -54,7 +54,7 @@
</dependency>
<dependency>
<groupId>org.apache.camel.quarkus</groupId>
- <artifactId>camel-quarkus-support-reactor-netty</artifactId>
+ <artifactId>camel-quarkus-support-azure-core</artifactId>
</dependency>
<dependency>
<groupId>org.apache.camel</groupId>
diff --git a/extensions/pom.xml b/extensions/pom.xml
index 523e3fa..4aae82a 100644
--- a/extensions/pom.xml
+++ b/extensions/pom.xml
@@ -74,6 +74,7 @@
<module>aws2-sts</module>
<module>aws2-translate</module>
<module>azure</module>
+ <module>azure-eventhubs</module>
<module>azure-storage-blob</module>
<module>azure-storage-queue</module>
<module>base64</module>
diff --git a/integration-tests/azure-eventhubs/README.adoc b/integration-tests/azure-eventhubs/README.adoc
new file mode 100644
index 0000000..452c326
--- /dev/null
+++ b/integration-tests/azure-eventhubs/README.adoc
@@ -0,0 +1,18 @@
+== Azure Event Hubs Service integration tests
+
+By default the integration tests run only against the real remote Azure API.
+
+Prerequisites:
+
+* A https://docs.microsoft.com/en-us/azure/storage/common/storage-account-create?toc=%2Fazure%2Fstorage%2Fblobs%2Ftoc.json&tabs=azure-portal[general-purpose v2 Azure storage account] and [create a container]
+* An https://docs.microsoft.com/en-us/azure/event-hubs/event-hubs-create[Azure Event Hub]
+* An https://docs.microsoft.com/en-us/azure/event-hubs/event-hubs-get-connection-string[Event Hubs connection string] and set the following environment variables:
++
+[source,shell]
+----
+export AZURE_STORAGE_ACCOUNT_NAME=<your-azure-storage-account-name>
+export AZURE_STORAGE_ACCOUNT_KEY=<your-azure-storage-account-key>
+# the container has to exist before you run the test
+export AZURE_BLOB_CONTAINER_NAME=<your-container-name>
+export AZURE_EVENT_HUBS_CONNECTION_STRING="Endpoint=sb://<your-namespace>.servicebus.windows.net/;SharedAccessKeyName=RootManageSharedAccessKey;SharedAccessKey=<your-key>;EntityPath=<your-hub-name>"
+----
diff --git a/integration-tests/azure-eventhubs/pom.xml b/integration-tests/azure-eventhubs/pom.xml
new file mode 100644
index 0000000..ba18caa
--- /dev/null
+++ b/integration-tests/azure-eventhubs/pom.xml
@@ -0,0 +1,137 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--
+
+ 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.
+
+-->
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+ xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+ xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+ <modelVersion>4.0.0</modelVersion>
+ <parent>
+ <groupId>org.apache.camel.quarkus</groupId>
+ <artifactId>camel-quarkus-integration-tests</artifactId>
+ <version>1.7.0-SNAPSHOT</version>
+ <relativePath>../pom.xml</relativePath>
+ </parent>
+
+ <artifactId>camel-quarkus-integration-test-azure-eventhubs</artifactId>
+ <name>Camel Quarkus :: Integration Tests :: Azure Event Hubs</name>
+ <description>Integration tests for Camel Quarkus Azure Event Hubs extension</description>
+
+ <dependencyManagement>
+ <dependencies>
+ <dependency>
+ <groupId>org.apache.camel.quarkus</groupId>
+ <artifactId>camel-quarkus-bom-test</artifactId>
+ <version>${project.version}</version>
+ <type>pom</type>
+ <scope>import</scope>
+ </dependency>
+ </dependencies>
+ </dependencyManagement>
+
+ <dependencies>
+ <dependency>
+ <groupId>org.apache.camel.quarkus</groupId>
+ <artifactId>camel-quarkus-azure-eventhubs</artifactId>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.camel.quarkus</groupId>
+ <artifactId>camel-quarkus-main</artifactId>
+ </dependency>
+ <dependency>
+ <groupId>io.quarkus</groupId>
+ <artifactId>quarkus-resteasy</artifactId>
+ </dependency>
+
+ <!-- test dependencies -->
+ <dependency>
+ <groupId>io.quarkus</groupId>
+ <artifactId>quarkus-junit5</artifactId>
+ <scope>test</scope>
+ </dependency>
+ <dependency>
+ <groupId>io.rest-assured</groupId>
+ <artifactId>rest-assured</artifactId>
+ <scope>test</scope>
+ </dependency>
+ <dependency>
+ <groupId>org.awaitility</groupId>
+ <artifactId>awaitility</artifactId>
+ <scope>test</scope>
+ </dependency>
+
+ <!-- The following dependencies guarantee that this module is built after them. You can update them by running `mvn process-resources -Pformat -N` from the source tree root directory -->
+ <dependency>
+ <groupId>org.apache.camel.quarkus</groupId>
+ <artifactId>camel-quarkus-azure-eventhubs-deployment</artifactId>
+ <version>${project.version}</version>
+ <type>pom</type>
+ <scope>test</scope>
+ <exclusions>
+ <exclusion>
+ <groupId>*</groupId>
+ <artifactId>*</artifactId>
+ </exclusion>
+ </exclusions>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.camel.quarkus</groupId>
+ <artifactId>camel-quarkus-main-deployment</artifactId>
+ <version>${project.version}</version>
+ <type>pom</type>
+ <scope>test</scope>
+ <exclusions>
+ <exclusion>
+ <groupId>*</groupId>
+ <artifactId>*</artifactId>
+ </exclusion>
+ </exclusions>
+ </dependency>
+ </dependencies>
+
+ <profiles>
+ <profile>
+ <id>native</id>
+ <activation>
+ <property>
+ <name>native</name>
+ </property>
+ </activation>
+ <properties>
+ <quarkus.package.type>native</quarkus.package.type>
+ </properties>
+ <build>
+ <plugins>
+ <plugin>
+ <groupId>org.apache.maven.plugins</groupId>
+ <artifactId>maven-failsafe-plugin</artifactId>
+ <executions>
+ <execution>
+ <goals>
+ <goal>integration-test</goal>
+ <goal>verify</goal>
+ </goals>
+ </execution>
+ </executions>
+ </plugin>
+ </plugins>
+ </build>
+ </profile>
+ </profiles>
+
+</project>
diff --git a/integration-tests/azure-eventhubs/src/main/java/org/apache/camel/quarkus/component/azure/eventhubs/it/AzureEventhubsResource.java b/integration-tests/azure-eventhubs/src/main/java/org/apache/camel/quarkus/component/azure/eventhubs/it/AzureEventhubsResource.java
new file mode 100644
index 0000000..a19aeb8
--- /dev/null
+++ b/integration-tests/azure-eventhubs/src/main/java/org/apache/camel/quarkus/component/azure/eventhubs/it/AzureEventhubsResource.java
@@ -0,0 +1,83 @@
+/*
+ * 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.
+ */
+package org.apache.camel.quarkus.component.azure.eventhubs.it;
+
+import java.net.URI;
+
+import javax.enterprise.context.ApplicationScoped;
+import javax.inject.Inject;
+import javax.ws.rs.Consumes;
+import javax.ws.rs.GET;
+import javax.ws.rs.POST;
+import javax.ws.rs.Path;
+import javax.ws.rs.Produces;
+import javax.ws.rs.core.MediaType;
+import javax.ws.rs.core.Response;
+
+import org.apache.camel.ConsumerTemplate;
+import org.apache.camel.ProducerTemplate;
+import org.eclipse.microprofile.config.inject.ConfigProperty;
+
+@Path("/azure-eventhubs")
+@ApplicationScoped
+public class AzureEventhubsResource {
+
+ @Inject
+ ProducerTemplate producerTemplate;
+
+ @Inject
+ ConsumerTemplate consumerTemplate;
+
+ @ConfigProperty(name = "azure.storage.account-name")
+ String azureStorageAccountName;
+
+ @ConfigProperty(name = "azure.storage.account-key")
+ String azureStorageAccountKey;
+
+ @ConfigProperty(name = "azure.event.hubs.connection.string")
+ String connectionString;
+
+ @ConfigProperty(name = "azure.blob.container.name")
+ String azureBlobContainerName;
+
+ @Path("/receive-events")
+ @GET
+ @Produces(MediaType.TEXT_PLAIN)
+ public String receiveEvents() throws Exception {
+
+ final String endpointUri = "azure-eventhubs:?connectionString=RAW(" + connectionString
+ + ")&blobAccountName=RAW(" + azureStorageAccountName
+ + ")&blobAccessKey=RAW(" + azureStorageAccountKey
+ + ")&blobContainerName=RAW(" + azureBlobContainerName + ")";
+ return consumerTemplate.receiveBody(endpointUri,
+ 10000L,
+ String.class);
+ }
+
+ @Path("/send-events")
+ @POST
+ @Produces(MediaType.TEXT_PLAIN)
+ @Consumes(MediaType.TEXT_PLAIN)
+ public Response sendEvents(String body) throws Exception {
+
+ final String endpointUri = "azure-eventhubs:?connectionString=RAW(" + connectionString + ")";
+
+ producerTemplate.sendBody(endpointUri, body);
+ return Response.created(new URI("https://camel.apache.org/")).build();
+ }
+
+}
diff --git a/integration-tests/azure-eventhubs/src/test/java/org/apache/camel/quarkus/component/azure/eventhubs/it/AzureEventhubsIT.java b/integration-tests/azure-eventhubs/src/test/java/org/apache/camel/quarkus/component/azure/eventhubs/it/AzureEventhubsIT.java
new file mode 100644
index 0000000..d0f0c0f
--- /dev/null
+++ b/integration-tests/azure-eventhubs/src/test/java/org/apache/camel/quarkus/component/azure/eventhubs/it/AzureEventhubsIT.java
@@ -0,0 +1,29 @@
+/*
+ * 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.
+ */
+package org.apache.camel.quarkus.component.azure.eventhubs.it;
+
+import io.quarkus.test.junit.NativeImageTest;
+import org.junit.jupiter.api.condition.EnabledIfEnvironmentVariable;
+
+@EnabledIfEnvironmentVariable(named = "AZURE_STORAGE_ACCOUNT_NAME", matches = ".+")
+@EnabledIfEnvironmentVariable(named = "AZURE_STORAGE_ACCOUNT_KEY", matches = ".+")
+@EnabledIfEnvironmentVariable(named = "AZURE_BLOB_CONTAINER_NAME", matches = ".+")
+@EnabledIfEnvironmentVariable(named = "AZURE_EVENT_HUBS_CONNECTION_STRING", matches = ".+")
+@NativeImageTest
+class AzureEventhubsIT extends AzureEventhubsTest {
+
+}
diff --git a/integration-tests/azure-eventhubs/src/test/java/org/apache/camel/quarkus/component/azure/eventhubs/it/AzureEventhubsTest.java b/integration-tests/azure-eventhubs/src/test/java/org/apache/camel/quarkus/component/azure/eventhubs/it/AzureEventhubsTest.java
new file mode 100644
index 0000000..1f26173
--- /dev/null
+++ b/integration-tests/azure-eventhubs/src/test/java/org/apache/camel/quarkus/component/azure/eventhubs/it/AzureEventhubsTest.java
@@ -0,0 +1,60 @@
+/*
+ * 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.
+ */
+package org.apache.camel.quarkus.component.azure.eventhubs.it;
+
+import java.util.concurrent.TimeUnit;
+
+import io.quarkus.test.junit.QuarkusTest;
+import io.restassured.RestAssured;
+import io.restassured.http.ContentType;
+import org.apache.commons.lang3.RandomStringUtils;
+import org.awaitility.Awaitility;
+import org.jboss.logging.Logger;
+import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.condition.EnabledIfEnvironmentVariable;
+
+@EnabledIfEnvironmentVariable(named = "AZURE_STORAGE_ACCOUNT_NAME", matches = ".+")
+@EnabledIfEnvironmentVariable(named = "AZURE_STORAGE_ACCOUNT_KEY", matches = ".+")
+@EnabledIfEnvironmentVariable(named = "AZURE_BLOB_CONTAINER_NAME", matches = ".+")
+@EnabledIfEnvironmentVariable(named = "AZURE_EVENT_HUBS_CONNECTION_STRING", matches = ".+")
+@QuarkusTest
+class AzureEventhubsTest {
+
+ private static final Logger LOG = Logger.getLogger(AzureEventhubsTest.class);
+
+ @Test
+ public void roundTrip() {
+ final String messageBody = RandomStringUtils.randomAlphabetic(30);
+
+ RestAssured.given()
+ .contentType(ContentType.TEXT)
+ .body(messageBody)
+ .post("/azure-eventhubs/send-events")
+ .then()
+ .statusCode(201);
+
+ Awaitility.await().pollInterval(1, TimeUnit.SECONDS).atMost(120, TimeUnit.SECONDS).until(() -> {
+ final String body = RestAssured.given()
+ .get("/azure-eventhubs/receive-events")
+ .then()
+ .extract().body().asString();
+ LOG.infof("Expected message body: '%s'; actual: '%s'", messageBody, body);
+ return body != null && body.contains(messageBody);
+ });
+
+ }
+}
diff --git a/integration-tests/pom.xml b/integration-tests/pom.xml
index 4c8ac12..be1b53c 100644
--- a/integration-tests/pom.xml
+++ b/integration-tests/pom.xml
@@ -69,6 +69,7 @@
<module>aws</module>
<module>aws2</module>
<module>azure</module>
+ <module>azure-eventhubs</module>
<module>azure-storage-blob</module>
<module>azure-storage-queue</module>
<module>base64</module>
diff --git a/pom.xml b/pom.xml
index 4602446..59c3e29 100644
--- a/pom.xml
+++ b/pom.xml
@@ -43,6 +43,14 @@
<antlr3.version>3.5.2</antlr3.version><!-- Spark, Stringtemplate and probably others -->
<avro.version>${avro-version}</avro.version>
<awssdk1-swf-libs.version>1.11.22</awssdk1-swf-libs.version>
+ <!-- TODO: Use azure-sdk-bom once they start maintaining it properly https://github.com/Azure/azure-sdk-for-java/issues/18759 -->
+ <azure-core.version>1.8.1</azure-core.version><!-- keep compatible with the azure artifacts below -->
+ <azure-sdk-bom.version>1.0.1</azure-sdk-bom.version>
+ <azure-storage-blob-java-sdk12.version>${azure-storage-blob-java-sdk12-version}</azure-storage-blob-java-sdk12.version>
+ <azure-storage-queue-java-sdk12.version>${azure-storage-queue-java-sdk12-version}</azure-storage-queue-java-sdk12.version>
+ <azure-eventhubs-java.version>${azure-eventhubs-java-version}</azure-eventhubs-java.version>
+ <azure-eventhubs-checkpointstore-blob.version>${azure-eventhubs-checkpointstore-blob-version}</azure-eventhubs-checkpointstore-blob.version>
+
<bouncycastle.version>${bouncycastle-version}</bouncycastle.version><!-- keep in sync with Camel -->
<camel.major.minor>3.7</camel.major.minor> <!-- run after each change: cd docs && mvndev validate -->
@@ -97,6 +105,8 @@
<quarkus-hazelcast-client.version>1.1.1</quarkus-hazelcast-client.version>
<quarkus-qpid-jms.version>0.22.0</quarkus-qpid-jms.version>
<protobuf.version>${protobuf-version}</protobuf.version>
+ <reactor-core.version>3.3.13.RELEASE</reactor-core.version>
+ <reactor-netty.version>0.9.16.RELEASE</reactor-netty.version><!-- A newer micro than the one in azure-sdk-bom required by camel-quarkus-azure-eventhubs -->
<retrofit.version>2.5.0</retrofit.version>
<scala-2.11.version>2.11.12</scala-2.11.version><!-- Spark -->
<smallrye.reactive.messaging.camel.version>2.7.1</smallrye.reactive.messaging.camel.version> <!-- keep in sync with Quarkus SmallRye Reactive Messaging -->
diff --git a/poms/bom/pom.xml b/poms/bom/pom.xml
index c0b92b8..a47d5bb 100644
--- a/poms/bom/pom.xml
+++ b/poms/bom/pom.xml
@@ -62,8 +62,6 @@
<scope>import</scope>
</dependency>
-
-
<!-- Dependencies a..z; do not remove this comment, it is important when sorting via mvn process-resources -Pformat -->
<!--$ org.apache.camel $-->
@@ -481,13 +479,36 @@
</dependency>
<dependency>
<groupId>org.apache.camel</groupId>
+ <artifactId>camel-azure-eventhubs</artifactId>
+ <version>${camel.version}</version>
+ <exclusions>
+ <exclusion>
+ <groupId>io.netty</groupId>
+ <artifactId>netty-tcnative-boringssl-static</artifactId>
+ </exclusion>
+ </exclusions>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.camel</groupId>
<artifactId>camel-azure-storage-blob</artifactId>
<version>${camel.version}</version>
+ <exclusions>
+ <exclusion>
+ <groupId>io.netty</groupId>
+ <artifactId>netty-tcnative-boringssl-static</artifactId>
+ </exclusion>
+ </exclusions>
</dependency>
<dependency>
<groupId>org.apache.camel</groupId>
<artifactId>camel-azure-storage-queue</artifactId>
<version>${camel.version}</version>
+ <exclusions>
+ <exclusion>
+ <groupId>io.netty</groupId>
+ <artifactId>netty-tcnative-boringssl-static</artifactId>
+ </exclusion>
+ </exclusions>
</dependency>
<dependency>
<groupId>org.apache.camel</groupId>
@@ -2619,6 +2640,16 @@
</dependency>
<dependency>
<groupId>org.apache.camel.quarkus</groupId>
+ <artifactId>camel-quarkus-azure-eventhubs</artifactId>
+ <version>${camel-quarkus.version}</version>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.camel.quarkus</groupId>
+ <artifactId>camel-quarkus-azure-eventhubs-deployment</artifactId>
+ <version>${camel-quarkus.version}</version>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.camel.quarkus</groupId>
<artifactId>camel-quarkus-azure-storage-blob</artifactId>
<version>${camel-quarkus.version}</version>
</dependency>
@@ -4834,6 +4865,16 @@
</dependency>
<dependency>
<groupId>org.apache.camel.quarkus</groupId>
+ <artifactId>camel-quarkus-support-azure-core</artifactId>
+ <version>${camel-quarkus.version}</version>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.camel.quarkus</groupId>
+ <artifactId>camel-quarkus-support-azure-core-deployment</artifactId>
+ <version>${camel-quarkus.version}</version>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.camel.quarkus</groupId>
<artifactId>camel-quarkus-support-bouncycastle</artifactId>
<version>${camel-quarkus.version}</version>
</dependency>
@@ -5451,6 +5492,37 @@
</exclusions>
</dependency>
<dependency>
+ <groupId>com.azure</groupId>
+ <artifactId>azure-core</artifactId>
+ <version>${azure-core.version}</version>
+ <exclusions>
+ <exclusion>
+ <groupId>io.netty</groupId>
+ <artifactId>netty-tcnative-boringssl-static</artifactId>
+ </exclusion>
+ </exclusions>
+ </dependency>
+ <dependency>
+ <groupId>com.azure</groupId>
+ <artifactId>azure-messaging-eventhubs</artifactId>
+ <version>${azure-eventhubs-java.version}</version>
+ </dependency>
+ <dependency>
+ <groupId>com.azure</groupId>
+ <artifactId>azure-messaging-eventhubs-checkpointstore-blob</artifactId>
+ <version>${azure-eventhubs-checkpointstore-blob.version}</version>
+ </dependency>
+ <dependency>
+ <groupId>com.azure</groupId>
+ <artifactId>azure-storage-blob</artifactId>
+ <version>${azure-storage-blob-java-sdk12.version}</version>
+ </dependency>
+ <dependency>
+ <groupId>com.azure</groupId>
+ <artifactId>azure-storage-queue</artifactId>
+ <version>${azure-storage-queue-java-sdk12-version}</version>
+ </dependency>
+ <dependency>
<groupId>com.fasterxml.woodstox</groupId>
<artifactId>woodstox-core</artifactId>
<version>${woodstox-core.version}</version>
@@ -5644,6 +5716,16 @@
<version>${debezium.version}</version>
</dependency>
<dependency>
+ <groupId>io.projectreactor</groupId>
+ <artifactId>reactor-core</artifactId>
+ <version>${reactor-core.version}</version>
+ </dependency>
+ <dependency>
+ <groupId>io.projectreactor.netty</groupId>
+ <artifactId>reactor-netty</artifactId>
+ <version>${reactor-netty.version}</version>
+ </dependency>
+ <dependency>
<groupId>io.quarkiverse.googlecloudservices</groupId>
<artifactId>quarkus-google-cloud-bigquery</artifactId>
<version>${quarkus-google-cloud.version}</version>
diff --git a/tooling/scripts/test-categories.yaml b/tooling/scripts/test-categories.yaml
index 2b5fa9e..e750fb3 100644
--- a/tooling/scripts/test-categories.yaml
+++ b/tooling/scripts/test-categories.yaml
@@ -108,9 +108,9 @@ dozer-social-azure:
- master
- syndication
- zendesk
- - csimple
- azure-storage-blob
- azure-storage-queue
+ - azure-eventhubs
messaging-networking1:
- activemq
- amqp
@@ -160,6 +160,7 @@ platform:
- reactive-streams
- rest
- rest-openapi
+ - csimple
saas:
- box
- github