[camel-quarkus] 01/01: Upgrade to Camel 3.3.0 - WIP
This is an automated email from the ASF dual-hosted git repository. ppalaga pushed a commit to branch camel-master in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git commit 5772e986c19cb31599487c7516dbec84a56cba26 Author: James Netherton AuthorDate: Tue Apr 14 09:34:35 2020 +0100 Upgrade to Camel 3.3.0 - WIP --- .../pages/list-of-camel-quarkus-extensions.adoc| 378 ++--- .../core/deployment/CamelRoutesDiscoveryTest.java | 2 +- .../core/deployment/CamelRoutesFilterTest.java | 7 +- .../org/apache/camel/quarkus/core/BaseModel.java | 29 ++ .../org/apache/camel/quarkus/core/CamelMain.java | 2 +- .../quarkus/core/CamelMainEventDispatcher.java | 12 +- .../apache/camel/quarkus/core/CamelMainEvents.java | 9 +- .../camel/quarkus/core/CamelMainRecorder.java | 2 +- .../camel/quarkus/core/FastCamelContext.java | 20 ++ .../quarkus/core/FastFactoryFinderResolver.java| 19 +- .../component/file/deployment/FileProcessor.java | 36 -- .../org/apache/camel/component/qute/qute.json | 21 +- .../camel/quarkus/core/CoreMainXmlIoResource.java | 2 +- .../quarkus/core/CoreMainXmlJaxbResource.java | 2 +- .../camel/quarkus/core/CoreMainResource.java | 2 +- .../quarkus/component/slack/it/SlackRoutes.java| 4 +- .../core/runtime/support/SupportListener.java | 14 +- pom.xml| 4 +- 18 files changed, 298 insertions(+), 267 deletions(-) diff --git a/docs/modules/ROOT/pages/list-of-camel-quarkus-extensions.adoc b/docs/modules/ROOT/pages/list-of-camel-quarkus-extensions.adoc index b2706df..bb68845 100644 --- a/docs/modules/ROOT/pages/list-of-camel-quarkus-extensions.adoc +++ b/docs/modules/ROOT/pages/list-of-camel-quarkus-extensions.adoc @@ -27,15 +27,15 @@ Level | Since | Description | link:https://camel.apache.org/components/latest/activemq-component.html[ActiveMQ] (camel-quarkus-activemq) + `activemq:destinationType:destinationName` | Native + - Stable | 1.0.0-M5 | The activemq component allows messages to be sent to (or consumed from) Apache ActiveMQ. This component extends the Camel JMS component. + Stable | 1.0.0-M5 | Send messages to (or consume from) Apache ActiveMQ. This component extends the Camel JMS component. | xref:extensions/ahc.adoc[AHC] (camel-quarkus-ahc) + `ahc:httpUri` | Native + - Stable | 1.0.0-M3 | To call external HTTP services using Async Http Client. + Stable | 1.0.0-M3 | Call external HTTP services using Async Http Client. | link:https://camel.apache.org/components/latest/ahc-ws-component.html[AHC Websocket] (camel-quarkus-ahc-ws) + `ahc-ws:httpUri` | Native + - Stable | 1.0.0-M3 | To exchange data with external Websocket servers using Async Http Client. + Stable | 1.0.0-M3 | Exchange data with external Websocket servers using Async Http Client. | link:https://camel.apache.org/components/latest/amqp-component.html[AMQP] (camel-quarkus-amqp) + `amqp:destinationType:destinationName` | Native + @@ -43,235 +43,235 @@ Level | Since | Description | link:https://camel.apache.org/components/latest/avro-component.html[Avro] (camel-quarkus-avro-rpc) + `avro:transport:host:port/messageName` | JVM + - Preview | 1.0.0-M6 | Working with Apache Avro for data serialization. + Preview | 1.0.0-M6 | Produce or consume Apache Avro RPC services. | link:https://camel.apache.org/components/latest/aws2-cw-component.html[AWS 2 CloudWatch] (camel-quarkus-aws2-cw) + `aws2-cw:namespace` | Native + - Stable | 1.0.0-M6 | The aws2-cw component is used for sending metrics to an Amazon CloudWatch. + Stable | 1.0.0-M6 | Sending metrics to AWS CloudWatch using AWS SDK version 2.x. | link:https://camel.apache.org/components/latest/aws2-ddb-component.html[AWS 2 DynamoDB] (camel-quarkus-aws2-ddb) + `aws2-ddb:tableName` | JVM + - Preview | 1.0.0-M6 | The aws2-ddb component is used for storing and retrieving data from Amazon's DynamoDB service. + Preview | 1.0.0-M6 | Store and retrieve data from AWS DynamoDB service using AWS SDK version 2.x. | link:https://camel.apache.org/components/latest/aws2-ddbstream-component.html[AWS 2 DynamoDB Streams] (camel-quarkus-aws2-ddb) + `aws2-ddbstream:tableName` | JVM + - Preview | 1.0.0-M6 | The aws2-ddbstream component is used for working with Amazon DynamoDB Streams. + Preview | 1.0.0-M6 | Receive messages from AWS DynamoDB Stream service using AWS SDK version 2.x. | link:https://camel.apache.org/components/latest/aws2-ec2-component.html[AWS 2 EC2] (camel-quarkus-aws2-ec2) + `aws2-ec2:label` | JVM + - Preview | 1.0.0-M6 | The aws2-ec2 is used for managing Amazon EC2 instances. + Preview | 1.0.0-M6 | Manage AWS EC2 instances using AWS SDK version 2.x. | link:https://camel.apache.org/components/latest/aws2-ecs-component.html[AWS 2 ECS] (camel-quarkus-aws2-ecs) + `aws2-ecs:label` | JVM + - Preview | 1.0.0-M6 | The aws2-ecs is used for managing Amazon ECS + Preview |
[camel-quarkus] 01/01: Upgrade to Camel 3.3.0 - WIP
This is an automated email from the ASF dual-hosted git repository. jamesnetherton pushed a commit to branch camel-master in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git commit b862f45aa5c819d58857f7551e45910e5353dbbc Author: James Netherton AuthorDate: Tue Apr 14 09:34:35 2020 +0100 Upgrade to Camel 3.3.0 - WIP --- .../pages/list-of-camel-quarkus-extensions.adoc| 378 ++--- .../org/apache/camel/quarkus/core/BaseModel.java | 29 ++ .../camel/quarkus/core/FastCamelContext.java | 20 ++ .../quarkus/core/FastFactoryFinderResolver.java| 19 +- .../component/file/deployment/FileProcessor.java | 36 -- .../org/apache/camel/component/qute/qute.json | 21 +- .../quarkus/component/slack/it/SlackRoutes.java| 4 +- pom.xml| 4 +- 8 files changed, 257 insertions(+), 254 deletions(-) diff --git a/docs/modules/ROOT/pages/list-of-camel-quarkus-extensions.adoc b/docs/modules/ROOT/pages/list-of-camel-quarkus-extensions.adoc index b2706df..bb68845 100644 --- a/docs/modules/ROOT/pages/list-of-camel-quarkus-extensions.adoc +++ b/docs/modules/ROOT/pages/list-of-camel-quarkus-extensions.adoc @@ -27,15 +27,15 @@ Level | Since | Description | link:https://camel.apache.org/components/latest/activemq-component.html[ActiveMQ] (camel-quarkus-activemq) + `activemq:destinationType:destinationName` | Native + - Stable | 1.0.0-M5 | The activemq component allows messages to be sent to (or consumed from) Apache ActiveMQ. This component extends the Camel JMS component. + Stable | 1.0.0-M5 | Send messages to (or consume from) Apache ActiveMQ. This component extends the Camel JMS component. | xref:extensions/ahc.adoc[AHC] (camel-quarkus-ahc) + `ahc:httpUri` | Native + - Stable | 1.0.0-M3 | To call external HTTP services using Async Http Client. + Stable | 1.0.0-M3 | Call external HTTP services using Async Http Client. | link:https://camel.apache.org/components/latest/ahc-ws-component.html[AHC Websocket] (camel-quarkus-ahc-ws) + `ahc-ws:httpUri` | Native + - Stable | 1.0.0-M3 | To exchange data with external Websocket servers using Async Http Client. + Stable | 1.0.0-M3 | Exchange data with external Websocket servers using Async Http Client. | link:https://camel.apache.org/components/latest/amqp-component.html[AMQP] (camel-quarkus-amqp) + `amqp:destinationType:destinationName` | Native + @@ -43,235 +43,235 @@ Level | Since | Description | link:https://camel.apache.org/components/latest/avro-component.html[Avro] (camel-quarkus-avro-rpc) + `avro:transport:host:port/messageName` | JVM + - Preview | 1.0.0-M6 | Working with Apache Avro for data serialization. + Preview | 1.0.0-M6 | Produce or consume Apache Avro RPC services. | link:https://camel.apache.org/components/latest/aws2-cw-component.html[AWS 2 CloudWatch] (camel-quarkus-aws2-cw) + `aws2-cw:namespace` | Native + - Stable | 1.0.0-M6 | The aws2-cw component is used for sending metrics to an Amazon CloudWatch. + Stable | 1.0.0-M6 | Sending metrics to AWS CloudWatch using AWS SDK version 2.x. | link:https://camel.apache.org/components/latest/aws2-ddb-component.html[AWS 2 DynamoDB] (camel-quarkus-aws2-ddb) + `aws2-ddb:tableName` | JVM + - Preview | 1.0.0-M6 | The aws2-ddb component is used for storing and retrieving data from Amazon's DynamoDB service. + Preview | 1.0.0-M6 | Store and retrieve data from AWS DynamoDB service using AWS SDK version 2.x. | link:https://camel.apache.org/components/latest/aws2-ddbstream-component.html[AWS 2 DynamoDB Streams] (camel-quarkus-aws2-ddb) + `aws2-ddbstream:tableName` | JVM + - Preview | 1.0.0-M6 | The aws2-ddbstream component is used for working with Amazon DynamoDB Streams. + Preview | 1.0.0-M6 | Receive messages from AWS DynamoDB Stream service using AWS SDK version 2.x. | link:https://camel.apache.org/components/latest/aws2-ec2-component.html[AWS 2 EC2] (camel-quarkus-aws2-ec2) + `aws2-ec2:label` | JVM + - Preview | 1.0.0-M6 | The aws2-ec2 is used for managing Amazon EC2 instances. + Preview | 1.0.0-M6 | Manage AWS EC2 instances using AWS SDK version 2.x. | link:https://camel.apache.org/components/latest/aws2-ecs-component.html[AWS 2 ECS] (camel-quarkus-aws2-ecs) + `aws2-ecs:label` | JVM + - Preview | 1.0.0-M6 | The aws2-ecs is used for managing Amazon ECS + Preview | 1.0.0-M6 | Manage AWS ECS cluster instances using AWS SDK version 2.x. | link:https://camel.apache.org/components/latest/aws2-eks-component.html[AWS 2 EKS] (camel-quarkus-aws2-eks) + `aws2-eks:label` | JVM + - Preview | 1.0.0-M6 | The aws2-eks is used for managing Amazon EKS + Preview | 1.0.0-M6 | Manage AWS EKS cluster instances using AWS SDK version 2.x. | link:https://camel.apache.org/components/latest/aws2-iam-component.html[AWS 2 IAM] (camel-quarkus-aws2-iam) + `aws2-iam:label` | JVM + - Preview | 1.0.0-M6 | The aws2-iam is used for managing Amazon IAM + Preview | 1.0.0-M6 | Manage AWS
[camel-quarkus] 01/01: Upgrade to Camel 3.3.0 - WIP
This is an automated email from the ASF dual-hosted git repository. jamesnetherton pushed a commit to branch camel-master in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git commit e8543f5bbcf5ef1ef2df641f4fb071a1a618679a Author: James Netherton AuthorDate: Tue Apr 14 09:34:35 2020 +0100 Upgrade to Camel 3.3.0 - WIP --- .../pages/list-of-camel-quarkus-extensions.adoc| 378 ++--- .../org/apache/camel/quarkus/core/BaseModel.java | 29 ++ .../camel/quarkus/core/FastCamelContext.java | 20 ++ .../quarkus/core/FastFactoryFinderResolver.java| 19 +- .../component/file/deployment/FileProcessor.java | 36 -- .../org/apache/camel/component/qute/qute.json | 21 +- pom.xml| 4 +- 7 files changed, 255 insertions(+), 252 deletions(-) diff --git a/docs/modules/ROOT/pages/list-of-camel-quarkus-extensions.adoc b/docs/modules/ROOT/pages/list-of-camel-quarkus-extensions.adoc index f26e8a1..c549b35 100644 --- a/docs/modules/ROOT/pages/list-of-camel-quarkus-extensions.adoc +++ b/docs/modules/ROOT/pages/list-of-camel-quarkus-extensions.adoc @@ -27,15 +27,15 @@ Level | Since | Description | link:https://camel.apache.org/components/latest/activemq-component.html[ActiveMQ] (camel-quarkus-activemq) + `activemq:destinationType:destinationName` | Native + - Stable | 1.0.0-M5 | The activemq component allows messages to be sent to (or consumed from) Apache ActiveMQ. This component extends the Camel JMS component. + Stable | 1.0.0-M5 | Send messages to (or consume from) Apache ActiveMQ. This component extends the Camel JMS component. | xref:extensions/ahc.adoc[AHC] (camel-quarkus-ahc) + `ahc:httpUri` | Native + - Stable | 1.0.0-M3 | To call external HTTP services using Async Http Client. + Stable | 1.0.0-M3 | Call external HTTP services using Async Http Client. | link:https://camel.apache.org/components/latest/ahc-ws-component.html[AHC Websocket] (camel-quarkus-ahc-ws) + `ahc-ws:httpUri` | Native + - Stable | 1.0.0-M3 | To exchange data with external Websocket servers using Async Http Client. + Stable | 1.0.0-M3 | Exchange data with external Websocket servers using Async Http Client. | link:https://camel.apache.org/components/latest/amqp-component.html[AMQP] (camel-quarkus-amqp) + `amqp:destinationType:destinationName` | Native + @@ -43,235 +43,235 @@ Level | Since | Description | link:https://camel.apache.org/components/latest/avro-component.html[Avro] (camel-quarkus-avro-rpc) + `avro:transport:host:port/messageName` | JVM + - Preview | 1.0.0-M6 | Working with Apache Avro for data serialization. + Preview | 1.0.0-M6 | Produce or consume Apache Avro RPC services. | link:https://camel.apache.org/components/latest/aws2-cw-component.html[AWS 2 CloudWatch] (camel-quarkus-aws2-cw) + `aws2-cw:namespace` | Native + - Stable | 1.0.0-M6 | The aws2-cw component is used for sending metrics to an Amazon CloudWatch. + Stable | 1.0.0-M6 | Sending metrics to AWS CloudWatch using AWS SDK version 2.x. | link:https://camel.apache.org/components/latest/aws2-ddb-component.html[AWS 2 DynamoDB] (camel-quarkus-aws2-ddb) + `aws2-ddb:tableName` | JVM + - Preview | 1.0.0-M6 | The aws2-ddb component is used for storing and retrieving data from Amazon's DynamoDB service. + Preview | 1.0.0-M6 | Store and retrieve data from AWS DynamoDB service using AWS SDK version 2.x. | link:https://camel.apache.org/components/latest/aws2-ddbstream-component.html[AWS 2 DynamoDB Streams] (camel-quarkus-aws2-ddb) + `aws2-ddbstream:tableName` | JVM + - Preview | 1.0.0-M6 | The aws2-ddbstream component is used for working with Amazon DynamoDB Streams. + Preview | 1.0.0-M6 | Receive messages from AWS DynamoDB Stream service using AWS SDK version 2.x. | link:https://camel.apache.org/components/latest/aws2-ec2-component.html[AWS 2 EC2] (camel-quarkus-aws2-ec2) + `aws2-ec2:label` | JVM + - Preview | 1.0.0-M6 | The aws2-ec2 is used for managing Amazon EC2 instances. + Preview | 1.0.0-M6 | Manage AWS EC2 instances using AWS SDK version 2.x. | link:https://camel.apache.org/components/latest/aws2-ecs-component.html[AWS 2 ECS] (camel-quarkus-aws2-ecs) + `aws2-ecs:label` | JVM + - Preview | 1.0.0-M6 | The aws2-ecs is used for managing Amazon ECS + Preview | 1.0.0-M6 | Manage AWS ECS cluster instances using AWS SDK version 2.x. | link:https://camel.apache.org/components/latest/aws2-eks-component.html[AWS 2 EKS] (camel-quarkus-aws2-eks) + `aws2-eks:label` | JVM + - Preview | 1.0.0-M6 | The aws2-eks is used for managing Amazon EKS + Preview | 1.0.0-M6 | Manage AWS EKS cluster instances using AWS SDK version 2.x. | link:https://camel.apache.org/components/latest/aws2-iam-component.html[AWS 2 IAM] (camel-quarkus-aws2-iam) + `aws2-iam:label` | JVM + - Preview | 1.0.0-M6 | The aws2-iam is used for managing Amazon IAM + Preview | 1.0.0-M6 | Manage AWS IAM instances using AWS SDK version 2.x. |
[camel-quarkus] 01/01: Upgrade to Camel 3.3.0 - WIP
This is an automated email from the ASF dual-hosted git repository.
jamesnetherton pushed a commit to branch camel-master
in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git
commit 30b94b20dea8671c47710da013afcd9af6444703
Author: James Netherton
AuthorDate: Tue Apr 14 09:34:35 2020 +0100
Upgrade to Camel 3.3.0 - WIP
---
.../pages/list-of-camel-quarkus-extensions.adoc| 2 +-
.../org/apache/camel/quarkus/core/BaseModel.java | 29 ++
.../camel/quarkus/core/FastCamelContext.java | 20 +++
.../org/apache/camel/component/qute/qute.json | 21
pom.xml| 4 +--
5 files changed, 63 insertions(+), 13 deletions(-)
diff --git a/docs/modules/ROOT/pages/list-of-camel-quarkus-extensions.adoc
b/docs/modules/ROOT/pages/list-of-camel-quarkus-extensions.adoc
index f26e8a1..eb70431 100644
--- a/docs/modules/ROOT/pages/list-of-camel-quarkus-extensions.adoc
+++ b/docs/modules/ROOT/pages/list-of-camel-quarkus-extensions.adoc
@@ -161,7 +161,7 @@ Level | Since | Description
`aws2-s3://bucketNameOrArn` | Native +
Stable | 1.0.0-M7 | The aws2-s3 component is used for storing and retrieving
object from Amazon S3 Storage Service.
-|
link:https://camel.apache.org/components/latest/azure-blob-component.html[Azure
Storage Blob Service] (camel-quarkus-azure) +
+|
link:https://camel.apache.org/components/latest/azure-blob-component.html[Azure
Storage Blob Service (Legacy)] (camel-quarkus-azure) +
`azure-blob:containerOrBlobUri` | Native +
Stable | 1.0.0-M4 | The azure-blob component is used for storing and
retrieving blobs from Azure Storage Blob Service.
diff --git
a/extensions-core/core/runtime/src/main/java/org/apache/camel/quarkus/core/BaseModel.java
b/extensions-core/core/runtime/src/main/java/org/apache/camel/quarkus/core/BaseModel.java
index 2ccfc61..9bd3b06 100644
---
a/extensions-core/core/runtime/src/main/java/org/apache/camel/quarkus/core/BaseModel.java
+++
b/extensions-core/core/runtime/src/main/java/org/apache/camel/quarkus/core/BaseModel.java
@@ -40,6 +40,7 @@ public abstract class BaseModel implements Model {
private Map
serviceCallConfigurations = new ConcurrentHashMap<>();
private Map hystrixConfigurations
= new ConcurrentHashMap<>();
private Map
resilience4jConfigurations = new ConcurrentHashMap<>();
+private Map
faultToleranceConfigurations = new ConcurrentHashMap<>();
private Function routeFilter;
public BaseModel(CamelContext camelContext) {
@@ -216,6 +217,34 @@ public abstract class BaseModel implements Model {
}
@Override
+public FaultToleranceConfigurationDefinition
getFaultToleranceConfiguration(String id) {
+if (id == null) {
+id = "";
+}
+
+return faultToleranceConfigurations.get(id);
+}
+
+@Override
+public void
setFaultToleranceConfiguration(FaultToleranceConfigurationDefinition
configuration) {
+faultToleranceConfigurations.put("", configuration);
+}
+
+@Override
+public void
setFaultToleranceConfigurations(List
configurations) {
+if (configurations != null) {
+for (FaultToleranceConfigurationDefinition configuration :
configurations) {
+faultToleranceConfigurations.put(configuration.getId(),
configuration);
+}
+}
+}
+
+@Override
+public void addFaultToleranceConfiguration(String id,
FaultToleranceConfigurationDefinition configuration) {
+faultToleranceConfigurations.put(id, configuration);
+}
+
+@Override
public DataFormatDefinition resolveDataFormatDefinition(String name) {
// lookup type and create the data format from it
DataFormatDefinition type = lookup(camelContext, name,
DataFormatDefinition.class);
diff --git
a/extensions-core/core/runtime/src/main/java/org/apache/camel/quarkus/core/FastCamelContext.java
b/extensions-core/core/runtime/src/main/java/org/apache/camel/quarkus/core/FastCamelContext.java
index 768a48f..152ebb0 100644
---
a/extensions-core/core/runtime/src/main/java/org/apache/camel/quarkus/core/FastCamelContext.java
+++
b/extensions-core/core/runtime/src/main/java/org/apache/camel/quarkus/core/FastCamelContext.java
@@ -593,6 +593,26 @@ public class FastCamelContext extends AbstractCamelContext
implements CatalogCam
}
@Override
+public FaultToleranceConfigurationDefinition
getFaultToleranceConfiguration(String id) {
+return model.getFaultToleranceConfiguration(id);
+}
+
+@Override
+public void
setFaultToleranceConfiguration(FaultToleranceConfigurationDefinition
configuration) {
+model.setFaultToleranceConfiguration(configuration);
+}
+
+@Override
+public void
setFaultToleranceConfigurations(List
configurations) {
+model.setFaultToleranceConfigurations(configurations);
+}
+
+@Override
+public void
[camel-quarkus] 01/01: Upgrade to Camel 3.3.0 - WIP
This is an automated email from the ASF dual-hosted git repository.
jamesnetherton pushed a commit to branch camel-master
in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git
commit 849e36663db428ade3462b8882b58f6eb32f1a47
Author: James Netherton
AuthorDate: Tue Apr 14 09:34:35 2020 +0100
Upgrade to Camel 3.3.0 - WIP
---
.../pages/list-of-camel-quarkus-extensions.adoc| 2 +-
.../org/apache/camel/quarkus/core/BaseModel.java | 29 ++
.../camel/quarkus/core/FastCamelContext.java | 20 +++
.../org/apache/camel/component/qute/qute.json | 21
pom.xml| 4 +--
5 files changed, 63 insertions(+), 13 deletions(-)
diff --git a/docs/modules/ROOT/pages/list-of-camel-quarkus-extensions.adoc
b/docs/modules/ROOT/pages/list-of-camel-quarkus-extensions.adoc
index 36a32d3..47bdfe3 100644
--- a/docs/modules/ROOT/pages/list-of-camel-quarkus-extensions.adoc
+++ b/docs/modules/ROOT/pages/list-of-camel-quarkus-extensions.adoc
@@ -161,7 +161,7 @@ Level | Since | Description
`aws2-s3://bucketNameOrArn` | Native +
Stable | 1.0.0-M7 | The aws2-s3 component is used for storing and retrieving
object from Amazon S3 Storage Service.
-|
link:https://camel.apache.org/components/latest/azure-blob-component.html[Azure
Storage Blob Service] (camel-quarkus-azure) +
+|
link:https://camel.apache.org/components/latest/azure-blob-component.html[Azure
Storage Blob Service (Legacy)] (camel-quarkus-azure) +
`azure-blob:containerOrBlobUri` | Native +
Stable | 1.0.0-M4 | The azure-blob component is used for storing and
retrieving blobs from Azure Storage Blob Service.
diff --git
a/extensions-core/core/runtime/src/main/java/org/apache/camel/quarkus/core/BaseModel.java
b/extensions-core/core/runtime/src/main/java/org/apache/camel/quarkus/core/BaseModel.java
index 2ccfc61..9bd3b06 100644
---
a/extensions-core/core/runtime/src/main/java/org/apache/camel/quarkus/core/BaseModel.java
+++
b/extensions-core/core/runtime/src/main/java/org/apache/camel/quarkus/core/BaseModel.java
@@ -40,6 +40,7 @@ public abstract class BaseModel implements Model {
private Map
serviceCallConfigurations = new ConcurrentHashMap<>();
private Map hystrixConfigurations
= new ConcurrentHashMap<>();
private Map
resilience4jConfigurations = new ConcurrentHashMap<>();
+private Map
faultToleranceConfigurations = new ConcurrentHashMap<>();
private Function routeFilter;
public BaseModel(CamelContext camelContext) {
@@ -216,6 +217,34 @@ public abstract class BaseModel implements Model {
}
@Override
+public FaultToleranceConfigurationDefinition
getFaultToleranceConfiguration(String id) {
+if (id == null) {
+id = "";
+}
+
+return faultToleranceConfigurations.get(id);
+}
+
+@Override
+public void
setFaultToleranceConfiguration(FaultToleranceConfigurationDefinition
configuration) {
+faultToleranceConfigurations.put("", configuration);
+}
+
+@Override
+public void
setFaultToleranceConfigurations(List
configurations) {
+if (configurations != null) {
+for (FaultToleranceConfigurationDefinition configuration :
configurations) {
+faultToleranceConfigurations.put(configuration.getId(),
configuration);
+}
+}
+}
+
+@Override
+public void addFaultToleranceConfiguration(String id,
FaultToleranceConfigurationDefinition configuration) {
+faultToleranceConfigurations.put(id, configuration);
+}
+
+@Override
public DataFormatDefinition resolveDataFormatDefinition(String name) {
// lookup type and create the data format from it
DataFormatDefinition type = lookup(camelContext, name,
DataFormatDefinition.class);
diff --git
a/extensions-core/core/runtime/src/main/java/org/apache/camel/quarkus/core/FastCamelContext.java
b/extensions-core/core/runtime/src/main/java/org/apache/camel/quarkus/core/FastCamelContext.java
index 768a48f..152ebb0 100644
---
a/extensions-core/core/runtime/src/main/java/org/apache/camel/quarkus/core/FastCamelContext.java
+++
b/extensions-core/core/runtime/src/main/java/org/apache/camel/quarkus/core/FastCamelContext.java
@@ -593,6 +593,26 @@ public class FastCamelContext extends AbstractCamelContext
implements CatalogCam
}
@Override
+public FaultToleranceConfigurationDefinition
getFaultToleranceConfiguration(String id) {
+return model.getFaultToleranceConfiguration(id);
+}
+
+@Override
+public void
setFaultToleranceConfiguration(FaultToleranceConfigurationDefinition
configuration) {
+model.setFaultToleranceConfiguration(configuration);
+}
+
+@Override
+public void
setFaultToleranceConfigurations(List
configurations) {
+model.setFaultToleranceConfigurations(configurations);
+}
+
+@Override
+public void
[camel-quarkus] 01/01: Upgrade to Camel 3.3.0 - WIP
This is an automated email from the ASF dual-hosted git repository. jamesnetherton pushed a commit to branch camel-master in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git commit 4aed3761f289adeeb41f84189917dbd19e9605ba Author: James Netherton AuthorDate: Tue Apr 14 09:34:35 2020 +0100 Upgrade to Camel 3.3.0 - WIP --- pom.xml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pom.xml b/pom.xml index 63e5b87..492cef2 100644 --- a/pom.xml +++ b/pom.xml @@ -45,7 +45,7 @@ 1.11.714 1.11.22 2.11.5 -3.2.0 +3.3.0-SNAPSHOT 2.3.30 1.22.0 26.0-jre
[camel-quarkus] 01/01: Upgrade to Camel 3.3.0 - WIP
This is an automated email from the ASF dual-hosted git repository. jamesnetherton pushed a commit to branch camel-master in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git commit 4b1f40c44a6662b9876ced493dd20adae047ad58 Author: James Netherton AuthorDate: Tue Apr 14 09:34:35 2020 +0100 Upgrade to Camel 3.3.0 - WIP --- pom.xml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pom.xml b/pom.xml index a3a7ddb..92493a8 100644 --- a/pom.xml +++ b/pom.xml @@ -45,7 +45,7 @@ 1.11.714 1.11.22 2.11.5 -3.2.0 +3.3.0-SNAPSHOT 2.3.30 1.22.0 26.0-jre
[camel-quarkus] 01/01: Upgrade to Camel 3.3.0 - WIP
This is an automated email from the ASF dual-hosted git repository. jamesnetherton pushed a commit to branch camel-master in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git commit c0b98f4790574dae5845a3a018ac208a78cd9c76 Author: James Netherton AuthorDate: Tue Apr 14 09:34:35 2020 +0100 Upgrade to Camel 3.3.0 - WIP --- pom.xml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pom.xml b/pom.xml index 6b1c306..a4c706b 100644 --- a/pom.xml +++ b/pom.xml @@ -45,7 +45,7 @@ 1.11.714 1.11.22 2.11.5 -3.2.0 +3.3.0-SNAPSHOT 2.3.30 1.22.0 26.0-jre
