You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ja...@apache.org on 2020/11/05 15:01:37 UTC
[camel-quarkus] branch camel-master updated (b219bf6 -> 8b197bd)
This is an automated email from the ASF dual-hosted git repository.
jamesnetherton pushed a change to branch camel-master
in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git.
omit b219bf6 Added the joni optional dependency in order fix the native build
omit 09094a0 Upgrade to Camel 3.7.0
add 38a59c6 Updated CHANGELOG.md
add 796fe87 Add WireMock test support
add 0f7b5e2 Twilio native support
add 8d82f59 Fix #819 saga native support
add 1f0c189 Zendesk native support
add 4d47081 Upgrade Quarkus to 1.9.1.Final
add 9bdf64d Fixup Provide a quick profile #1607
add 1857a8f Updated CHANGELOG.md
add 4de7d8e Temporarily disable Olingo integration tests due to test service throwing SSLPeerUnverifiedException #1972
add 386ad9c Enable quickly profile for SNAPSHOT deploy build
add 449caff Automate the process of creating jvm only extensions
add d3f8265 aws2-eventbridge JVM support
add 88aac10 Configuration option (not) to start the runtime #1969
add 529cb10 Updated CHANGELOG.md
add 39fa805 Updated CHANGELOG.md
add 792ddb7 Reenable Olingo4 integration test
add 03a9b37 PostgresSQL Event : add usage of Quarkus AgroalDatasource fixes #1909
add 50db02e Updated CHANGELOG.md
add d8da529 fix(docs): use cross reference URLs
add 72edb0b Revert "fix(docs): use cross reference URLs"
add 11923e3 fix(docs): use cross reference URLs
add 771142d fix(docs): use cross reference URLs (2)
add ad10f3e fix(docs): use cross reference URLs (3)
add 3147920 Updated CHANGELOG.md
add 63a1bf3 Added nagios native support #1726
add 98c2f39 Fix WireMock server field injection for native tests
add edb21d5 Discover WireMock mappings from the classpath to keep quarkus-platform happy
add 8f311be Stub ServiceNow tests with WireMock
add 06d0b0a Stub Slack tests with WireMock
add b774567 Stub Geocoder tests with WireMock
add be675db Add missing geocoder reflective class
add 5302af6 Stub Telegram tests with WireMock
add 6a7527d Updated CHANGELOG.md
add 0805ab4 core: allign BaseModel with org.apache.camel.impl.DefaultModel
add 8ab74db Upgrade Quarkus to 1.9.2.Final
new 704b03f Upgrade to Camel 3.7.0
new 8b197bd Temporarily disable failing antora xref check
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (b219bf6)
\
N -- N -- N refs/heads/camel-master (8b197bd)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.github/workflows/generate-jvm-extension.yaml | 82 +++
CHANGELOG.md | 31 +-
Jenkinsfile | 2 +-
catalog/pom.xml | 13 +
docs/antora-playbook.yml | 10 +
.../contributor-guide/extension-metadata.adoc | 2 +-
.../pages/contributor-guide/release-guide.adoc | 4 +-
docs/modules/ROOT/pages/index.adoc | 4 +-
.../ROOT/pages/reference/extensions/activemq.adoc | 2 +-
.../ROOT/pages/reference/extensions/ahc-ws.adoc | 4 +-
.../ROOT/pages/reference/extensions/ahc.adoc | 2 +-
.../ROOT/pages/reference/extensions/amqp.adoc | 2 +-
.../ROOT/pages/reference/extensions/apns.adoc | 2 +-
.../ROOT/pages/reference/extensions/arangodb.adoc | 2 +-
.../ROOT/pages/reference/extensions/as2.adoc | 2 +-
.../ROOT/pages/reference/extensions/asn1.adoc | 2 +-
.../ROOT/pages/reference/extensions/asterisk.adoc | 2 +-
.../ROOT/pages/reference/extensions/atmos.adoc | 2 +-
.../ROOT/pages/reference/extensions/atom.adoc | 2 +-
.../ROOT/pages/reference/extensions/atomix.adoc | 12 +-
.../pages/reference/extensions/attachments.adoc | 2 +-
.../ROOT/pages/reference/extensions/avro-rpc.adoc | 2 +-
.../ROOT/pages/reference/extensions/avro.adoc | 2 +-
.../ROOT/pages/reference/extensions/aws-ec2.adoc | 2 +-
.../ROOT/pages/reference/extensions/aws-ecs.adoc | 2 +-
.../ROOT/pages/reference/extensions/aws-eks.adoc | 2 +-
.../ROOT/pages/reference/extensions/aws-iam.adoc | 2 +-
.../pages/reference/extensions/aws-kinesis.adoc | 4 +-
.../ROOT/pages/reference/extensions/aws-kms.adoc | 2 +-
.../pages/reference/extensions/aws-lambda.adoc | 2 +-
.../ROOT/pages/reference/extensions/aws-s3.adoc | 2 +-
.../ROOT/pages/reference/extensions/aws-sdb.adoc | 2 +-
.../ROOT/pages/reference/extensions/aws-sns.adoc | 2 +-
.../ROOT/pages/reference/extensions/aws-sqs.adoc | 2 +-
.../ROOT/pages/reference/extensions/aws-swf.adoc | 2 +-
.../pages/reference/extensions/aws-translate.adoc | 2 +-
.../ROOT/pages/reference/extensions/aws-xray.adoc | 2 +-
.../pages/reference/extensions/aws2-athena.adoc | 2 +-
.../ROOT/pages/reference/extensions/aws2-cw.adoc | 2 +-
.../ROOT/pages/reference/extensions/aws2-ddb.adoc | 4 +-
.../ROOT/pages/reference/extensions/aws2-ec2.adoc | 2 +-
.../ROOT/pages/reference/extensions/aws2-ecs.adoc | 2 +-
.../ROOT/pages/reference/extensions/aws2-eks.adoc | 2 +-
.../{asn1.adoc => aws2-eventbridge.adoc} | 16 +-
.../ROOT/pages/reference/extensions/aws2-iam.adoc | 2 +-
.../pages/reference/extensions/aws2-kinesis.adoc | 4 +-
.../ROOT/pages/reference/extensions/aws2-kms.adoc | 2 +-
.../pages/reference/extensions/aws2-lambda.adoc | 2 +-
.../ROOT/pages/reference/extensions/aws2-mq.adoc | 2 +-
.../ROOT/pages/reference/extensions/aws2-msk.adoc | 2 +-
.../ROOT/pages/reference/extensions/aws2-s3.adoc | 2 +-
.../ROOT/pages/reference/extensions/aws2-ses.adoc | 2 +-
.../ROOT/pages/reference/extensions/aws2-sns.adoc | 2 +-
.../ROOT/pages/reference/extensions/aws2-sqs.adoc | 2 +-
.../ROOT/pages/reference/extensions/aws2-sts.adoc | 2 +-
.../pages/reference/extensions/aws2-translate.adoc | 2 +-
.../reference/extensions/azure-storage-blob.adoc | 2 +-
.../reference/extensions/azure-storage-queue.adoc | 2 +-
.../ROOT/pages/reference/extensions/azure.adoc | 4 +-
.../ROOT/pages/reference/extensions/barcode.adoc | 2 +-
.../ROOT/pages/reference/extensions/base64.adoc | 2 +-
.../pages/reference/extensions/bean-validator.adoc | 2 +-
.../ROOT/pages/reference/extensions/bean.adoc | 6 +-
.../ROOT/pages/reference/extensions/beanio.adoc | 2 +-
.../ROOT/pages/reference/extensions/beanstalk.adoc | 2 +-
.../ROOT/pages/reference/extensions/bindy.adoc | 6 +-
.../ROOT/pages/reference/extensions/bonita.adoc | 2 +-
.../ROOT/pages/reference/extensions/box.adoc | 2 +-
.../ROOT/pages/reference/extensions/braintree.adoc | 2 +-
.../ROOT/pages/reference/extensions/browse.adoc | 2 +-
.../ROOT/pages/reference/extensions/caffeine.adoc | 4 +-
.../pages/reference/extensions/cassandraql.adoc | 2 +-
.../ROOT/pages/reference/extensions/cbor.adoc | 2 +-
.../pages/reference/extensions/chatscript.adoc | 2 +-
.../ROOT/pages/reference/extensions/chunk.adoc | 2 +-
.../ROOT/pages/reference/extensions/cm-sms.adoc | 2 +-
.../ROOT/pages/reference/extensions/cmis.adoc | 2 +-
.../ROOT/pages/reference/extensions/coap.adoc | 8 +-
.../ROOT/pages/reference/extensions/cometd.adoc | 4 +-
.../ROOT/pages/reference/extensions/consul.adoc | 2 +-
.../pages/reference/extensions/controlbus.adoc | 2 +-
.../ROOT/pages/reference/extensions/corda.adoc | 2 +-
.../ROOT/pages/reference/extensions/core.adoc | 14 +-
.../ROOT/pages/reference/extensions/couchbase.adoc | 2 +-
.../ROOT/pages/reference/extensions/couchdb.adoc | 2 +-
.../ROOT/pages/reference/extensions/cron.adoc | 2 +-
.../ROOT/pages/reference/extensions/crypto.adoc | 6 +-
.../ROOT/pages/reference/extensions/csv.adoc | 2 +-
.../pages/reference/extensions/dataformat.adoc | 2 +-
.../reference/extensions/debezium-mongodb.adoc | 2 +-
.../pages/reference/extensions/debezium-mysql.adoc | 2 +-
.../reference/extensions/debezium-postgres.adoc | 2 +-
.../reference/extensions/debezium-sqlserver.adoc | 2 +-
.../pages/reference/extensions/digitalocean.adoc | 2 +-
.../ROOT/pages/reference/extensions/direct.adoc | 2 +-
.../ROOT/pages/reference/extensions/disruptor.adoc | 4 +-
.../ROOT/pages/reference/extensions/djl.adoc | 2 +-
.../ROOT/pages/reference/extensions/dns.adoc | 2 +-
.../ROOT/pages/reference/extensions/dozer.adoc | 2 +-
.../ROOT/pages/reference/extensions/drill.adoc | 2 +-
.../ROOT/pages/reference/extensions/dropbox.adoc | 2 +-
.../ROOT/pages/reference/extensions/ehcache.adoc | 2 +-
.../reference/extensions/elasticsearch-rest.adoc | 2 +-
.../ROOT/pages/reference/extensions/elsql.adoc | 2 +-
.../ROOT/pages/reference/extensions/etcd.adoc | 6 +-
.../ROOT/pages/reference/extensions/exec.adoc | 2 +-
.../ROOT/pages/reference/extensions/facebook.adoc | 2 +-
.../ROOT/pages/reference/extensions/fastjson.adoc | 2 +-
.../ROOT/pages/reference/extensions/fhir.adoc | 6 +-
.../pages/reference/extensions/file-watch.adoc | 2 +-
.../ROOT/pages/reference/extensions/file.adoc | 2 +-
.../ROOT/pages/reference/extensions/flatpack.adoc | 4 +-
.../ROOT/pages/reference/extensions/flink.adoc | 2 +-
.../ROOT/pages/reference/extensions/fop.adoc | 2 +-
.../pages/reference/extensions/freemarker.adoc | 2 +-
.../ROOT/pages/reference/extensions/ftp.adoc | 6 +-
.../ROOT/pages/reference/extensions/ganglia.adoc | 2 +-
.../ROOT/pages/reference/extensions/geocoder.adoc | 2 +-
.../ROOT/pages/reference/extensions/git.adoc | 2 +-
.../ROOT/pages/reference/extensions/github.adoc | 2 +-
.../reference/extensions/google-bigquery.adoc | 4 +-
.../reference/extensions/google-calendar.adoc | 4 +-
.../pages/reference/extensions/google-drive.adoc | 2 +-
.../pages/reference/extensions/google-mail.adoc | 4 +-
.../pages/reference/extensions/google-pubsub.adoc | 2 +-
.../pages/reference/extensions/google-sheets.adoc | 4 +-
.../ROOT/pages/reference/extensions/graphql.adoc | 2 +-
.../ROOT/pages/reference/extensions/grok.adoc | 2 +-
.../ROOT/pages/reference/extensions/groovy.adoc | 2 +-
.../ROOT/pages/reference/extensions/grpc.adoc | 2 +-
.../ROOT/pages/reference/extensions/gson.adoc | 2 +-
.../pages/reference/extensions/guava-eventbus.adoc | 2 +-
.../ROOT/pages/reference/extensions/hazelcast.adoc | 22 +-
.../ROOT/pages/reference/extensions/hbase.adoc | 2 +-
.../ROOT/pages/reference/extensions/hdfs.adoc | 2 +-
.../pages/reference/extensions/headersmap.adoc | 2 +-
.../ROOT/pages/reference/extensions/hl7.adoc | 4 +-
.../ROOT/pages/reference/extensions/http.adoc | 4 +-
.../ROOT/pages/reference/extensions/hystrix.adoc | 2 +-
.../ROOT/pages/reference/extensions/ical.adoc | 2 +-
.../ROOT/pages/reference/extensions/iec60870.adoc | 4 +-
.../ROOT/pages/reference/extensions/ignite.adoc | 14 +-
.../pages/reference/extensions/infinispan.adoc | 2 +-
.../ROOT/pages/reference/extensions/influxdb.adoc | 2 +-
.../ROOT/pages/reference/extensions/iota.adoc | 2 +-
.../ROOT/pages/reference/extensions/ipfs.adoc | 2 +-
.../ROOT/pages/reference/extensions/irc.adoc | 2 +-
.../ROOT/pages/reference/extensions/jackson.adoc | 2 +-
.../pages/reference/extensions/jacksonxml.adoc | 2 +-
.../ROOT/pages/reference/extensions/jasypt.adoc | 2 +-
.../ROOT/pages/reference/extensions/jaxb.adoc | 2 +-
.../ROOT/pages/reference/extensions/jbpm.adoc | 2 +-
.../ROOT/pages/reference/extensions/jcache.adoc | 2 +-
.../ROOT/pages/reference/extensions/jclouds.adoc | 2 +-
.../ROOT/pages/reference/extensions/jcr.adoc | 2 +-
.../ROOT/pages/reference/extensions/jdbc.adoc | 2 +-
.../pages/reference/extensions/jgroups-raft.adoc | 2 +-
.../ROOT/pages/reference/extensions/jgroups.adoc | 2 +-
.../ROOT/pages/reference/extensions/jing.adoc | 2 +-
.../ROOT/pages/reference/extensions/jira.adoc | 2 +-
.../ROOT/pages/reference/extensions/jms.adoc | 2 +-
.../ROOT/pages/reference/extensions/johnzon.adoc | 2 +-
.../ROOT/pages/reference/extensions/jolt.adoc | 2 +-
.../ROOT/pages/reference/extensions/jooq.adoc | 2 +-
.../ROOT/pages/reference/extensions/jpa.adoc | 2 +-
.../ROOT/pages/reference/extensions/jsch.adoc | 2 +-
.../ROOT/pages/reference/extensions/jslt.adoc | 2 +-
.../pages/reference/extensions/json-validator.adoc | 2 +-
.../ROOT/pages/reference/extensions/jsonapi.adoc | 2 +-
.../ROOT/pages/reference/extensions/jsonpath.adoc | 2 +-
.../ROOT/pages/reference/extensions/jt400.adoc | 2 +-
.../ROOT/pages/reference/extensions/jta.adoc | 2 +-
.../ROOT/pages/reference/extensions/kafka.adoc | 2 +-
.../pages/reference/extensions/kubernetes.adoc | 33 +-
.../ROOT/pages/reference/extensions/kudu.adoc | 2 +-
.../ROOT/pages/reference/extensions/language.adoc | 2 +-
.../ROOT/pages/reference/extensions/ldap.adoc | 2 +-
.../ROOT/pages/reference/extensions/ldif.adoc | 2 +-
.../ROOT/pages/reference/extensions/leveldb.adoc | 2 +-
.../ROOT/pages/reference/extensions/log.adoc | 2 +-
.../ROOT/pages/reference/extensions/lra.adoc | 2 +-
.../ROOT/pages/reference/extensions/lucene.adoc | 2 +-
.../pages/reference/extensions/lumberjack.adoc | 2 +-
.../ROOT/pages/reference/extensions/lzf.adoc | 2 +-
.../ROOT/pages/reference/extensions/mail.adoc | 14 +-
.../ROOT/pages/reference/extensions/master.adoc | 2 +-
.../extensions/microprofile-fault-tolerance.adoc | 2 +-
.../reference/extensions/microprofile-health.adoc | 4 +-
.../reference/extensions/microprofile-metrics.adoc | 6 +-
.../ROOT/pages/reference/extensions/milo.adoc | 4 +-
.../ROOT/pages/reference/extensions/mllp.adoc | 2 +-
.../ROOT/pages/reference/extensions/mock.adoc | 2 +-
.../pages/reference/extensions/mongodb-gridfs.adoc | 2 +-
.../ROOT/pages/reference/extensions/mongodb.adoc | 2 +-
.../ROOT/pages/reference/extensions/msv.adoc | 2 +-
.../ROOT/pages/reference/extensions/mustache.adoc | 2 +-
.../ROOT/pages/reference/extensions/mvel.adoc | 4 +-
.../ROOT/pages/reference/extensions/mybatis.adoc | 4 +-
.../ROOT/pages/reference/extensions/nagios.adoc | 10 +-
.../ROOT/pages/reference/extensions/nats.adoc | 2 +-
.../pages/reference/extensions/netty-http.adoc | 2 +-
.../ROOT/pages/reference/extensions/netty.adoc | 2 +-
.../ROOT/pages/reference/extensions/nitrite.adoc | 2 +-
.../ROOT/pages/reference/extensions/nsq.adoc | 2 +-
.../ROOT/pages/reference/extensions/ognl.adoc | 2 +-
.../ROOT/pages/reference/extensions/olingo4.adoc | 2 +-
.../pages/reference/extensions/openapi-java.adoc | 2 +-
.../ROOT/pages/reference/extensions/openstack.adoc | 12 +-
.../pages/reference/extensions/opentracing.adoc | 2 +-
.../pages/reference/extensions/optaplanner.adoc | 2 +-
.../ROOT/pages/reference/extensions/paho.adoc | 2 +-
.../ROOT/pages/reference/extensions/pdf.adoc | 2 +-
.../reference/extensions/pg-replication-slot.adoc | 2 +-
.../ROOT/pages/reference/extensions/pgevent.adoc | 30 +-
.../pages/reference/extensions/platform-http.adoc | 2 +-
.../ROOT/pages/reference/extensions/printer.adoc | 2 +-
.../ROOT/pages/reference/extensions/protobuf.adoc | 2 +-
.../ROOT/pages/reference/extensions/pubnub.adoc | 2 +-
.../ROOT/pages/reference/extensions/pulsar.adoc | 2 +-
.../ROOT/pages/reference/extensions/quartz.adoc | 2 +-
.../ROOT/pages/reference/extensions/quickfix.adoc | 2 +-
.../ROOT/pages/reference/extensions/rabbitmq.adoc | 2 +-
.../reference/extensions/reactive-executor.adoc | 2 +-
.../reference/extensions/reactive-streams.adoc | 2 +-
.../ROOT/pages/reference/extensions/ref.adoc | 2 +-
.../pages/reference/extensions/rest-openapi.adoc | 2 +-
.../ROOT/pages/reference/extensions/rest.adoc | 4 +-
.../ROOT/pages/reference/extensions/ribbon.adoc | 2 +-
.../pages/reference/extensions/robotframework.adoc | 2 +-
.../ROOT/pages/reference/extensions/rss.adoc | 4 +-
.../ROOT/pages/reference/extensions/saga.adoc | 10 +-
.../pages/reference/extensions/salesforce.adoc | 2 +-
.../pages/reference/extensions/sap-netweaver.adoc | 2 +-
.../ROOT/pages/reference/extensions/saxon.adoc | 4 +-
.../ROOT/pages/reference/extensions/scheduler.adoc | 2 +-
.../pages/reference/extensions/schematron.adoc | 2 +-
.../ROOT/pages/reference/extensions/seda.adoc | 2 +-
.../pages/reference/extensions/servicenow.adoc | 2 +-
.../ROOT/pages/reference/extensions/servlet.adoc | 2 +-
.../ROOT/pages/reference/extensions/shiro.adoc | 2 +-
.../ROOT/pages/reference/extensions/sip.adoc | 4 +-
.../ROOT/pages/reference/extensions/sjms.adoc | 4 +-
.../ROOT/pages/reference/extensions/sjms2.adoc | 2 +-
.../ROOT/pages/reference/extensions/slack.adoc | 2 +-
.../ROOT/pages/reference/extensions/smpp.adoc | 4 +-
.../ROOT/pages/reference/extensions/snakeyaml.adoc | 2 +-
.../ROOT/pages/reference/extensions/snmp.adoc | 2 +-
.../ROOT/pages/reference/extensions/soap.adoc | 2 +-
.../ROOT/pages/reference/extensions/solr.adoc | 6 +-
.../ROOT/pages/reference/extensions/soroush.adoc | 2 +-
.../ROOT/pages/reference/extensions/spark.adoc | 2 +-
.../pages/reference/extensions/splunk-hec.adoc | 2 +-
.../ROOT/pages/reference/extensions/splunk.adoc | 2 +-
.../ROOT/pages/reference/extensions/sql.adoc | 4 +-
.../ROOT/pages/reference/extensions/ssh.adoc | 2 +-
.../ROOT/pages/reference/extensions/stax.adoc | 2 +-
.../ROOT/pages/reference/extensions/stomp.adoc | 2 +-
.../ROOT/pages/reference/extensions/stream.adoc | 2 +-
.../pages/reference/extensions/stringtemplate.adoc | 2 +-
.../ROOT/pages/reference/extensions/stub.adoc | 2 +-
.../ROOT/pages/reference/extensions/syslog.adoc | 2 +-
.../ROOT/pages/reference/extensions/tagsoup.adoc | 2 +-
.../ROOT/pages/reference/extensions/tarfile.adoc | 2 +-
.../ROOT/pages/reference/extensions/telegram.adoc | 2 +-
.../extensions/threadpoolfactory-vertx.adoc | 2 +-
.../ROOT/pages/reference/extensions/thrift.adoc | 4 +-
.../ROOT/pages/reference/extensions/tika.adoc | 2 +-
.../ROOT/pages/reference/extensions/timer.adoc | 2 +-
.../ROOT/pages/reference/extensions/twilio.adoc | 16 +-
.../ROOT/pages/reference/extensions/twitter.adoc | 6 +-
.../reference/extensions/univocity-parsers.adoc | 6 +-
.../ROOT/pages/reference/extensions/validator.adoc | 2 +-
.../ROOT/pages/reference/extensions/velocity.adoc | 2 +-
.../pages/reference/extensions/vertx-http.adoc | 2 +-
.../reference/extensions/vertx-websocket.adoc | 2 +-
.../ROOT/pages/reference/extensions/vertx.adoc | 2 +-
.../ROOT/pages/reference/extensions/vm.adoc | 2 +-
.../ROOT/pages/reference/extensions/weather.adoc | 2 +-
.../ROOT/pages/reference/extensions/web3j.adoc | 2 +-
.../reference/extensions/websocket-jsr356.adoc | 2 +-
.../ROOT/pages/reference/extensions/weka.adoc | 2 +-
.../ROOT/pages/reference/extensions/wordpress.adoc | 2 +-
.../ROOT/pages/reference/extensions/workday.adoc | 2 +-
.../ROOT/pages/reference/extensions/xchange.adoc | 2 +-
.../ROOT/pages/reference/extensions/xj.adoc | 2 +-
.../ROOT/pages/reference/extensions/xml-jaxp.adoc | 2 +-
.../pages/reference/extensions/xmlsecurity.adoc | 6 +-
.../ROOT/pages/reference/extensions/xmpp.adoc | 2 +-
.../ROOT/pages/reference/extensions/xpath.adoc | 2 +-
.../pages/reference/extensions/xslt-saxon.adoc | 2 +-
.../ROOT/pages/reference/extensions/xslt.adoc | 2 +-
.../ROOT/pages/reference/extensions/xstream.adoc | 4 +-
.../ROOT/pages/reference/extensions/yammer.adoc | 2 +-
.../ROOT/pages/reference/extensions/zendesk.adoc | 16 +-
.../pages/reference/extensions/zip-deflater.adoc | 4 +-
.../ROOT/pages/reference/extensions/zipfile.adoc | 2 +-
.../reference/extensions/zookeeper-master.adoc | 2 +-
.../ROOT/pages/reference/extensions/zookeeper.adoc | 2 +-
docs/modules/ROOT/pages/user-guide/bootstrap.adoc | 6 +-
.../modules/ROOT/pages/user-guide/native-mode.adoc | 2 +-
.../ROOT/pages/user-guide/observability.adoc | 2 +-
.../reference/components/aws2-eventbridge.adoc | 14 +-
.../components/kubernetes-custom-resources.adoc | 13 +
.../ROOT/partials/reference/components/nagios.adoc | 6 +-
.../ROOT/partials/reference/components/saga.adoc | 6 +-
.../ROOT/partials/reference/components/twilio.adoc | 6 +-
.../partials/reference/components/zendesk.adoc | 6 +-
docs/pom.xml | 4 +-
.../core/deployment/CamelBootstrapProcessor.java | 3 +-
.../core/deployment/CamelContextProcessor.java | 3 +-
.../quarkus/core/deployment/CamelProcessor.java | 8 +
.../core/deployment/spi/CamelRuntimeBuildItem.java | 4 -
.../org/apache/camel/quarkus/core/BaseModel.java | 102 ++-
.../camel/quarkus/core/CamelConfigFlags.java | 7 -
.../camel/quarkus/core/FastCamelContext.java | 49 +-
.../camel/quarkus/core/FastTypeConverter.java | 2 +-
.../{saga => aws2-eventbridge}/deployment/pom.xml | 12 +-
.../deployment/Aws2EventbridgeProcessor.java} | 8 +-
.../integration-test/pom.xml | 15 +-
.../eventbridge/it/Aws2EventbridgeResource.java} | 20 +-
.../aws2/eventbridge/it/Aws2EventbridgeTest.java} | 8 +-
extensions-jvm/{saga => aws2-eventbridge}/pom.xml | 8 +-
.../{saga => aws2-eventbridge}/runtime/pom.xml | 17 +-
.../main/resources/META-INF/quarkus-extension.yaml | 6 +-
extensions-jvm/pom.xml | 5 +-
extensions-jvm/saga/integration-test/pom.xml | 83 ---
.../twilio/deployment/TwilioProcessor.java | 46 --
extensions-jvm/twilio/integration-test/pom.xml | 82 ---
.../src/main/resources/application.properties | 20 -
extensions-jvm/zendesk/integration-test/pom.xml | 78 ---
.../component/zendesk/it/ZendeskResource.java | 51 --
.../geocoder/deployment/GeocoderProcessor.java | 1 +
.../MicroprofileFaultToleranceProcessor.java | 8 +
.../runtime/src/main/doc/usage.adoc | 2 +-
.../runtime/src/main/doc/usage.adoc | 6 +-
.../nagios/deployment/pom.xml | 0
.../nagios/deployment/NagiosProcessor.java | 14 -
{extensions-jvm => extensions}/nagios/pom.xml | 1 -
.../nagios/runtime/pom.xml | 1 +
.../main/resources/META-INF/quarkus-extension.yaml | 3 +-
extensions/pgevent/deployment/pom.xml | 4 +
.../pgevent/deployment/PgeventProcessor.java | 14 +
extensions/pgevent/runtime/pom.xml | 5 +
.../runtime/src/main/doc/configuration.adoc | 24 +
extensions/pom.xml | 4 +
.../component/qute/QuteComponentConfigurer.java | 9 +
.../component/qute/QuteEndpointConfigurer.java | 9 +
.../saga/deployment/pom.xml | 0
.../component/saga/deployment/SagaProcessor.java | 24 +-
{extensions-jvm => extensions}/saga/pom.xml | 1 -
.../saga/runtime/pom.xml | 1 +
.../main/resources/META-INF/quarkus-extension.yaml | 3 +-
.../twilio/deployment/pom.xml | 8 +
.../twilio/deployment/TwilioProcessor.java | 95 +++
{extensions-jvm => extensions}/twilio/pom.xml | 1 -
.../twilio/runtime/pom.xml | 9 +
.../main/resources/META-INF/quarkus-extension.yaml | 3 +-
.../zendesk/deployment/pom.xml | 8 +
.../zendesk/deployment/ZendeskProcessor.java | 36 +-
{extensions-jvm => extensions}/zendesk/pom.xml | 1 -
.../zendesk/runtime/pom.xml | 9 +
.../main/resources/META-INF/quarkus-extension.yaml | 3 +-
integration-tests-support/pom.xml | 1 +
integration-tests-support/wiremock/README.adoc | 48 ++
.../wiremock}/pom.xml | 51 +-
.../camel/quarkus/test/wiremock/MockServer.java | 28 +-
.../WireMockTestResourceLifecycleManager.java | 233 +++++++
integration-tests/geocoder/README.adoc | 10 +
integration-tests/geocoder/pom.xml | 2 +-
.../geocoder/it/GeocoderGoogleResource.java | 6 +-
.../component/geocoder/it/GeocoderProducers.java | 55 ++
.../quarkus/component/geocoder/it/Routes.java | 129 ----
.../src/main/resources/application.properties | 8 +-
.../component/geocoder/it/GeocoderGoogleTest.java | 25 +-
.../geocoder/it/GeocoderNominationTest.java | 2 +
.../geocoder/it/GeocoderTestResource.java | 25 +-
.../test/resources/__files/mapsApiAddresses.json | 771 +++++++++++++++++++++
.../resources/mappings/geocodeGetFromAddress.json | 28 +
.../resources/mappings/geocodeGetFromFile.json | 29 +
.../resources/mappings/geocodeGetFromLatLng.json | 28 +
integration-tests/{geocoder => nagios}/pom.xml | 64 +-
.../component/nagios/it/NagiosResource.java | 42 +-
.../quarkus/component/nagios/it/NagiosIT.java} | 11 +-
.../quarkus/component/nagios/it/NagiosTest.java | 25 +-
.../component/nagios/it/NagiosTestResource.java | 130 ++++
.../quarkus/component/olingo4/it/Olingo4IT.java | 2 +
integration-tests/pgevent/pom.xml | 14 +-
.../component/pgevent/it/PgeventRoutes.java | 38 +-
.../src/main/resources/application.properties | 13 +-
.../component/pgevent/it/PgEventTestResource.java | 4 +-
integration-tests/pom.xml | 4 +
integration-tests/{pgevent => saga}/pom.xml | 47 +-
.../quarkus/component/saga/it/CreditService.java | 49 +-
.../component/saga/it/OrderManagerService.java} | 26 +-
.../quarkus/component/saga/it/SagaResource.java | 47 ++
.../camel/quarkus/component/saga/it/SagaRoute.java | 68 ++
.../camel/quarkus/component/saga/it/SagaTest.java | 7 +
.../quarkus/component/saga/it/SagaTestIT.java} | 4 +-
integration-tests/servicenow/README.adoc | 10 +
integration-tests/servicenow/pom.xml | 5 +
.../servicenow/it/ServicenowResource.java | 2 +-
.../component/servicenow/it/model/Incident.java | 2 +
.../src/main/resources/application.properties | 23 -
.../component/servicenow/it/ServicenowIT.java | 4 -
.../component/servicenow/it/ServicenowTest.java | 6 +-
.../servicenow/it/ServicenowTestResource.java | 54 ++
.../mappings/servicenowConfirmDeleteIncident.json | 29 +
.../mappings/servicenowCreateIncident.json | 33 +
.../mappings/servicenowDeleteIncident.json | 22 +
.../resources/mappings/servicenowGetIncident.json | 30 +
integration-tests/slack/README.adoc | 24 +
integration-tests/slack/pom.xml | 4 +
.../quarkus/component/slack/it/SlackResource.java | 2 +-
.../quarkus/component/slack/it/SlackRoutes.java | 48 --
.../src/main/resources/application.properties | 21 -
.../quarkus/component/slack/it/SlackTest.java | 7 +-
.../component/slack/it/SlackTestResource.java | 55 ++
.../test/resources/mappings/slackGetChannels.json | 37 +
.../mappings/slackGetConversationHistory.json | 37 +
.../resources/mappings/slackWebhookMesagePost.json | 30 +
integration-tests/telegram/README.adoc | 16 +-
integration-tests/telegram/pom.xml | 9 +-
.../component/telegram/it/TelegramResource.java | 2 +-
.../component/telegram/it/TelegramRoutes.java | 110 ---
.../src/main/resources/application.properties | 12 +-
.../mock-messages/editMessageLiveLocation.json | 24 -
.../main/resources/mock-messages/getUpdates.json | 41 --
.../main/resources/mock-messages/sendAudio.json | 25 -
.../main/resources/mock-messages/sendDocument.json | 24 -
.../main/resources/mock-messages/sendLocation.json | 23 -
.../main/resources/mock-messages/sendMessage.json | 20 -
.../main/resources/mock-messages/sendPhoto.json | 27 -
.../main/resources/mock-messages/sendVenue.json | 31 -
.../main/resources/mock-messages/sendVideo.json | 33 -
.../mock-messages/stopMessageLiveLocation.json | 24 -
.../component/telegram/it/TelegramTest.java | 26 +-
.../telegram/it/TelegramTestResource.java | 47 ++
.../mappings/telegramEditMessageLiveLocation.json | 26 +
.../test/resources/mappings/telegramSendAudio.json | 24 +
.../resources/mappings/telegramSendDocument.json | 24 +
.../resources/mappings/telegramSendLocation.json | 26 +
.../resources/mappings/telegramSendMessage.json | 26 +
.../test/resources/mappings/telegramSendPhoto.json | 24 +
.../test/resources/mappings/telegramSendVenue.json | 26 +
.../test/resources/mappings/telegramSendVideo.json | 24 +
.../mappings/telegramStopMessageLiveAction.json | 26 +
integration-tests/twilio/README.adoc | 22 +
integration-tests/{geocoder => twilio}/pom.xml | 35 +-
.../component/twilio/it/TwilioResource.java | 129 ++++
.../quarkus/component/twilio/it/TwilioIT.java | 16 +-
.../quarkus/component/twilio/it/TwilioTest.java | 75 ++
.../component/twilio/it/TwilioTestResource.java | 51 ++
.../test/resources/mappings/twilioPhoneCall.json | 31 +
.../resources/mappings/twilioPurchaseNumber.json | 31 +
.../test/resources/mappings/twilioSendMessage.json | 31 +
integration-tests/zendesk/README.adoc | 22 +
integration-tests/{geocoder => zendesk}/pom.xml | 35 +-
.../component/zendesk/it/ZendeskResource.java | 69 ++
.../quarkus/component/zendesk/it/ZendeskIT.java} | 4 +-
.../quarkus/component/zendesk/it/ZendeskTest.java | 66 ++
.../component/zendesk/it/ZendeskTestResource.java | 53 ++
.../mappings/zendeskConfirmTicketDelete.json | 40 ++
.../resources/mappings/zendeskCreateTicket.json | 46 ++
.../resources/mappings/zendeskDeleteTicket.json | 37 +
.../test/resources/mappings/zendeskGetTicket.json | 43 ++
pom.xml | 5 +-
poms/bom-test/pom.xml | 28 +
poms/bom/pom.xml | 15 +
.../integration-test-pom.xml | 16 -
tooling/create-extension-templates/runtime-pom.xml | 40 +-
.../quarkus/maven/UpdateExtensionDocPageMojo.java | 4 +-
tooling/scripts/test-categories.yaml | 6 +-
472 files changed, 4354 insertions(+), 1915 deletions(-)
create mode 100644 .github/workflows/generate-jvm-extension.yaml
copy docs/modules/ROOT/pages/reference/extensions/{asn1.adoc => aws2-eventbridge.adoc} (53%)
create mode 100644 docs/modules/ROOT/partials/reference/components/kubernetes-custom-resources.adoc
copy extensions-jvm/{saga => aws2-eventbridge}/deployment/pom.xml (80%)
rename extensions-jvm/{saga/deployment/src/main/java/org/apache/camel/quarkus/component/saga/deployment/SagaProcessor.java => aws2-eventbridge/deployment/src/main/java/org/apache/camel/quarkus/component/aws2/eventbridge/deployment/Aws2EventbridgeProcessor.java} (86%)
rename extensions-jvm/{nagios => aws2-eventbridge}/integration-test/pom.xml (82%)
rename extensions-jvm/{nagios/integration-test/src/main/java/org/apache/camel/quarkus/component/nagios/it/NagiosResource.java => aws2-eventbridge/integration-test/src/main/java/org/apache/camel/quarkus/component/aws2/eventbridge/it/Aws2EventbridgeResource.java} (68%)
rename extensions-jvm/{zendesk/integration-test/src/test/java/org/apache/camel/quarkus/component/zendesk/it/ZendeskTest.java => aws2-eventbridge/integration-test/src/test/java/org/apache/camel/quarkus/component/aws2/eventbridge/it/Aws2EventbridgeTest.java} (82%)
copy extensions-jvm/{saga => aws2-eventbridge}/pom.xml (79%)
copy extensions-jvm/{saga => aws2-eventbridge}/runtime/pom.xml (84%)
copy extensions-jvm/{twilio => aws2-eventbridge}/runtime/src/main/resources/META-INF/quarkus-extension.yaml (88%)
delete mode 100644 extensions-jvm/saga/integration-test/pom.xml
delete mode 100644 extensions-jvm/twilio/deployment/src/main/java/org/apache/camel/quarkus/component/twilio/deployment/TwilioProcessor.java
delete mode 100644 extensions-jvm/twilio/integration-test/pom.xml
delete mode 100644 extensions-jvm/twilio/integration-test/src/main/resources/application.properties
delete mode 100644 extensions-jvm/zendesk/integration-test/pom.xml
delete mode 100644 extensions-jvm/zendesk/integration-test/src/main/java/org/apache/camel/quarkus/component/zendesk/it/ZendeskResource.java
rename {extensions-jvm => extensions}/nagios/deployment/pom.xml (100%)
rename {extensions-jvm => extensions}/nagios/deployment/src/main/java/org/apache/camel/quarkus/component/nagios/deployment/NagiosProcessor.java (68%)
rename {extensions-jvm => extensions}/nagios/pom.xml (97%)
rename {extensions-jvm => extensions}/nagios/runtime/pom.xml (98%)
rename {extensions-jvm => extensions}/nagios/runtime/src/main/resources/META-INF/quarkus-extension.yaml (97%)
create mode 100644 extensions/pgevent/runtime/src/main/doc/configuration.adoc
rename {extensions-jvm => extensions}/saga/deployment/pom.xml (100%)
copy extensions-jvm/nagios/integration-test/src/test/java/org/apache/camel/quarkus/component/nagios/it/NagiosTest.java => extensions/saga/deployment/src/main/java/org/apache/camel/quarkus/component/saga/deployment/SagaProcessor.java (64%)
rename {extensions-jvm => extensions}/saga/pom.xml (97%)
rename {extensions-jvm => extensions}/saga/runtime/pom.xml (98%)
rename {extensions-jvm => extensions}/saga/runtime/src/main/resources/META-INF/quarkus-extension.yaml (97%)
rename {extensions-jvm => extensions}/twilio/deployment/pom.xml (88%)
create mode 100644 extensions/twilio/deployment/src/main/java/org/apache/camel/quarkus/component/twilio/deployment/TwilioProcessor.java
rename {extensions-jvm => extensions}/twilio/pom.xml (97%)
rename {extensions-jvm => extensions}/twilio/runtime/pom.xml (91%)
rename {extensions-jvm => extensions}/twilio/runtime/src/main/resources/META-INF/quarkus-extension.yaml (97%)
rename {extensions-jvm => extensions}/zendesk/deployment/pom.xml (88%)
rename {extensions-jvm => extensions}/zendesk/deployment/src/main/java/org/apache/camel/quarkus/component/zendesk/deployment/ZendeskProcessor.java (52%)
rename {extensions-jvm => extensions}/zendesk/pom.xml (97%)
rename {extensions-jvm => extensions}/zendesk/runtime/pom.xml (91%)
rename {extensions-jvm => extensions}/zendesk/runtime/src/main/resources/META-INF/quarkus-extension.yaml (97%)
create mode 100644 integration-tests-support/wiremock/README.adoc
copy {extensions/pgevent/deployment => integration-tests-support/wiremock}/pom.xml (59%)
copy extensions-jvm/saga/integration-test/src/test/java/org/apache/camel/quarkus/component/saga/it/SagaTest.java => integration-tests-support/wiremock/src/main/java/org/apache/camel/quarkus/test/wiremock/MockServer.java (63%)
create mode 100644 integration-tests-support/wiremock/src/main/java/org/apache/camel/quarkus/test/wiremock/WireMockTestResourceLifecycleManager.java
create mode 100644 integration-tests/geocoder/src/main/java/org/apache/camel/quarkus/component/geocoder/it/GeocoderProducers.java
delete mode 100644 integration-tests/geocoder/src/main/java/org/apache/camel/quarkus/component/geocoder/it/Routes.java
copy extensions-jvm/twilio/integration-test/src/test/java/org/apache/camel/quarkus/component/twilio/it/TwilioTest.java => integration-tests/geocoder/src/test/java/org/apache/camel/quarkus/component/geocoder/it/GeocoderTestResource.java (57%)
create mode 100644 integration-tests/geocoder/src/test/resources/__files/mapsApiAddresses.json
create mode 100644 integration-tests/geocoder/src/test/resources/mappings/geocodeGetFromAddress.json
create mode 100644 integration-tests/geocoder/src/test/resources/mappings/geocodeGetFromFile.json
create mode 100644 integration-tests/geocoder/src/test/resources/mappings/geocodeGetFromLatLng.json
copy integration-tests/{geocoder => nagios}/pom.xml (78%)
rename extensions-jvm/twilio/integration-test/src/main/java/org/apache/camel/quarkus/component/twilio/it/TwilioResource.java => integration-tests/nagios/src/main/java/org/apache/camel/quarkus/component/nagios/it/NagiosResource.java (50%)
copy integration-tests/{pgevent/src/main/java/org/apache/camel/quarkus/component/pgevent/it/MyBean.java => nagios/src/test/java/org/apache/camel/quarkus/component/nagios/it/NagiosIT.java} (76%)
rename {extensions-jvm/nagios/integration-test => integration-tests/nagios}/src/test/java/org/apache/camel/quarkus/component/nagios/it/NagiosTest.java (54%)
create mode 100644 integration-tests/nagios/src/test/java/org/apache/camel/quarkus/component/nagios/it/NagiosTestResource.java
copy integration-tests/{pgevent => saga}/pom.xml (87%)
copy extensions-jvm/saga/integration-test/src/main/java/org/apache/camel/quarkus/component/saga/it/SagaResource.java => integration-tests/saga/src/main/java/org/apache/camel/quarkus/component/saga/it/CreditService.java (50%)
rename integration-tests/{pgevent/src/main/java/org/apache/camel/quarkus/component/pgevent/it/MyBean.java => saga/src/main/java/org/apache/camel/quarkus/component/saga/it/OrderManagerService.java} (62%)
rename {extensions-jvm/saga/integration-test => integration-tests/saga}/src/main/java/org/apache/camel/quarkus/component/saga/it/SagaResource.java (56%)
create mode 100644 integration-tests/saga/src/main/java/org/apache/camel/quarkus/component/saga/it/SagaRoute.java
rename {extensions-jvm/saga/integration-test => integration-tests/saga}/src/test/java/org/apache/camel/quarkus/component/saga/it/SagaTest.java (88%)
copy integration-tests/{olingo4/src/test/java/org/apache/camel/quarkus/component/olingo4/it/Olingo4IT.java => saga/src/test/java/org/apache/camel/quarkus/component/saga/it/SagaTestIT.java} (90%)
delete mode 100644 integration-tests/servicenow/src/main/resources/application.properties
create mode 100644 integration-tests/servicenow/src/test/java/org/apache/camel/quarkus/component/servicenow/it/ServicenowTestResource.java
create mode 100644 integration-tests/servicenow/src/test/resources/mappings/servicenowConfirmDeleteIncident.json
create mode 100644 integration-tests/servicenow/src/test/resources/mappings/servicenowCreateIncident.json
create mode 100644 integration-tests/servicenow/src/test/resources/mappings/servicenowDeleteIncident.json
create mode 100644 integration-tests/servicenow/src/test/resources/mappings/servicenowGetIncident.json
create mode 100644 integration-tests/slack/README.adoc
delete mode 100644 integration-tests/slack/src/main/java/org/apache/camel/quarkus/component/slack/it/SlackRoutes.java
delete mode 100644 integration-tests/slack/src/main/resources/application.properties
create mode 100644 integration-tests/slack/src/test/java/org/apache/camel/quarkus/component/slack/it/SlackTestResource.java
create mode 100644 integration-tests/slack/src/test/resources/mappings/slackGetChannels.json
create mode 100644 integration-tests/slack/src/test/resources/mappings/slackGetConversationHistory.json
create mode 100644 integration-tests/slack/src/test/resources/mappings/slackWebhookMesagePost.json
delete mode 100644 integration-tests/telegram/src/main/java/org/apache/camel/quarkus/component/telegram/it/TelegramRoutes.java
delete mode 100644 integration-tests/telegram/src/main/resources/mock-messages/editMessageLiveLocation.json
delete mode 100644 integration-tests/telegram/src/main/resources/mock-messages/getUpdates.json
delete mode 100644 integration-tests/telegram/src/main/resources/mock-messages/sendAudio.json
delete mode 100644 integration-tests/telegram/src/main/resources/mock-messages/sendDocument.json
delete mode 100644 integration-tests/telegram/src/main/resources/mock-messages/sendLocation.json
delete mode 100644 integration-tests/telegram/src/main/resources/mock-messages/sendMessage.json
delete mode 100644 integration-tests/telegram/src/main/resources/mock-messages/sendPhoto.json
delete mode 100644 integration-tests/telegram/src/main/resources/mock-messages/sendVenue.json
delete mode 100644 integration-tests/telegram/src/main/resources/mock-messages/sendVideo.json
delete mode 100644 integration-tests/telegram/src/main/resources/mock-messages/stopMessageLiveLocation.json
create mode 100644 integration-tests/telegram/src/test/java/org/apache/camel/quarkus/component/telegram/it/TelegramTestResource.java
create mode 100644 integration-tests/telegram/src/test/resources/mappings/telegramEditMessageLiveLocation.json
create mode 100644 integration-tests/telegram/src/test/resources/mappings/telegramSendAudio.json
create mode 100644 integration-tests/telegram/src/test/resources/mappings/telegramSendDocument.json
create mode 100644 integration-tests/telegram/src/test/resources/mappings/telegramSendLocation.json
create mode 100644 integration-tests/telegram/src/test/resources/mappings/telegramSendMessage.json
create mode 100644 integration-tests/telegram/src/test/resources/mappings/telegramSendPhoto.json
create mode 100644 integration-tests/telegram/src/test/resources/mappings/telegramSendVenue.json
create mode 100644 integration-tests/telegram/src/test/resources/mappings/telegramSendVideo.json
create mode 100644 integration-tests/telegram/src/test/resources/mappings/telegramStopMessageLiveAction.json
create mode 100644 integration-tests/twilio/README.adoc
copy integration-tests/{geocoder => twilio}/pom.xml (85%)
create mode 100644 integration-tests/twilio/src/main/java/org/apache/camel/quarkus/component/twilio/it/TwilioResource.java
rename extensions-jvm/twilio/integration-test/src/test/java/org/apache/camel/quarkus/component/twilio/it/TwilioTest.java => integration-tests/twilio/src/test/java/org/apache/camel/quarkus/component/twilio/it/TwilioIT.java (70%)
create mode 100644 integration-tests/twilio/src/test/java/org/apache/camel/quarkus/component/twilio/it/TwilioTest.java
create mode 100644 integration-tests/twilio/src/test/java/org/apache/camel/quarkus/component/twilio/it/TwilioTestResource.java
create mode 100644 integration-tests/twilio/src/test/resources/mappings/twilioPhoneCall.json
create mode 100644 integration-tests/twilio/src/test/resources/mappings/twilioPurchaseNumber.json
create mode 100644 integration-tests/twilio/src/test/resources/mappings/twilioSendMessage.json
create mode 100644 integration-tests/zendesk/README.adoc
copy integration-tests/{geocoder => zendesk}/pom.xml (85%)
create mode 100644 integration-tests/zendesk/src/main/java/org/apache/camel/quarkus/component/zendesk/it/ZendeskResource.java
copy integration-tests/{olingo4/src/test/java/org/apache/camel/quarkus/component/olingo4/it/Olingo4IT.java => zendesk/src/test/java/org/apache/camel/quarkus/component/zendesk/it/ZendeskIT.java} (90%)
create mode 100644 integration-tests/zendesk/src/test/java/org/apache/camel/quarkus/component/zendesk/it/ZendeskTest.java
create mode 100644 integration-tests/zendesk/src/test/java/org/apache/camel/quarkus/component/zendesk/it/ZendeskTestResource.java
create mode 100644 integration-tests/zendesk/src/test/resources/mappings/zendeskConfirmTicketDelete.json
create mode 100644 integration-tests/zendesk/src/test/resources/mappings/zendeskCreateTicket.json
create mode 100644 integration-tests/zendesk/src/test/resources/mappings/zendeskDeleteTicket.json
create mode 100644 integration-tests/zendesk/src/test/resources/mappings/zendeskGetTicket.json
[camel-quarkus] 02/02: Temporarily disable failing antora xref check
Posted by ja...@apache.org.
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 8b197bd787bdd0a75d4130155bca2a0278730a93
Author: James Netherton <ja...@gmail.com>
AuthorDate: Thu Nov 5 14:52:19 2020 +0000
Temporarily disable failing antora xref check
---
docs/pom.xml | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
diff --git a/docs/pom.xml b/docs/pom.xml
index 5e75ce8..66f18e0 100644
--- a/docs/pom.xml
+++ b/docs/pom.xml
@@ -102,6 +102,7 @@
<commandlineArgs>${project.basedir}/node/yarn/dist/bin/yarn.js install --no-progress --force --non-interactive --frozen-lockfile</commandlineArgs>
</configuration>
</execution>
+ <!-- TODO: Reinstate this - https://github.com/apache/camel-quarkus/issues/1996
<execution>
<id>antora-xref-check</id>
<goals>
@@ -110,9 +111,10 @@
<phase>verify</phase>
<configuration>
<executable>${project.basedir}/node/node</executable>
- <commandlineArgs>${project.basedir}/node/yarn/dist/bin/yarn.js --non-interactive antora --generator @antora/xref-validator antora-playbook.yml</commandlineArgs>
+ <commandlineArgs>${project.basedir}/node/yarn/dist/bin/yarn.js --non-interactive antora --generator @antora/xref-validator antora-playbook.yml</commandlineArgs>
</configuration>
</execution>
+ -->
</executions>
</plugin>
</plugins>
[camel-quarkus] 01/02: Upgrade to Camel 3.7.0
Posted by ja...@apache.org.
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 704b03f59eb9683ad1b1b3af7279248e2f2e5cee
Author: James Netherton <ja...@gmail.com>
AuthorDate: Mon Oct 19 07:16:38 2020 +0100
Upgrade to Camel 3.7.0
---
.../pages/reference/extensions/kubernetes.adoc | 1 +
.../ROOT/pages/reference/extensions/leveldb.adoc | 12 ++-
.../partials/reference/components/atlasmap.adoc | 1 +
.../components/kubernetes-custom-resources.adoc | 13 +++
.../partials/reference/dataformats/json-jsonb.adoc | 1 +
.../ROOT/partials/reference/languages/joor.adoc | 1 +
.../partials/reference/others/leveldb-legacy.adoc | 1 +
.../quarkus/core/deployment/CamelProcessor.java | 8 ++
extensions-core/core/runtime/pom.xml | 16 +--
.../org/apache/camel/quarkus/core/BaseModel.java | 31 ++++--
.../camel/quarkus/core/FastCamelContext.java | 117 +++++++++++++++------
.../org/apache/camel/quarkus/core/FastModel.java | 1 -
.../camel/quarkus/core/FastTypeConverter.java | 2 +-
extensions/json-validator/runtime/pom.xml | 4 +
.../leveldb/runtime/src/main/doc/limitations.adoc | 12 ++-
.../component/leveldb/ObjectCodecSubstitute.java | 64 -----------
.../QuarkusLevelDBAggregationRepository.java | 71 +++++++++++++
.../MicroprofileFaultToleranceProcessor.java | 8 ++
.../component/qute/QuteComponentConfigurer.java | 9 ++
.../component/qute/QuteEndpointConfigurer.java | 9 ++
.../component/qute/QuteEndpointUriFactory.java | 4 +-
.../component/foundation/it/mock/MockResource.java | 4 +-
.../component/leveldb/it/LeveldbRouteBuilder.java | 10 +-
.../quarkus/component/leveldb/it/LeveldbIT.java | 4 -
.../quarkus/component/leveldb/it/LeveldbTest.java | 14 +--
.../camel/quarkus/component/saga/it/SagaRoute.java | 2 +-
pom.xml | 3 +-
poms/bom/pom.xml | 10 ++
28 files changed, 285 insertions(+), 148 deletions(-)
diff --git a/docs/modules/ROOT/pages/reference/extensions/kubernetes.adoc b/docs/modules/ROOT/pages/reference/extensions/kubernetes.adoc
index 03778ed..05cfc34 100644
--- a/docs/modules/ROOT/pages/reference/extensions/kubernetes.adoc
+++ b/docs/modules/ROOT/pages/reference/extensions/kubernetes.adoc
@@ -18,6 +18,7 @@ Perform operations against Kubernetes API
== What's inside
* xref:latest@components::kubernetes-config-maps-component.adoc[Kubernetes ConfigMap component], URI syntax: `kubernetes-config-maps:masterUrl`
+* xref:latest@components::kubernetes-custom-resources-component.adoc[Kubernetes Custom Resources component], URI syntax: `kubernetes-custom-resources:masterUrl`
* xref:latest@components::kubernetes-deployments-component.adoc[Kubernetes Deployments component], URI syntax: `kubernetes-deployments:masterUrl`
* xref:latest@components::kubernetes-hpa-component.adoc[Kubernetes HPA component], URI syntax: `kubernetes-hpa:masterUrl`
* xref:latest@components::kubernetes-job-component.adoc[Kubernetes Job component], URI syntax: `kubernetes-job:masterUrl`
diff --git a/docs/modules/ROOT/pages/reference/extensions/leveldb.adoc b/docs/modules/ROOT/pages/reference/extensions/leveldb.adoc
index fda4ef0..190fc8d 100644
--- a/docs/modules/ROOT/pages/reference/extensions/leveldb.adoc
+++ b/docs/modules/ROOT/pages/reference/extensions/leveldb.adoc
@@ -38,8 +38,14 @@ In native mode the extension uses a port of LevelDB written in Java (https://git
which is within 10% of the performance of the C++ original. Please upvote https://github.com/apache/camel-quarkus/issues/1911[this issue]
if you do not like the present state.
-This extension does not support binary payloads in native mode since object serialization is https://github.com/oracle/graal/issues/460[not supported] on GraalVM. To work around this limitation, the extension instead uses Jackson serializaton / deserialization.
+Serialization is https://github.com/oracle/graal/issues/460[not supported] on GraalVM. Extension has to use serializationization based
+on Jackson. Aggregation repository in native has to be constructed in one of the following ways:
+
+* Use class `QuarkusLevelDBAggregationRepository` instead of `LevelDBAggregationRepository`.
+* Configure jackson serializer on `LevelDBAggregationRepository` by calling `repo.setSerializer(new JacksonLevelDBSerializer());`
+
+Jackson serializer has limitation towards binary content. If payload object contains binary data (does not concern payloads which are completely binary), Jackson serialization and deserialization won't work correctly.
+To avoid this, define your own jackson serializer/deserealizer via `Module` and provide it to the aggragation repository
+(you can use for example the constructor of `QuarkusLevelDBAggregationRepository`).
-The problem will be solved when the camel-leveldb component is refactored to use Jackson and custom
-serializers (see https://issues.apache.org/jira/browse/CAMEL-15679[issue])
diff --git a/docs/modules/ROOT/partials/reference/components/atlasmap.adoc b/docs/modules/ROOT/partials/reference/components/atlasmap.adoc
new file mode 100644
index 0000000..a509c1d
--- /dev/null
+++ b/docs/modules/ROOT/partials/reference/components/atlasmap.adoc
@@ -0,0 +1 @@
+// Empty partial for a Camel bit unsupported by Camel Quarkus to avoid warnings when this file is included from a Camel page
diff --git a/docs/modules/ROOT/partials/reference/components/kubernetes-custom-resources.adoc b/docs/modules/ROOT/partials/reference/components/kubernetes-custom-resources.adoc
new file mode 100644
index 0000000..07f368a
--- /dev/null
+++ b/docs/modules/ROOT/partials/reference/components/kubernetes-custom-resources.adoc
@@ -0,0 +1,13 @@
+// Do not edit directly!
+// This file was generated by camel-quarkus-maven-plugin:update-extension-doc-page
+:cq-artifact-id: camel-quarkus-kubernetes
+:cq-artifact-id-base: kubernetes
+:cq-native-supported: true
+:cq-status: Stable
+:cq-deprecated: false
+:cq-jvm-since: 1.0.0
+:cq-native-since: 1.0.0
+:cq-camel-part-name: kubernetes-custom-resources
+:cq-camel-part-title: Kubernetes Custom Resources
+:cq-camel-part-description: Perform operations on Kubernetes Custom Resources and get notified on Deployment changes.
+:cq-extension-page-title: Kubernetes
diff --git a/docs/modules/ROOT/partials/reference/dataformats/json-jsonb.adoc b/docs/modules/ROOT/partials/reference/dataformats/json-jsonb.adoc
new file mode 100644
index 0000000..a509c1d
--- /dev/null
+++ b/docs/modules/ROOT/partials/reference/dataformats/json-jsonb.adoc
@@ -0,0 +1 @@
+// Empty partial for a Camel bit unsupported by Camel Quarkus to avoid warnings when this file is included from a Camel page
diff --git a/docs/modules/ROOT/partials/reference/languages/joor.adoc b/docs/modules/ROOT/partials/reference/languages/joor.adoc
new file mode 100644
index 0000000..a509c1d
--- /dev/null
+++ b/docs/modules/ROOT/partials/reference/languages/joor.adoc
@@ -0,0 +1 @@
+// Empty partial for a Camel bit unsupported by Camel Quarkus to avoid warnings when this file is included from a Camel page
diff --git a/docs/modules/ROOT/partials/reference/others/leveldb-legacy.adoc b/docs/modules/ROOT/partials/reference/others/leveldb-legacy.adoc
new file mode 100644
index 0000000..a509c1d
--- /dev/null
+++ b/docs/modules/ROOT/partials/reference/others/leveldb-legacy.adoc
@@ -0,0 +1 @@
+// Empty partial for a Camel bit unsupported by Camel Quarkus to avoid warnings when this file is included from a Camel page
diff --git a/extensions-core/core/deployment/src/main/java/org/apache/camel/quarkus/core/deployment/CamelProcessor.java b/extensions-core/core/deployment/src/main/java/org/apache/camel/quarkus/core/deployment/CamelProcessor.java
index 4b542c9..7efea5e 100644
--- a/extensions-core/core/deployment/src/main/java/org/apache/camel/quarkus/core/deployment/CamelProcessor.java
+++ b/extensions-core/core/deployment/src/main/java/org/apache/camel/quarkus/core/deployment/CamelProcessor.java
@@ -40,6 +40,7 @@ import io.quarkus.deployment.annotations.Overridable;
import io.quarkus.deployment.annotations.Record;
import io.quarkus.deployment.builditem.ApplicationArchivesBuildItem;
import io.quarkus.deployment.builditem.CombinedIndexBuildItem;
+import io.quarkus.deployment.builditem.nativeimage.NativeImageResourceBuildItem;
import io.quarkus.deployment.recording.RecorderContext;
import io.quarkus.runtime.RuntimeValue;
import org.apache.camel.impl.converter.BaseTypeConverterRegistry;
@@ -346,4 +347,11 @@ class CamelProcessor {
.map(CamelRoutesBuilderClassBuildItem::new)
.collect(Collectors.toList());
}
+
+ @BuildStep
+ NativeImageResourceBuildItem initResources() {
+ return new NativeImageResourceBuildItem(
+ "META-INF/services/org/apache/camel/bean-processor-factory",
+ "META-INF/services/org/apache/camel/rest-registry-factory");
+ }
}
diff --git a/extensions-core/core/runtime/pom.xml b/extensions-core/core/runtime/pom.xml
index 0f2a2c8..9688e0c 100644
--- a/extensions-core/core/runtime/pom.xml
+++ b/extensions-core/core/runtime/pom.xml
@@ -66,27 +66,31 @@
<dependency>
<groupId>org.apache.camel</groupId>
- <artifactId>camel-core-engine</artifactId>
+ <artifactId>camel-base</artifactId>
</dependency>
<dependency>
<groupId>org.apache.camel</groupId>
- <artifactId>camel-base</artifactId>
+ <artifactId>camel-componentdsl</artifactId>
</dependency>
<dependency>
<groupId>org.apache.camel</groupId>
- <artifactId>camel-core-languages</artifactId>
+ <artifactId>camel-core-catalog</artifactId>
</dependency>
<dependency>
<groupId>org.apache.camel</groupId>
- <artifactId>camel-endpointdsl</artifactId>
+ <artifactId>camel-core-engine</artifactId>
</dependency>
<dependency>
<groupId>org.apache.camel</groupId>
- <artifactId>camel-componentdsl</artifactId>
+ <artifactId>camel-core-languages</artifactId>
</dependency>
<dependency>
<groupId>org.apache.camel</groupId>
- <artifactId>camel-core-catalog</artifactId>
+ <artifactId>camel-core-processor</artifactId>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.camel</groupId>
+ <artifactId>camel-endpointdsl</artifactId>
</dependency>
<dependency>
<groupId>org.apache.camel</groupId>
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 8ee50e0..df3c89a 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
@@ -29,6 +29,7 @@ import java.util.function.Function;
import org.apache.camel.CamelContext;
import org.apache.camel.ExtendedCamelContext;
+import org.apache.camel.impl.DefaultModelReifierFactory;
import org.apache.camel.model.DataFormatDefinition;
import org.apache.camel.model.FaultToleranceConfigurationDefinition;
import org.apache.camel.model.HystrixConfigurationDefinition;
@@ -46,6 +47,7 @@ import org.apache.camel.model.cloud.ServiceCallConfigurationDefinition;
import org.apache.camel.model.rest.RestDefinition;
import org.apache.camel.model.transformer.TransformerDefinition;
import org.apache.camel.model.validator.ValidatorDefinition;
+import org.apache.camel.spi.ModelReifierFactory;
import org.apache.camel.spi.NodeIdFactory;
import org.apache.camel.util.AntPathMatcher;
@@ -53,6 +55,7 @@ public abstract class BaseModel implements Model {
private final CamelContext camelContext;
+ private ModelReifierFactory modelReifierFactory = new DefaultModelReifierFactory();
private final List<RouteDefinition> routeDefinitions = new ArrayList<>();
private final List<RouteTemplateDefinition> routeTemplateDefinitions = new ArrayList<>();
private final List<RestDefinition> restDefinitions = new ArrayList<>();
@@ -201,10 +204,11 @@ public abstract class BaseModel implements Model {
throw new IllegalArgumentException("Cannot find RouteTemplate with id " + routeTemplateId);
}
- StringJoiner templatesBuilder = new StringJoiner(", ");
final Map<String, Object> prop = new HashMap<>();
// include default values first from the template (and validate that we have inputs for all required parameters)
if (target.getTemplateParameters() != null) {
+ StringJoiner templatesBuilder = new StringJoiner(", ");
+
for (RouteTemplateParameterDefinition temp : target.getTemplateParameters()) {
if (temp.getDefaultValue() != null) {
prop.put(temp.getName(), temp.getDefaultValue());
@@ -215,18 +219,19 @@ public abstract class BaseModel implements Model {
}
}
}
+ if (templatesBuilder.length() > 0) {
+ throw new IllegalArgumentException(
+ "Route template " + routeTemplateId + " the following mandatory parameters must be provided: "
+ + templatesBuilder.toString());
+ }
}
- if (templatesBuilder.length() > 0) {
- throw new IllegalArgumentException(
- "Route template " + routeTemplateId + " the following mandatory parameters must be provided: "
- + templatesBuilder.toString());
- }
+
// then override with user parameters
if (parameters != null) {
prop.putAll(parameters);
}
- RouteTemplateDefinition.Converter converter = RouteTemplateDefinition::asRouteDefinition;
+ RouteTemplateDefinition.Converter converter = RouteTemplateDefinition.Converter.DEFAULT_CONVERTER;
for (Map.Entry<String, RouteTemplateDefinition.Converter> entry : routeTemplateConverters.entrySet()) {
final String key = entry.getKey();
@@ -244,7 +249,7 @@ public abstract class BaseModel implements Model {
}
}
- RouteDefinition def = converter.apply(target);
+ RouteDefinition def = converter.apply(target, prop);
if (routeId != null) {
def.setId(routeId);
}
@@ -476,6 +481,16 @@ public abstract class BaseModel implements Model {
return modelLifecycleStrategies;
}
+ @Override
+ public ModelReifierFactory getModelReifierFactory() {
+ return modelReifierFactory;
+ }
+
+ @Override
+ public void setModelReifierFactory(ModelReifierFactory modelReifierFactory) {
+ this.modelReifierFactory = modelReifierFactory;
+ }
+
/**
* Should we start newly added routes?
*/
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 4ca613e..fd96350 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
@@ -22,10 +22,8 @@ import java.util.Collection;
import java.util.List;
import java.util.Map;
import java.util.Properties;
-import java.util.concurrent.ExecutorService;
import java.util.function.Function;
-import org.apache.camel.AsyncProcessor;
import org.apache.camel.CatalogCamelContext;
import org.apache.camel.Component;
import org.apache.camel.Endpoint;
@@ -36,12 +34,12 @@ import org.apache.camel.Processor;
import org.apache.camel.Route;
import org.apache.camel.TypeConverter;
import org.apache.camel.ValueHolder;
+import org.apache.camel.builder.AdviceWith;
import org.apache.camel.builder.AdviceWithRouteBuilder;
import org.apache.camel.catalog.RuntimeCamelCatalog;
import org.apache.camel.catalog.impl.DefaultRuntimeCamelCatalog;
import org.apache.camel.component.microprofile.config.CamelMicroProfilePropertiesSource;
import org.apache.camel.health.HealthCheckRegistry;
-import org.apache.camel.impl.DefaultExecutorServiceManager;
import org.apache.camel.impl.engine.AbstractCamelContext;
import org.apache.camel.impl.engine.BaseServiceResolver;
import org.apache.camel.impl.engine.DefaultAsyncProcessorAwaitManager;
@@ -54,17 +52,19 @@ import org.apache.camel.impl.engine.DefaultComponentResolver;
import org.apache.camel.impl.engine.DefaultConfigurerResolver;
import org.apache.camel.impl.engine.DefaultDataFormatResolver;
import org.apache.camel.impl.engine.DefaultEndpointRegistry;
+import org.apache.camel.impl.engine.DefaultExecutorServiceManager;
import org.apache.camel.impl.engine.DefaultHeadersMapFactory;
import org.apache.camel.impl.engine.DefaultInflightRepository;
import org.apache.camel.impl.engine.DefaultInjector;
+import org.apache.camel.impl.engine.DefaultInterceptEndpointFactory;
import org.apache.camel.impl.engine.DefaultLanguageResolver;
import org.apache.camel.impl.engine.DefaultMessageHistoryFactory;
import org.apache.camel.impl.engine.DefaultNodeIdFactory;
import org.apache.camel.impl.engine.DefaultPackageScanClassResolver;
import org.apache.camel.impl.engine.DefaultPackageScanResourceResolver;
-import org.apache.camel.impl.engine.DefaultProcessorFactory;
import org.apache.camel.impl.engine.DefaultReactiveExecutor;
import org.apache.camel.impl.engine.DefaultRouteController;
+import org.apache.camel.impl.engine.DefaultRouteFactory;
import org.apache.camel.impl.engine.DefaultStreamCachingStrategy;
import org.apache.camel.impl.engine.DefaultTracer;
import org.apache.camel.impl.engine.DefaultTransformerRegistry;
@@ -73,8 +73,8 @@ import org.apache.camel.impl.engine.DefaultUriFactoryResolver;
import org.apache.camel.impl.engine.DefaultValidatorRegistry;
import org.apache.camel.impl.engine.EndpointKey;
import org.apache.camel.impl.engine.RouteService;
-import org.apache.camel.impl.transformer.TransformerKey;
-import org.apache.camel.impl.validator.ValidatorKey;
+import org.apache.camel.impl.engine.TransformerKey;
+import org.apache.camel.impl.engine.ValidatorKey;
import org.apache.camel.model.DataFormatDefinition;
import org.apache.camel.model.FaultToleranceConfigurationDefinition;
import org.apache.camel.model.HystrixConfigurationDefinition;
@@ -91,12 +91,16 @@ import org.apache.camel.model.language.ExpressionDefinition;
import org.apache.camel.model.rest.RestDefinition;
import org.apache.camel.model.transformer.TransformerDefinition;
import org.apache.camel.model.validator.ValidatorDefinition;
-import org.apache.camel.processor.MulticastProcessor;
+import org.apache.camel.processor.DefaultAnnotationBasedProcessorFactory;
+import org.apache.camel.processor.DefaultDeferServiceFactory;
+import org.apache.camel.processor.DefaultInternalProcessorFactory;
+import org.apache.camel.processor.DefaultProcessorFactory;
import org.apache.camel.reifier.RouteReifier;
import org.apache.camel.reifier.errorhandler.ErrorHandlerReifier;
import org.apache.camel.reifier.language.ExpressionReifier;
import org.apache.camel.reifier.transformer.TransformerReifier;
import org.apache.camel.reifier.validator.ValidatorReifier;
+import org.apache.camel.spi.AnnotationBasedProcessorFactory;
import org.apache.camel.spi.AsyncProcessorAwaitManager;
import org.apache.camel.spi.BeanIntrospection;
import org.apache.camel.spi.BeanProcessorFactory;
@@ -110,17 +114,21 @@ import org.apache.camel.spi.ConfigurerResolver;
import org.apache.camel.spi.DataFormat;
import org.apache.camel.spi.DataFormatResolver;
import org.apache.camel.spi.DataType;
+import org.apache.camel.spi.DeferServiceFactory;
import org.apache.camel.spi.EndpointRegistry;
import org.apache.camel.spi.ExecutorServiceManager;
import org.apache.camel.spi.FactoryFinderResolver;
import org.apache.camel.spi.HeadersMapFactory;
import org.apache.camel.spi.InflightRepository;
import org.apache.camel.spi.Injector;
+import org.apache.camel.spi.InterceptEndpointFactory;
+import org.apache.camel.spi.InternalProcessorFactory;
import org.apache.camel.spi.Language;
import org.apache.camel.spi.LanguageResolver;
import org.apache.camel.spi.ManagementNameStrategy;
import org.apache.camel.spi.MessageHistoryFactory;
import org.apache.camel.spi.ModelJAXBContextFactory;
+import org.apache.camel.spi.ModelReifierFactory;
import org.apache.camel.spi.ModelToXMLDumper;
import org.apache.camel.spi.NodeIdFactory;
import org.apache.camel.spi.PackageScanClassResolver;
@@ -132,6 +140,7 @@ import org.apache.camel.spi.Registry;
import org.apache.camel.spi.RestBindingJaxbDataFormatFactory;
import org.apache.camel.spi.RestRegistryFactory;
import org.apache.camel.spi.RouteController;
+import org.apache.camel.spi.RouteFactory;
import org.apache.camel.spi.ShutdownStrategy;
import org.apache.camel.spi.StreamCachingStrategy;
import org.apache.camel.spi.Tracer;
@@ -150,7 +159,7 @@ import org.apache.camel.util.IOHelper;
import org.apache.camel.util.ObjectHelper;
public class FastCamelContext extends AbstractCamelContext implements CatalogCamelContext, ModelCamelContext {
- private final Model model;
+ private Model model;
private final String version;
private final XMLRoutesDefinitionLoader xmlLoader;
private final ModelToXMLDumper modelDumper;
@@ -275,6 +284,21 @@ public class FastCamelContext extends AbstractCamelContext implements CatalogCam
}
@Override
+ protected InternalProcessorFactory createInternalProcessorFactory() {
+ return new DefaultInternalProcessorFactory();
+ }
+
+ @Override
+ protected InterceptEndpointFactory createInterceptEndpointFactory() {
+ return new DefaultInterceptEndpointFactory();
+ }
+
+ @Override
+ protected RouteFactory createRouteFactory() {
+ return new DefaultRouteFactory();
+ }
+
+ @Override
protected MessageHistoryFactory createMessageHistoryFactory() {
return new DefaultMessageHistoryFactory();
}
@@ -320,18 +344,30 @@ public class FastCamelContext extends AbstractCamelContext implements CatalogCam
@Override
protected BeanProxyFactory createBeanProxyFactory() {
- return new BaseServiceResolver<>(BeanProxyFactory.FACTORY, BeanProxyFactory.class)
- .resolve(getCamelContextReference())
- .orElseThrow(() -> new IllegalArgumentException("Cannot find BeanProxyFactory on classpath. "
- + "Add camel-bean to classpath."));
+ return new BaseServiceResolver<>(BeanProxyFactory.FACTORY, BeanProxyFactory.class,
+ getBootstrapFactoryFinder())
+ .resolve(getCamelContextReference())
+ .orElseThrow(() -> new IllegalArgumentException("Cannot find BeanProxyFactory on classpath. "
+ + "Add camel-bean to classpath."));
+ }
+
+ @Override
+ protected AnnotationBasedProcessorFactory createAnnotationBasedProcessorFactory() {
+ return new DefaultAnnotationBasedProcessorFactory();
+ }
+
+ @Override
+ protected DeferServiceFactory createDeferServiceFactory() {
+ return new DefaultDeferServiceFactory();
}
@Override
protected BeanProcessorFactory createBeanProcessorFactory() {
- return new BaseServiceResolver<>(BeanProcessorFactory.FACTORY, BeanProcessorFactory.class)
- .resolve(getCamelContextReference())
- .orElseThrow(() -> new IllegalArgumentException("Cannot find BeanProcessorFactory on classpath. "
- + "Add camel-bean to classpath."));
+ return new BaseServiceResolver<>(BeanProcessorFactory.FACTORY, BeanProcessorFactory.class,
+ getBootstrapFactoryFinder())
+ .resolve(getCamelContextReference())
+ .orElseThrow(() -> new IllegalArgumentException("Cannot find BeanProcessorFactory on classpath. "
+ + "Add camel-bean to classpath."));
}
@Override
@@ -393,10 +429,11 @@ public class FastCamelContext extends AbstractCamelContext implements CatalogCam
@Override
protected RestRegistryFactory createRestRegistryFactory() {
- return new BaseServiceResolver<>(RestRegistryFactory.FACTORY, RestRegistryFactory.class)
- .resolve(getCamelContextReference())
- .orElseThrow(() -> new IllegalArgumentException("Cannot find RestRegistryFactory on classpath. "
- + "Add camel-rest to classpath."));
+ return new BaseServiceResolver<>(RestRegistryFactory.FACTORY, RestRegistryFactory.class,
+ getBootstrapFactoryFinder())
+ .resolve(getCamelContextReference())
+ .orElseThrow(() -> new IllegalArgumentException("Cannot find RestRegistryFactory on classpath. "
+ + "Add camel-rest to classpath."));
}
@Override
@@ -425,14 +462,6 @@ public class FastCamelContext extends AbstractCamelContext implements CatalogCam
}
@Override
- public AsyncProcessor createMulticast(Collection<Processor> processors, ExecutorService executor,
- boolean shutdownExecutorService) {
- return new MulticastProcessor(getCamelContextReference(), null, processors, null,
- true, executor, shutdownExecutorService, false, false,
- 0, null, false, false);
- }
-
- @Override
protected ConfigurerResolver createConfigurerResolver() {
return new DefaultConfigurerResolver();
}
@@ -444,8 +473,9 @@ public class FastCamelContext extends AbstractCamelContext implements CatalogCam
@Override
protected HealthCheckRegistry createHealthCheckRegistry() {
- return new BaseServiceResolver<>(HealthCheckRegistry.FACTORY, HealthCheckRegistry.class)
- .resolve(getCamelContextReference()).orElse(null);
+ return new BaseServiceResolver<>(HealthCheckRegistry.FACTORY, HealthCheckRegistry.class,
+ getBootstrapFactoryFinder())
+ .resolve(getCamelContextReference()).orElse(null);
}
@Override
@@ -455,10 +485,12 @@ public class FastCamelContext extends AbstractCamelContext implements CatalogCam
@Override
protected RestBindingJaxbDataFormatFactory createRestBindingJaxbDataFormatFactory() {
- return new BaseServiceResolver<>(RestBindingJaxbDataFormatFactory.FACTORY, RestBindingJaxbDataFormatFactory.class)
- .resolve(getCamelContextReference())
- .orElseThrow(() -> new IllegalArgumentException("Cannot find RestBindingJaxbDataFormatFactory on classpath. "
- + "Add camel-jaxb to classpath."));
+ return new BaseServiceResolver<>(RestBindingJaxbDataFormatFactory.FACTORY, RestBindingJaxbDataFormatFactory.class,
+ getBootstrapFactoryFinder())
+ .resolve(getCamelContextReference())
+ .orElseThrow(
+ () -> new IllegalArgumentException("Cannot find RestBindingJaxbDataFormatFactory on classpath. "
+ + "Add camel-jaxb to classpath."));
}
@Override
@@ -576,6 +608,11 @@ public class FastCamelContext extends AbstractCamelContext implements CatalogCam
.createErrorHandler(processor);
}
+ @Override
+ public void disposeModel() {
+ this.model = null;
+ }
+
//
// ModelCamelContext
//
@@ -804,6 +841,16 @@ public class FastCamelContext extends AbstractCamelContext implements CatalogCam
}
@Override
+ public ModelReifierFactory getModelReifierFactory() {
+ return model.getModelReifierFactory();
+ }
+
+ @Override
+ public void setModelReifierFactory(ModelReifierFactory modelReifierFactory) {
+ model.setModelReifierFactory(modelReifierFactory);
+ }
+
+ @Override
public void startRouteDefinitions(List<RouteDefinition> routeDefinitions) throws Exception {
// indicate we are staring the route using this thread so
// we are able to query this if needed
@@ -860,7 +907,7 @@ public class FastCamelContext extends AbstractCamelContext implements CatalogCam
@Override
public RouteDefinition adviceWith(RouteDefinition definition, AdviceWithRouteBuilder builder) throws Exception {
- return RouteReifier.adviceWith(definition, this, builder);
+ return AdviceWith.adviceWith(definition, this, builder);
}
@SuppressWarnings("unchecked")
diff --git a/extensions-core/core/runtime/src/main/java/org/apache/camel/quarkus/core/FastModel.java b/extensions-core/core/runtime/src/main/java/org/apache/camel/quarkus/core/FastModel.java
index fd299a8..f266f57 100644
--- a/extensions-core/core/runtime/src/main/java/org/apache/camel/quarkus/core/FastModel.java
+++ b/extensions-core/core/runtime/src/main/java/org/apache/camel/quarkus/core/FastModel.java
@@ -22,5 +22,4 @@ public class FastModel extends BaseModel {
public FastModel(CamelContext camelContext) {
super(camelContext);
}
-
}
diff --git a/extensions-core/core/runtime/src/main/java/org/apache/camel/quarkus/core/FastTypeConverter.java b/extensions-core/core/runtime/src/main/java/org/apache/camel/quarkus/core/FastTypeConverter.java
index 6492338..2df9239 100644
--- a/extensions-core/core/runtime/src/main/java/org/apache/camel/quarkus/core/FastTypeConverter.java
+++ b/extensions-core/core/runtime/src/main/java/org/apache/camel/quarkus/core/FastTypeConverter.java
@@ -25,7 +25,7 @@ public class FastTypeConverter extends DefaultTypeConverter {
private static final Logger LOG = LoggerFactory.getLogger(FastTypeConverter.class);
public FastTypeConverter() {
- super(null, null, null, null, false);
+ super(null, null, null, false);
}
@Override
diff --git a/extensions/json-validator/runtime/pom.xml b/extensions/json-validator/runtime/pom.xml
index cb6ee35..d94e66e 100644
--- a/extensions/json-validator/runtime/pom.xml
+++ b/extensions/json-validator/runtime/pom.xml
@@ -56,6 +56,10 @@
<groupId>org.apache.camel</groupId>
<artifactId>camel-json-validator</artifactId>
</dependency>
+ <dependency>
+ <groupId>org.jruby.joni</groupId>
+ <artifactId>joni</artifactId>
+ </dependency>
</dependencies>
<build>
diff --git a/extensions/leveldb/runtime/src/main/doc/limitations.adoc b/extensions/leveldb/runtime/src/main/doc/limitations.adoc
index e7ebff9..9b74c99 100644
--- a/extensions/leveldb/runtime/src/main/doc/limitations.adoc
+++ b/extensions/leveldb/runtime/src/main/doc/limitations.adoc
@@ -2,7 +2,13 @@ In native mode the extension uses a port of LevelDB written in Java (https://git
which is within 10% of the performance of the C++ original. Please upvote https://github.com/apache/camel-quarkus/issues/1911[this issue]
if you do not like the present state.
-This extension does not support binary payloads in native mode since object serialization is https://github.com/oracle/graal/issues/460[not supported] on GraalVM. To work around this limitation, the extension instead uses Jackson serializaton / deserialization.
+Serialization is https://github.com/oracle/graal/issues/460[not supported] on GraalVM. Extension has to use serializationization based
+on Jackson. Aggregation repository in native has to be constructed in one of the following ways:
+
+* Use class `QuarkusLevelDBAggregationRepository` instead of `LevelDBAggregationRepository`.
+* Configure jackson serializer on `LevelDBAggregationRepository` by calling `repo.setSerializer(new JacksonLevelDBSerializer());`
+
+Jackson serializer has limitation towards binary content. If payload object contains binary data (does not concern payloads which are completely binary), Jackson serialization and deserialization won't work correctly.
+To avoid this, define your own jackson serializer/deserealizer via `Module` and provide it to the aggragation repository
+(you can use for example the constructor of `QuarkusLevelDBAggregationRepository`).
-The problem will be solved when the camel-leveldb component is refactored to use Jackson and custom
-serializers (see https://issues.apache.org/jira/browse/CAMEL-15679[issue])
diff --git a/extensions/leveldb/runtime/src/main/java/org/apache/camel/quarkus/component/leveldb/ObjectCodecSubstitute.java b/extensions/leveldb/runtime/src/main/java/org/apache/camel/quarkus/component/leveldb/ObjectCodecSubstitute.java
deleted file mode 100644
index 8ab38a4..0000000
--- a/extensions/leveldb/runtime/src/main/java/org/apache/camel/quarkus/component/leveldb/ObjectCodecSubstitute.java
+++ /dev/null
@@ -1,64 +0,0 @@
-/*
- * 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.leveldb;
-
-import java.io.DataInput;
-import java.io.DataOutput;
-import java.io.IOException;
-
-import com.fasterxml.jackson.annotation.JsonAutoDetect;
-import com.fasterxml.jackson.annotation.PropertyAccessor;
-import com.fasterxml.jackson.databind.ObjectMapper;
-import com.oracle.svm.core.annotate.Inject;
-import com.oracle.svm.core.annotate.Substitute;
-import com.oracle.svm.core.annotate.TargetClass;
-import org.apache.camel.support.DefaultExchangeHolder;
-import org.fusesource.hawtbuf.codec.ObjectCodec;
-
-/**
- * This os workaround for serialization of DefaultExchangeHolder.
- * Once serialization is implemented in graalVM (see https://github.com/oracle/graal/issues/460), this substitution
- * could
- * be removed.
- */
-@TargetClass(value = ObjectCodec.class)
-final class ObjectCodecSubstitute {
-
- @Inject
- private ObjectMapper objectMapper;
-
- @Substitute
- public void encode(Object object, DataOutput dataOut) throws IOException {
- if (objectMapper == null) {
- objectMapper = new ObjectMapper();
- objectMapper.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.NONE);
- objectMapper.setVisibility(PropertyAccessor.FIELD, JsonAutoDetect.Visibility.ANY);
- }
- objectMapper.writeValue(dataOut, object);
- }
-
- @Substitute
- public Object decode(DataInput dataIn) throws IOException {
- if (objectMapper == null) {
- objectMapper = new ObjectMapper();
- objectMapper.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.NONE);
- objectMapper.setVisibility(PropertyAccessor.FIELD, JsonAutoDetect.Visibility.ANY);
- }
- return objectMapper.readValue(dataIn, DefaultExchangeHolder.class);
- }
-
-}
diff --git a/extensions/leveldb/runtime/src/main/java/org/apache/camel/quarkus/component/leveldb/QuarkusLevelDBAggregationRepository.java b/extensions/leveldb/runtime/src/main/java/org/apache/camel/quarkus/component/leveldb/QuarkusLevelDBAggregationRepository.java
new file mode 100644
index 0000000..7e930ec
--- /dev/null
+++ b/extensions/leveldb/runtime/src/main/java/org/apache/camel/quarkus/component/leveldb/QuarkusLevelDBAggregationRepository.java
@@ -0,0 +1,71 @@
+/*
+ * 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.leveldb;
+
+import com.fasterxml.jackson.databind.Module;
+import org.apache.camel.component.leveldb.LevelDBAggregationRepository;
+import org.apache.camel.component.leveldb.LevelDBFile;
+import org.apache.camel.component.leveldb.serializer.JacksonLevelDBSerializer;
+
+public class QuarkusLevelDBAggregationRepository extends LevelDBAggregationRepository {
+
+ public QuarkusLevelDBAggregationRepository() {
+ initSerializer(null);
+ }
+
+ public QuarkusLevelDBAggregationRepository(String repositoryName) {
+ super(repositoryName);
+ initSerializer(null);
+ }
+
+ public QuarkusLevelDBAggregationRepository(String repositoryName, String persistentFileName) {
+ super(repositoryName, persistentFileName);
+ initSerializer(null);
+ }
+
+ public QuarkusLevelDBAggregationRepository(String repositoryName, LevelDBFile levelDBFile) {
+ super(repositoryName, levelDBFile);
+ initSerializer(null);
+ }
+
+ //constructor with module
+
+ public QuarkusLevelDBAggregationRepository(Module module) {
+ JacksonLevelDBSerializer serializer = new JacksonLevelDBSerializer(module);
+ initSerializer(module);
+ }
+
+ public QuarkusLevelDBAggregationRepository(String repositoryName, Module module) {
+ super(repositoryName);
+ initSerializer(module);
+ }
+
+ public QuarkusLevelDBAggregationRepository(String repositoryName, String persistentFileName, Module module) {
+ super(repositoryName, persistentFileName);
+ initSerializer(module);
+ }
+
+ public QuarkusLevelDBAggregationRepository(String repositoryName, LevelDBFile levelDBFile, Module module) {
+ super(repositoryName, levelDBFile);
+ initSerializer(module);
+ }
+
+ private void initSerializer(Module module) {
+ JacksonLevelDBSerializer serializer = new JacksonLevelDBSerializer(module);
+ setSerializer(serializer);
+ }
+}
diff --git a/extensions/microprofile-fault-tolerance/deployment/src/main/java/org/apache/camel/quarkus/component/microprofile/fault/tolerance/deployment/MicroprofileFaultToleranceProcessor.java b/extensions/microprofile-fault-tolerance/deployment/src/main/java/org/apache/camel/quarkus/component/microprofile/fault/tolerance/deployment/MicroprofileFaultToleranceProcessor.java
index d5b8b14..05673b1 100644
--- a/extensions/microprofile-fault-tolerance/deployment/src/main/java/org/apache/camel/quarkus/component/microprofile/fault/tolerance/deployment/MicroprofileFaultToleranceProcessor.java
+++ b/extensions/microprofile-fault-tolerance/deployment/src/main/java/org/apache/camel/quarkus/component/microprofile/fault/tolerance/deployment/MicroprofileFaultToleranceProcessor.java
@@ -18,6 +18,7 @@ package org.apache.camel.quarkus.component.microprofile.fault.tolerance.deployme
import io.quarkus.deployment.annotations.BuildStep;
import io.quarkus.deployment.builditem.FeatureBuildItem;
+import io.quarkus.deployment.builditem.nativeimage.NativeImageResourceBuildItem;
class MicroprofileFaultToleranceProcessor {
@@ -27,4 +28,11 @@ class MicroprofileFaultToleranceProcessor {
FeatureBuildItem feature() {
return new FeatureBuildItem(FEATURE);
}
+
+ @BuildStep
+ NativeImageResourceBuildItem initResources() {
+ return new NativeImageResourceBuildItem(
+ "META-INF/services/org/apache/camel/model/CircuitBreakerDefinition");
+ }
+
}
diff --git a/extensions/qute/component/src/generated/java/org/apache/camel/component/qute/QuteComponentConfigurer.java b/extensions/qute/component/src/generated/java/org/apache/camel/component/qute/QuteComponentConfigurer.java
index 95e6cc2..eb7658e 100644
--- a/extensions/qute/component/src/generated/java/org/apache/camel/component/qute/QuteComponentConfigurer.java
+++ b/extensions/qute/component/src/generated/java/org/apache/camel/component/qute/QuteComponentConfigurer.java
@@ -4,6 +4,7 @@ package org.apache.camel.component.qute;
import java.util.Map;
import org.apache.camel.CamelContext;
+import org.apache.camel.spi.ConfigurerStrategy;
import org.apache.camel.spi.GeneratedPropertyConfigurer;
import org.apache.camel.spi.PropertyConfigurerGetter;
import org.apache.camel.util.CaseInsensitiveMap;
@@ -23,6 +24,7 @@ public class QuteComponentConfigurer extends PropertyConfigurerSupport implement
map.put("basicPropertyBinding", boolean.class);
map.put("quteEngine", io.quarkus.qute.Engine.class);
ALL_OPTIONS = map;
+ ConfigurerStrategy.addConfigurerClearer(QuteComponentConfigurer::clearConfigurers);
}
@Override
@@ -46,6 +48,13 @@ public class QuteComponentConfigurer extends PropertyConfigurerSupport implement
return ALL_OPTIONS;
}
+ public static void clearBootstrapConfigurers() {
+ }
+
+ public static void clearConfigurers() {
+ ALL_OPTIONS.clear();
+ }
+
@Override
public Object getOptionValue(Object obj, String name, boolean ignoreCase) {
QuteComponent target = (QuteComponent) obj;
diff --git a/extensions/qute/component/src/generated/java/org/apache/camel/component/qute/QuteEndpointConfigurer.java b/extensions/qute/component/src/generated/java/org/apache/camel/component/qute/QuteEndpointConfigurer.java
index 983fa1c..7e61ea5 100644
--- a/extensions/qute/component/src/generated/java/org/apache/camel/component/qute/QuteEndpointConfigurer.java
+++ b/extensions/qute/component/src/generated/java/org/apache/camel/component/qute/QuteEndpointConfigurer.java
@@ -4,6 +4,7 @@ package org.apache.camel.component.qute;
import java.util.Map;
import org.apache.camel.CamelContext;
+import org.apache.camel.spi.ConfigurerStrategy;
import org.apache.camel.spi.GeneratedPropertyConfigurer;
import org.apache.camel.spi.PropertyConfigurerGetter;
import org.apache.camel.util.CaseInsensitiveMap;
@@ -27,6 +28,7 @@ public class QuteEndpointConfigurer extends PropertyConfigurerSupport implements
map.put("basicPropertyBinding", boolean.class);
map.put("synchronous", boolean.class);
ALL_OPTIONS = map;
+ ConfigurerStrategy.addConfigurerClearer(QuteEndpointConfigurer::clearConfigurers);
}
@Override
@@ -54,6 +56,13 @@ public class QuteEndpointConfigurer extends PropertyConfigurerSupport implements
return ALL_OPTIONS;
}
+ public static void clearBootstrapConfigurers() {
+ }
+
+ public static void clearConfigurers() {
+ ALL_OPTIONS.clear();
+ }
+
@Override
public Object getOptionValue(Object obj, String name, boolean ignoreCase) {
QuteEndpoint target = (QuteEndpoint) obj;
diff --git a/extensions/qute/component/src/generated/java/org/apache/camel/component/qute/QuteEndpointUriFactory.java b/extensions/qute/component/src/generated/java/org/apache/camel/component/qute/QuteEndpointUriFactory.java
index f24c41f..28b192e 100644
--- a/extensions/qute/component/src/generated/java/org/apache/camel/component/qute/QuteEndpointUriFactory.java
+++ b/extensions/qute/component/src/generated/java/org/apache/camel/component/qute/QuteEndpointUriFactory.java
@@ -39,14 +39,14 @@ public class QuteEndpointUriFactory extends org.apache.camel.support.component.E
}
@Override
- public String buildUri(String scheme, Map<String, Object> properties) throws URISyntaxException {
+ public String buildUri(String scheme, Map<String, Object> properties, boolean encode) throws URISyntaxException {
String syntax = scheme + BASE;
String uri = syntax;
Map<String, Object> copy = new HashMap<>(properties);
uri = buildPathParameter(syntax, uri, "resourceUri", null, true, copy);
- uri = buildQueryParameters(uri, copy);
+ uri = buildQueryParameters(uri, copy, encode);
return uri;
}
diff --git a/integration-tests/foundation/src/main/java/org/apache/camel/quarkus/component/foundation/it/mock/MockResource.java b/integration-tests/foundation/src/main/java/org/apache/camel/quarkus/component/foundation/it/mock/MockResource.java
index 6d0e29c..985a507 100644
--- a/integration-tests/foundation/src/main/java/org/apache/camel/quarkus/component/foundation/it/mock/MockResource.java
+++ b/integration-tests/foundation/src/main/java/org/apache/camel/quarkus/component/foundation/it/mock/MockResource.java
@@ -26,10 +26,10 @@ import javax.ws.rs.core.MediaType;
import org.apache.camel.CamelContext;
import org.apache.camel.ProducerTemplate;
+import org.apache.camel.builder.AdviceWith;
import org.apache.camel.builder.AdviceWithRouteBuilder;
import org.apache.camel.component.mock.MockEndpoint;
import org.apache.camel.model.ModelCamelContext;
-import org.apache.camel.reifier.RouteReifier;
import org.jboss.logging.Logger;
import org.wildfly.common.Assert;
@@ -51,7 +51,7 @@ public class MockResource {
// advice the first route using the inlined AdviceWith route builder
// which has extended capabilities than the regular route builder
- RouteReifier.adviceWith(context.adapt(ModelCamelContext.class).getRouteDefinition("forMocking"), context,
+ AdviceWith.adviceWith(context.adapt(ModelCamelContext.class).getRouteDefinition("forMocking"), context,
new AdviceWithRouteBuilder() {
@Override
public void configure() throws Exception {
diff --git a/integration-tests/leveldb/src/main/java/org/apache/camel/quarkus/component/leveldb/it/LeveldbRouteBuilder.java b/integration-tests/leveldb/src/main/java/org/apache/camel/quarkus/component/leveldb/it/LeveldbRouteBuilder.java
index ed9674f..a5f7b8b 100644
--- a/integration-tests/leveldb/src/main/java/org/apache/camel/quarkus/component/leveldb/it/LeveldbRouteBuilder.java
+++ b/integration-tests/leveldb/src/main/java/org/apache/camel/quarkus/component/leveldb/it/LeveldbRouteBuilder.java
@@ -24,6 +24,7 @@ import org.apache.camel.AggregationStrategy;
import org.apache.camel.Exchange;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.component.leveldb.LevelDBAggregationRepository;
+import org.apache.camel.quarkus.component.leveldb.QuarkusLevelDBAggregationRepository;
public class LeveldbRouteBuilder extends RouteBuilder {
public static final String DIRECT_START = "direct:start";
@@ -39,21 +40,22 @@ public class LeveldbRouteBuilder extends RouteBuilder {
@Override
public void configure() throws Exception {
- LevelDBAggregationRepository repo = new LevelDBAggregationRepository("repo", DATA_FOLDER + "leveldb.dat");
+ LevelDBAggregationRepository repo = new QuarkusLevelDBAggregationRepository("repo", DATA_FOLDER + "leveldb.dat");
from(DIRECT_START)
.aggregate(header("id"), new MyAggregationStrategy())
.completionSize(7).aggregationRepository(repo)
.to(MOCK_RESULT);
- LevelDBAggregationRepository repoBinary = new LevelDBAggregationRepository("repo", DATA_FOLDER + "levelBinarydb.dat");
+ LevelDBAggregationRepository repoBinary = new QuarkusLevelDBAggregationRepository("repo",
+ DATA_FOLDER + "levelBinarydb.dat");
from(DIRECT_BINARY)
.aggregate(header("id"), new BinaryAggregationStrategy())
.completionSize(3).aggregationRepository(repoBinary)
.to(MOCK_RESULT);
- LevelDBAggregationRepository repoWithFailure = new LevelDBAggregationRepository("repoWithFailure",
+ LevelDBAggregationRepository repoWithFailure = new QuarkusLevelDBAggregationRepository("repoWithFailure",
DATA_FOLDER + "leveldbWithFailure.dat");
repoWithFailure.setUseRecovery(true);
@@ -72,7 +74,7 @@ public class LeveldbRouteBuilder extends RouteBuilder {
.to(MOCK_RESULT)
.end();
- LevelDBAggregationRepository repoDeadLetter = new LevelDBAggregationRepository("repoDeadLetter",
+ LevelDBAggregationRepository repoDeadLetter = new QuarkusLevelDBAggregationRepository("repoDeadLetter",
DATA_FOLDER + "leveldbDeadLetter.dat");
repoDeadLetter.setUseRecovery(true);
diff --git a/integration-tests/leveldb/src/test/java/org/apache/camel/quarkus/component/leveldb/it/LeveldbIT.java b/integration-tests/leveldb/src/test/java/org/apache/camel/quarkus/component/leveldb/it/LeveldbIT.java
index e4fc4ba..743e2ab 100644
--- a/integration-tests/leveldb/src/test/java/org/apache/camel/quarkus/component/leveldb/it/LeveldbIT.java
+++ b/integration-tests/leveldb/src/test/java/org/apache/camel/quarkus/component/leveldb/it/LeveldbIT.java
@@ -20,8 +20,4 @@ import io.quarkus.test.junit.NativeImageTest;
@NativeImageTest
class LeveldbIT extends LeveldbTest {
- @Override
- boolean doeasBinaryDataWork() {
- return false;
- }
}
diff --git a/integration-tests/leveldb/src/test/java/org/apache/camel/quarkus/component/leveldb/it/LeveldbTest.java b/integration-tests/leveldb/src/test/java/org/apache/camel/quarkus/component/leveldb/it/LeveldbTest.java
index 1ffa037..3d473b8 100644
--- a/integration-tests/leveldb/src/test/java/org/apache/camel/quarkus/component/leveldb/it/LeveldbTest.java
+++ b/integration-tests/leveldb/src/test/java/org/apache/camel/quarkus/component/leveldb/it/LeveldbTest.java
@@ -101,19 +101,7 @@ class LeveldbTest {
.statusCode(201)
.extract().as(Boolean.class);
- if (doeasBinaryDataWork()) {
- assertTrue(theSame);
- } else {
- assertFalse(theSame);
- }
- }
-
- /**
- * Until binary payload is not supported, in native binary test will fail.
- * Needs https://issues.apache.org/jira/browse/CAMEL-15679
- */
- boolean doeasBinaryDataWork() {
- return true;
+ assertTrue(theSame);
}
private Map<String, List<Map<String, Object>>> testAggregate(String path, List<String> messages) {
diff --git a/integration-tests/saga/src/main/java/org/apache/camel/quarkus/component/saga/it/SagaRoute.java b/integration-tests/saga/src/main/java/org/apache/camel/quarkus/component/saga/it/SagaRoute.java
index 32dc3cb..6196340 100644
--- a/integration-tests/saga/src/main/java/org/apache/camel/quarkus/component/saga/it/SagaRoute.java
+++ b/integration-tests/saga/src/main/java/org/apache/camel/quarkus/component/saga/it/SagaRoute.java
@@ -21,9 +21,9 @@ import javax.inject.Inject;
import org.apache.camel.Exchange;
import org.apache.camel.builder.RouteBuilder;
-import org.apache.camel.impl.saga.InMemorySagaService;
import org.apache.camel.model.SagaPropagation;
import org.apache.camel.saga.CamelSagaService;
+import org.apache.camel.saga.InMemorySagaService;
@ApplicationScoped
public class SagaRoute extends RouteBuilder {
diff --git a/pom.xml b/pom.xml
index 98b7973..7295173 100644
--- a/pom.xml
+++ b/pom.xml
@@ -45,7 +45,7 @@
<awssdk1-swf-libs.version>1.11.22</awssdk1-swf-libs.version>
<awssdk2.version>2.14.3</awssdk2.version>
<bouncycastle.version>1.66</bouncycastle.version>
- <camel.version>3.6.0</camel.version>
+ <camel.version>3.7.0-SNAPSHOT</camel.version>
<commons-beanutils.version>1.9.4</commons-beanutils.version><!-- keep in sync with Camel -->
<commons-cli.version>1.4</commons-cli.version><!-- keep in sync with Quarkus, via quarkus-bootstrap-core -->
<commons-collections.version>3.2.2</commons-collections.version><!-- used by hbase, should be pretty stable as commons-collections are not developed actively anymore -->
@@ -72,6 +72,7 @@
<jackson-asl.version>1.9.13</jackson-asl.version><!-- Mess in the transitive dependencies of spark and hbase-testing-util -->
<java.xml.ws.version>2.3.1</java.xml.ws.version>
<jcodings.version>1.0.55</jcodings.version><!-- used by hbase -->
+ <joni.version>2.1.31</joni.version><!-- used by json-validator -->
<jaxen.version>1.2.0</jaxen.version>
<javassist.version>3.22.0-CR2</javassist.version><!-- debezium -->
<jersey-sun.version>1.19.4</jersey-sun.version><!-- Spark -->
diff --git a/poms/bom/pom.xml b/poms/bom/pom.xml
index ab3e1e7..6b7003a 100644
--- a/poms/bom/pom.xml
+++ b/poms/bom/pom.xml
@@ -656,6 +656,11 @@
</dependency>
<dependency>
<groupId>org.apache.camel</groupId>
+ <artifactId>camel-core-processor</artifactId>
+ <version>${camel.version}</version>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.camel</groupId>
<artifactId>camel-couchbase</artifactId>
<version>${camel.version}</version>
</dependency>
@@ -5602,6 +5607,11 @@
<version>${jcodings.version}</version>
</dependency>
<dependency>
+ <groupId>org.jruby.joni</groupId>
+ <artifactId>joni</artifactId>
+ <version>${joni.version}</version>
+ </dependency>
+ <dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-aop</artifactId>
<version>${spring.version}</version>