Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Atomix, AWS 2 Kinesis, AWS 2 Lambda, Azure Storage Blob and Azure Storage Queue JVM support #1569

Merged
merged 5 commits into from
Aug 24, 2020
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Jump to
Jump to file
Failed to load files.
Diff view
Diff view
5 changes: 5 additions & 0 deletions catalog/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -46,6 +46,7 @@
camel-quarkus-asterisk
camel-quarkus-atmos
camel-quarkus-atom
camel-quarkus-atomix
camel-quarkus-attachments
camel-quarkus-avro
camel-quarkus-avro-rpc
Expand All @@ -69,7 +70,9 @@
camel-quarkus-aws2-ecs
camel-quarkus-aws2-eks
camel-quarkus-aws2-iam
camel-quarkus-aws2-kinesis
camel-quarkus-aws2-kms
camel-quarkus-aws2-lambda
camel-quarkus-aws2-mq
camel-quarkus-aws2-msk
camel-quarkus-aws2-s3
Expand All @@ -78,6 +81,8 @@
camel-quarkus-aws2-sqs
camel-quarkus-aws2-translate
camel-quarkus-azure
camel-quarkus-azure-storage-blob
camel-quarkus-azure-storage-queue
camel-quarkus-base64
camel-quarkus-bean
camel-quarkus-bean-validator
Expand Down
5 changes: 5 additions & 0 deletions docs/modules/ROOT/nav.adoc
Original file line number Diff line number Diff line change
Expand Up @@ -22,6 +22,7 @@
*** xref:reference/extensions/ahc-ws.adoc[Async HTTP Client (AHC) Websocket]
*** xref:reference/extensions/atmos.adoc[Atmos]
*** xref:reference/extensions/atom.adoc[Atom]
*** xref:reference/extensions/atomix.adoc[Atomix Map]
*** xref:reference/extensions/attachments.adoc[Attachments]
*** xref:reference/extensions/avro.adoc[Avro]
*** xref:reference/extensions/avro-rpc.adoc[Avro RPC]
Expand All @@ -33,6 +34,8 @@
*** xref:reference/extensions/aws2-eks.adoc[AWS 2 Elastic Kubernetes Service (EKS)]
*** xref:reference/extensions/aws2-iam.adoc[AWS 2 Identity and Access Management (IAM)]
*** xref:reference/extensions/aws2-kms.adoc[AWS 2 Key Management Service (KMS)]
*** xref:reference/extensions/aws2-kinesis.adoc[AWS 2 Kinesis]
*** xref:reference/extensions/aws2-lambda.adoc[AWS 2 Lambda]
*** xref:reference/extensions/aws2-msk.adoc[AWS 2 Managed Streaming for Apache Kafka (MSK)]
*** xref:reference/extensions/aws2-mq.adoc[AWS 2 MQ]
*** xref:reference/extensions/aws2-s3.adoc[AWS 2 S3 Storage Service]
Expand All @@ -54,6 +57,8 @@
*** xref:reference/extensions/aws-sdb.adoc[AWS SimpleDB]
*** xref:reference/extensions/aws-translate.adoc[AWS Translate]
*** xref:reference/extensions/azure.adoc[Azure]
*** xref:reference/extensions/azure-storage-blob.adoc[Azure Storage Blob Service]
*** xref:reference/extensions/azure-storage-queue.adoc[Azure Storage Queue Service]
*** xref:reference/extensions/base64.adoc[Base64]
*** xref:reference/extensions/bean.adoc[Bean]
*** xref:reference/extensions/bean-validator.adoc[Bean Validator]
Expand Down
33 changes: 33 additions & 0 deletions docs/modules/ROOT/pages/reference/components.adoc
Original file line number Diff line number Diff line change
Expand Up @@ -34,6 +34,24 @@ Preview | 1.1.0 | Integract with EMC's ViPR object data services using the Atmos
| xref:reference/extensions/atom.adoc[Atom] | [.camel-element-artifact]##camel-quarkus-atom## | [.camel-element-JVM]##JVM## +
Preview | 1.1.0 | Poll Atom RSS feeds.

| xref:reference/extensions/atomix.adoc[Atomix Map] | [.camel-element-artifact]##camel-quarkus-atomix## | [.camel-element-JVM]##JVM## +
Preview | 1.1.0 | Access Atomix's distributed map.

| xref:reference/extensions/atomix.adoc[Atomix Messaging] | [.camel-element-artifact]##camel-quarkus-atomix## | [.camel-element-JVM]##JVM## +
Preview | 1.1.0 | Access Atomix's group messaging.

| xref:reference/extensions/atomix.adoc[Atomix MultiMap] | [.camel-element-artifact]##camel-quarkus-atomix## | [.camel-element-JVM]##JVM## +
Preview | 1.1.0 | Access Atomix's distributed multi map.

| xref:reference/extensions/atomix.adoc[Atomix Queue] | [.camel-element-artifact]##camel-quarkus-atomix## | [.camel-element-JVM]##JVM## +
Preview | 1.1.0 | Access Atomix's distributed queue.

| xref:reference/extensions/atomix.adoc[Atomix Set] | [.camel-element-artifact]##camel-quarkus-atomix## | [.camel-element-JVM]##JVM## +
Preview | 1.1.0 | Access Atomix's distributed set.

| xref:reference/extensions/atomix.adoc[Atomix Value] | [.camel-element-artifact]##camel-quarkus-atomix## | [.camel-element-JVM]##JVM## +
Preview | 1.1.0 | Access Atomix's distributed value.

| xref:reference/extensions/avro-rpc.adoc[Avro RPC] | [.camel-element-artifact]##camel-quarkus-avro-rpc## | [.camel-element-JVM]##JVM## +
Preview | 1.0.0 | Produce or consume Apache Avro RPC services.

Expand Down Expand Up @@ -64,6 +82,15 @@ Stable | 1.0.0 | Manage AWS IAM instances using AWS SDK version 2.x.
| xref:reference/extensions/aws2-kms.adoc[AWS 2 Key Management Service (KMS)] | [.camel-element-artifact]##camel-quarkus-aws2-kms## | [.camel-element-Native]##Native## +
Stable | 1.0.0 | Manage keys stored in AWS KMS instances using AWS SDK version 2.x.

| xref:reference/extensions/aws2-kinesis.adoc[AWS 2 Kinesis] | [.camel-element-artifact]##camel-quarkus-aws2-kinesis## | [.camel-element-JVM]##JVM## +
Preview | 1.1.0 | Consume and produce records from AWS Kinesis Streams using AWS SDK version 2.x.

| xref:reference/extensions/aws2-kinesis.adoc[AWS 2 Kinesis Firehose] | [.camel-element-artifact]##camel-quarkus-aws2-kinesis## | [.camel-element-JVM]##JVM## +
Preview | 1.1.0 | Consume data from AWS Kinesis Firehose streams using AWS SDK version 2.x.

| xref:reference/extensions/aws2-lambda.adoc[AWS 2 Lambda] | [.camel-element-artifact]##camel-quarkus-aws2-lambda## | [.camel-element-JVM]##JVM## +
Preview | 1.1.0 | Manage and invoke AWS Lambda functions using AWS SDK version 2.x.

| xref:reference/extensions/aws2-msk.adoc[AWS 2 Managed Streaming for Apache Kafka (MSK)] | [.camel-element-artifact]##camel-quarkus-aws2-msk## | [.camel-element-Native]##Native## +
Stable | 1.0.0 | Manage AWS MSK instances using AWS SDK version 2.x.

Expand Down Expand Up @@ -127,9 +154,15 @@ Stable | 1.0.0 | Store and Retrieve data from/to AWS SDB service.
| xref:reference/extensions/aws-translate.adoc[AWS Translate] | [.camel-element-artifact]##camel-quarkus-aws-translate## | [.camel-element-Native]##Native## +
Stable | 1.0.0 | Translate texts using AWS Translate.

| xref:reference/extensions/azure-storage-blob.adoc[Azure Storage Blob Service] | [.camel-element-artifact]##camel-quarkus-azure-storage-blob## | [.camel-element-JVM]##JVM## +
Preview | 1.1.0 | Store and retrieve blobs from Azure Storage Blob Service using SDK v12.

| xref:reference/extensions/azure.adoc[Azure Storage Blob Service (Legacy)] | [.camel-element-artifact]##camel-quarkus-azure## | [.camel-element-Native]##Native## +
Stable | 1.0.0 | Store and retrieve blobs from Azure Storage Blob Service.

| xref:reference/extensions/azure-storage-queue.adoc[Azure Storage Queue Service] | [.camel-element-artifact]##camel-quarkus-azure-storage-queue## | [.camel-element-JVM]##JVM## +
Preview | 1.1.0 | The azure-storage-queue component is used for storing and retrieving the messages to/from Azure Storage Queue using Azure SDK v12.

| xref:reference/extensions/azure.adoc[Azure Storage Queue Service (Legacy)] | [.camel-element-artifact]##camel-quarkus-azure## | [.camel-element-Native]##Native## +
Stable | 1.0.0 | Store and retrieve messages from Azure Storage Queue Service.

Expand Down
34 changes: 34 additions & 0 deletions docs/modules/ROOT/pages/reference/extensions/atomix.adoc
Original file line number Diff line number Diff line change
@@ -0,0 +1,34 @@
// Do not edit directly!
// This file was generated by camel-quarkus-maven-plugin:update-extension-doc-page

[[atomix]]
= Atomix Map
:page-aliases: extensions/atomix.adoc

[.badges]
[.badge-key]##Since Camel Quarkus##[.badge-version]##1.1.0## [.badge-key]##JVM##[.badge-supported]##supported## [.badge-key]##Native##[.badge-unsupported]##unsupported##

Access Atomix's distributed map.

== What's inside

* https://camel.apache.org/components/latest/atomix-map-component.html[Atomix Map component], URI syntax: `atomix-map:resourceName`
* https://camel.apache.org/components/latest/atomix-messaging-component.html[Atomix Messaging component], URI syntax: `atomix-messaging:resourceName`
* https://camel.apache.org/components/latest/atomix-multimap-component.html[Atomix MultiMap component], URI syntax: `atomix-multimap:resourceName`
* https://camel.apache.org/components/latest/atomix-queue-component.html[Atomix Queue component], URI syntax: `atomix-queue:resourceName`
* https://camel.apache.org/components/latest/atomix-set-component.html[Atomix Set component], URI syntax: `atomix-set:resourceName`
* https://camel.apache.org/components/latest/atomix-value-component.html[Atomix Value component], URI syntax: `atomix-value:resourceName`

Please refer to the above links for usage and configuration details.

== Maven coordinates

[source,xml]
----
<dependency>
<groupId>org.apache.camel.quarkus</groupId>
<artifactId>camel-quarkus-atomix</artifactId>
</dependency>
----

Check the xref:user-guide/index.adoc[User guide] for more information about writing Camel Quarkus applications.
30 changes: 30 additions & 0 deletions docs/modules/ROOT/pages/reference/extensions/aws2-kinesis.adoc
Original file line number Diff line number Diff line change
@@ -0,0 +1,30 @@
// Do not edit directly!
// This file was generated by camel-quarkus-maven-plugin:update-extension-doc-page

[[aws2-kinesis]]
= AWS 2 Kinesis
:page-aliases: extensions/aws2-kinesis.adoc

[.badges]
[.badge-key]##Since Camel Quarkus##[.badge-version]##1.1.0## [.badge-key]##JVM##[.badge-supported]##supported## [.badge-key]##Native##[.badge-unsupported]##unsupported##

Consume and produce records from AWS Kinesis Streams using AWS SDK version 2.x.

== What's inside

* https://camel.apache.org/components/latest/aws2-kinesis-component.html[AWS 2 Kinesis component], URI syntax: `aws2-kinesis:streamName`
* https://camel.apache.org/components/latest/aws2-kinesis-firehose-component.html[AWS 2 Kinesis Firehose component], URI syntax: `aws2-kinesis-firehose:streamName`

Please refer to the above links for usage and configuration details.

== Maven coordinates

[source,xml]
----
<dependency>
<groupId>org.apache.camel.quarkus</groupId>
<artifactId>camel-quarkus-aws2-kinesis</artifactId>
</dependency>
----

Check the xref:user-guide/index.adoc[User guide] for more information about writing Camel Quarkus applications.
29 changes: 29 additions & 0 deletions docs/modules/ROOT/pages/reference/extensions/aws2-lambda.adoc
Original file line number Diff line number Diff line change
@@ -0,0 +1,29 @@
// Do not edit directly!
// This file was generated by camel-quarkus-maven-plugin:update-extension-doc-page

[[aws2-lambda]]
= AWS 2 Lambda
:page-aliases: extensions/aws2-lambda.adoc

[.badges]
[.badge-key]##Since Camel Quarkus##[.badge-version]##1.1.0## [.badge-key]##JVM##[.badge-supported]##supported## [.badge-key]##Native##[.badge-unsupported]##unsupported##

Manage and invoke AWS Lambda functions using AWS SDK version 2.x.

== What's inside

* https://camel.apache.org/components/latest/aws2-lambda-component.html[AWS 2 Lambda component], URI syntax: `aws2-lambda:function`

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-aws2-lambda</artifactId>
</dependency>
----

Check the xref:user-guide/index.adoc[User guide] for more information about writing Camel Quarkus applications.
Original file line number Diff line number Diff line change
@@ -0,0 +1,29 @@
// Do not edit directly!
// This file was generated by camel-quarkus-maven-plugin:update-extension-doc-page

[[azure-storage-blob]]
= Azure Storage Blob Service
:page-aliases: extensions/azure-storage-blob.adoc

[.badges]
[.badge-key]##Since Camel Quarkus##[.badge-version]##1.1.0## [.badge-key]##JVM##[.badge-supported]##supported## [.badge-key]##Native##[.badge-unsupported]##unsupported##

Store and retrieve blobs from Azure Storage Blob Service using SDK v12.

== What's inside

* https://camel.apache.org/components/latest/azure-storage-blob-component.html[Azure Storage Blob Service component], URI syntax: `azure-storage-blob:containerName`

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-storage-blob</artifactId>
</dependency>
----

Check the xref:user-guide/index.adoc[User guide] for more information about writing Camel Quarkus applications.
Original file line number Diff line number Diff line change
@@ -0,0 +1,29 @@
// Do not edit directly!
// This file was generated by camel-quarkus-maven-plugin:update-extension-doc-page

[[azure-storage-queue]]
= Azure Storage Queue Service
:page-aliases: extensions/azure-storage-queue.adoc

[.badges]
[.badge-key]##Since Camel Quarkus##[.badge-version]##1.1.0## [.badge-key]##JVM##[.badge-supported]##supported## [.badge-key]##Native##[.badge-unsupported]##unsupported##

The azure-storage-queue component is used for storing and retrieving the messages to/from Azure Storage Queue using Azure SDK v12.

== What's inside

* https://camel.apache.org/components/latest/azure-storage-queue-component.html[Azure Storage Queue Service component], URI syntax: `azure-storage-queue:queueName`

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-storage-queue</artifactId>
</dependency>
----

Check the xref:user-guide/index.adoc[User guide] for more information about writing Camel Quarkus applications.
15 changes: 15 additions & 0 deletions docs/modules/ROOT/pages/reference/index.adoc
Original file line number Diff line number Diff line change
Expand Up @@ -47,6 +47,9 @@ Preview | 1.1.0 | Integract with EMC's ViPR object data services using the Atmos
| xref:reference/extensions/atom.adoc[Atom] | camel-quarkus-atom | [.camel-element-JVM]##JVM## +
Preview | 1.1.0 | Poll Atom RSS feeds.

| xref:reference/extensions/atomix.adoc[Atomix Map] | camel-quarkus-atomix | [.camel-element-JVM]##JVM## +
Preview | 1.1.0 | Access Atomix's distributed map.

| xref:reference/extensions/attachments.adoc[Attachments] | camel-quarkus-attachments | [.camel-element-Native]##Native## +
Stable | 0.3.0 | Support for attachments on Camel messages

Expand Down Expand Up @@ -80,6 +83,12 @@ Stable | 1.0.0 | Manage AWS IAM instances using AWS SDK version 2.x.
| xref:reference/extensions/aws2-kms.adoc[AWS 2 Key Management Service (KMS)] | camel-quarkus-aws2-kms | [.camel-element-Native]##Native## +
Stable | 1.0.0 | Manage keys stored in AWS KMS instances using AWS SDK version 2.x.

| xref:reference/extensions/aws2-kinesis.adoc[AWS 2 Kinesis] | camel-quarkus-aws2-kinesis | [.camel-element-JVM]##JVM## +
Preview | 1.1.0 | Consume and produce records from AWS Kinesis Streams using AWS SDK version 2.x.

| xref:reference/extensions/aws2-lambda.adoc[AWS 2 Lambda] | camel-quarkus-aws2-lambda | [.camel-element-JVM]##JVM## +
Preview | 1.1.0 | Manage and invoke AWS Lambda functions using AWS SDK version 2.x.

| xref:reference/extensions/aws2-msk.adoc[AWS 2 Managed Streaming for Apache Kafka (MSK)] | camel-quarkus-aws2-msk | [.camel-element-Native]##Native## +
Stable | 1.0.0 | Manage AWS MSK instances using AWS SDK version 2.x.

Expand Down Expand Up @@ -143,6 +152,12 @@ Stable | 1.0.0 | Translate texts using AWS Translate.
| xref:reference/extensions/azure.adoc[Azure] | camel-quarkus-azure | [.camel-element-Native]##Native## +
Stable | 1.0.0 | Store and retrieve blobs from Azure Storage Blob Service or store and retrieve messages from Azure Storage Queue Service

| xref:reference/extensions/azure-storage-blob.adoc[Azure Storage Blob Service] | camel-quarkus-azure-storage-blob | [.camel-element-JVM]##JVM## +
Preview | 1.1.0 | Store and retrieve blobs from Azure Storage Blob Service using SDK v12.

| xref:reference/extensions/azure-storage-queue.adoc[Azure Storage Queue Service] | camel-quarkus-azure-storage-queue | [.camel-element-JVM]##JVM## +
Preview | 1.1.0 | The azure-storage-queue component is used for storing and retrieving the messages to/from Azure Storage Queue using Azure SDK v12.

| xref:reference/extensions/base64.adoc[Base64] | camel-quarkus-base64 | [.camel-element-Native]##Native## +
Stable | 1.0.0 | Encode and decode data using Base64.

Expand Down
63 changes: 63 additions & 0 deletions extensions-jvm/atomix/deployment/pom.xml
Original file line number Diff line number Diff line change
@@ -0,0 +1,63 @@
<?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-atomix-parent</artifactId>
<version>1.1.0-SNAPSHOT</version>
<relativePath>../pom.xml</relativePath>
</parent>

<artifactId>camel-quarkus-atomix-deployment</artifactId>
<name>Camel Quarkus :: Atomix Map :: Deployment</name>

<dependencies>
<dependency>
<groupId>org.apache.camel.quarkus</groupId>
<artifactId>camel-quarkus-core-deployment</artifactId>
</dependency>
<dependency>
<groupId>org.apache.camel.quarkus</groupId>
<artifactId>camel-quarkus-atomix</artifactId>
</dependency>
</dependencies>

<build>
<plugins>
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-compiler-plugin</artifactId>
<configuration>
<annotationProcessorPaths>
<path>
<groupId>io.quarkus</groupId>
<artifactId>quarkus-extension-processor</artifactId>
<version>${quarkus.version}</version>
</path>
</annotationProcessorPaths>
</configuration>
</plugin>
</plugins>
</build>

</project>