Re: [PR] chore(deps): Bump mongo-java-driver-version from 4.11.1 to 5.1.1 [camel]
orpiske commented on PR #14499:
URL: https://github.com/apache/camel/pull/14499#issuecomment-2169140333
This is what I have in the logs:
```
2024-06-14 13:03:28,751 [main ] INFO DefaultCamelContextExtension
- Testing: verifyConnectionKO()
(org.apache.camel.component.mongodb.verifier.integration.MongoDbVerifierExtensionIT)
2024-06-14 13:03:28,753 [main ] INFO
ongoComponentVerifierExtension - Testing connection against
mongodb://test-user:test-...@notreachable.host/admin
2024-06-14 13:03:28,754 [main ] INFO client
- MongoClient with metadata {"driver": {"name": "mongo-java-driver|sync",
"version": "5.1.1"}, "os": {"type": "Linux", "name": "Linux", "architecture":
"amd64", "version": "6.8.11-200.fc39.x86_64"}, "platform": "Java/Eclipse
Adoptium/17.0.9+9"} created with settings
MongoClientSettings{readPreference=primary, writeConcern=WriteConcern{w=null,
wTimeout=null ms, journal=null}, retryWrites=true, retryReads=true,
readConcern=ReadConcern{level=null}, credential=MongoCredential{mechanism=null,
userName='test-user', source='admin', password=,
mechanismProperties=}, transportSettings=null, commandListeners=[],
codecRegistry=ProvidersCodecRegistry{codecProviders=[ValueCodecProvider{},
BsonValueCodecProvider{}, DBRefCodecProvider{}, DBObjectCodecProvider{},
DocumentCodecProvider{}, CollectionCodecProvider{}, IterableCodecProvider{},
MapCodecProvider{}, GeoJsonCodecProvider{}, GridFSFileCodecProvid
er{}, Jsr310CodecProvider{}, JsonObjectCodecProvider{}, BsonCodecProvider{},
EnumCodecProvider{},
com.mongodb.client.model.mql.ExpressionCodecProvider@28369db0,
com.mongodb.Jep395RecordCodecProvider@30893e08,
com.mongodb.KotlinCodecProvider@2e86807a]},
loggerSettings=LoggerSettings{maxDocumentLength=1000},
clusterSettings={hosts=[notreachable.host:27017], srvServiceName=mongodb,
mode=SINGLE, requiredClusterType=UNKNOWN, requiredReplicaSetName='null',
serverSelector='null', clusterListeners='[]', serverSelectionTimeout='3
ms', localThreshold='15 ms'},
socketSettings=SocketSettings{connectTimeoutMS=1, readTimeoutMS=0,
receiveBufferSize=0, proxySettings=ProxySettings{host=null, port=null,
username=null, password=null}},
heartbeatSocketSettings=SocketSettings{connectTimeoutMS=1,
readTimeoutMS=1, receiveBufferSize=0,
proxySettings=ProxySettings{host=null, port=null, username=null,
password=null}}, connectionPoolSettings=ConnectionPoolSettings{maxSize=100,
minSize=0, maxWa
itTimeMS=12, maxConnectionLifeTimeMS=0, maxConnectionIdleTimeMS=0,
maintenanceInitialDelayMS=0, maintenanceFrequencyMS=6,
connectionPoolListeners=[], maxConnecting=2},
serverSettings=ServerSettings{heartbeatFrequencyMS=1,
minHeartbeatFrequencyMS=500, serverMonitoringMode=AUTO, serverListeners='[]',
serverMonitorListeners='[]'}, sslSettings=SslSettings{enabled=false,
invalidHostNameAllowed=false, context=null}, applicationName='null',
compressorList=[], uuidRepresentation=UNSPECIFIED, serverApi=null,
autoEncryptionSettings=null, dnsClient=null, inetAddressResolver=null,
contextProvider=null}
2024-06-14 13:03:28,754 [main ] INFO cluster
- Waiting for server to become available for operation with ID 137684.
Remaining time: 3 ms. Selector:
ReadPreferenceServerSelector{readPreference=primary}, topology description:
{type=UNKNOWN, servers=[{address=notreachable.host:27017, type=UNKNOWN,
state=CONNECTING}].
2024-06-14 13:03:28,775 [able.host:27017] INFO cluster
- Exception in monitor thread while connecting to server
notreachable.host:27017
com.mongodb.MongoSocketException: notreachable.host: Name or service not
known
at
com.mongodb.internal.connection.ServerAddressHelper.getSocketAddresses(ServerAddressHelper.java:75)
~[mongodb-driver-core-5.1.1.jar:?]
at
com.mongodb.internal.connection.SocketStream.initializeSocket(SocketStream.java:101)
~[mongodb-driver-core-5.1.1.jar:?]
at
com.mongodb.internal.connection.SocketStream.open(SocketStream.java:80)
~[mongodb-driver-core-5.1.1.jar:?]
at
com.mongodb.internal.connection.InternalStreamConnection.open(InternalStreamConnection.java:226)
~[mongodb-driver-core-5.1.1.jar:?]
at
com.mongodb.internal.connection.DefaultServerMonitor$ServerMonitor.lookupServerDescription(DefaultServerMonitor.java:216)
[mongodb-driver-core-5.1.1.jar:?]
at
com.mongodb.internal.connection.DefaultServerMonitor$ServerMonitor.run(DefaultServerMonitor.java:173)
[mongodb-driver-core-5.1.1.jar:?]
Caused by: java.net.UnknownHostException: notreachable.host: Name or service
not known
at java.base/java.net.Inet6AddressImpl.lookupAllHostAddr(Native
Method) ~[?:?]
at
java.base/java.net.InetAddress$PlatformNameService.lookupAllHostAddr(InetAddress.java:934)
~[?:?]
at
Re: [PR] CAMEL-20840: fixed incomplete/incorrect implementation of resume adapter [camel]
orpiske merged PR #14479: URL: https://github.com/apache/camel/pull/14479 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
(camel) branch main updated: CAMEL-20840: fixed incomplete/incorrect implementation of resume adapter
This is an automated email from the ASF dual-hosted git repository.
orpiske pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/main by this push:
new 46e003c436c CAMEL-20840: fixed incomplete/incorrect implementation of
resume adapter
46e003c436c is described below
commit 46e003c436c6d90fa765403a3b512ed1c73c0168
Author: Otavio Rodolfo Piske
AuthorDate: Tue Jun 11 11:26:40 2024 +0200
CAMEL-20840: fixed incomplete/incorrect implementation of resume adapter
- removed invalid test
- adjust Kinesis resume adapter to use the ResumeActionAware
- simplify Kinesis resume adapter
---
.../camel/catalog/components/aws2-kinesis.json | 3 +-
.../camel/component/aws2/kinesis/aws2-kinesis.json | 3 +-
.../services/org/apache/camel/adapter-factory | 2 -
.../component/aws2/kinesis/Kinesis2Constants.java | 3 +
.../component/aws2/kinesis/Kinesis2Consumer.java | 25 -
.../consumer/KinesisDefaultResumeAdapter.java | 81
.../aws2/kinesis/consumer/KinesisResumeAction.java | 68 +
.../kinesis/consumer/KinesisResumeAdapter.java | 33 ---
.../KinesisConsumerResumeAfterRestartIT.java | 106 -
.../integration/KinesisConsumerResumeIT.java | 37 +++
.../support/resume/ResumeActionAwareAdapter.java | 4 +
.../dsl/Kinesis2EndpointBuilderFactory.java| 12 +++
12 files changed, 134 insertions(+), 243 deletions(-)
diff --git
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/aws2-kinesis.json
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/aws2-kinesis.json
index 8f1a0065ed7..2c45648f61e 100644
---
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/aws2-kinesis.json
+++
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/aws2-kinesis.json
@@ -58,7 +58,8 @@
"CamelAwsKinesisApproximateArrivalTimestamp": { "index": 1, "kind":
"header", "displayName": "", "group": "common", "label": "", "required": false,
"javaType": "String", "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "description": "The time AWS assigned as the arrival
time of the record.", "constantName":
"org.apache.camel.component.aws2.kinesis.Kinesis2Constants#APPROX_ARRIVAL_TIME"
},
"CamelAwsKinesisPartitionKey": { "index": 2, "kind": "header",
"displayName": "", "group": "common", "label": "", "required": false,
"javaType": "String", "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "description": "Identifies which shard in the stream
the data record is assigned to.", "constantName":
"org.apache.camel.component.aws2.kinesis.Kinesis2Constants#PARTITION_KEY" },
"CamelMessageTimestamp": { "index": 3, "kind": "header", "displayName":
"", "group": "common", "label": "", "required": false, "javaType": "long",
"deprecated": false, "deprecationNote": "", "autowired": false, "secret":
false, "description": "The timestamp of the message", "constantName":
"org.apache.camel.component.aws2.kinesis.Kinesis2Constants#MESSAGE_TIMESTAMP" },
-"CamelAwsKinesisShardId": { "index": 4, "kind": "header", "displayName":
"", "group": "common", "label": "", "required": false, "javaType": "String",
"deprecated": false, "deprecationNote": "", "autowired": false, "secret":
false, "description": "The shard ID of the shard where the data record was
placed.", "constantName":
"org.apache.camel.component.aws2.kinesis.Kinesis2Constants#SHARD_ID" }
+"CamelKinesisDbResumeAction": { "index": 4, "kind": "header",
"displayName": "", "group": "consumer", "label": "consumer", "required": false,
"javaType": "String", "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "description": "The resume action to execute when
resuming.", "constantName":
"org.apache.camel.component.aws2.kinesis.Kinesis2Constants#RESUME_ACTION" },
+"CamelAwsKinesisShardId": { "index": 5, "kind": "header", "displayName":
"", "group": "common", "label": "", "required": false, "javaType": "String",
"deprecated": false, "deprecationNote": "", "autowired": false, "secret":
false, "description": "The shard ID of the shard where the data record was
placed.", "constantName":
"org.apache.camel.component.aws2.kinesis.Kinesis2Constants#SHARD_ID" }
},
"properties": {
"streamName": { "index": 0, "kind": "path", "displayName": "Stream Name",
"group": "common", "label": "", "required": true, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.aws2.kinesis.Kinesis2Configuration",
"configurationField": "configuration", "description": "Name of the stream" },
diff --git
Re: [PR] Backport CAMEL-20790 to 4.4.x [camel]
github-actions[bot] commented on PR #14537: URL: https://github.com/apache/camel/pull/14537#issuecomment-2169139160 :star2: Thank you for your contribution to the Apache Camel project! :star2: :robot: CI automation will test this PR automatically. :camel: Apache Camel Committers, please review the following items: * First-time contributors **require MANUAL approval** for the GitHub Actions to run * You can use the command `/component-test (camel-)component-name1 (camel-)component-name2..` to request a test from the test bot. * You can label PRs using `build-all`, `build-dependents`, `skip-tests` and `test-dependents` to fine-tune the checks executed by this PR. * Build and test logs are available in the Summary page. **Only** [Apache Camel committers](https://camel.apache.org/community/team/#committers) have access to the summary. * :warning: Be careful when sharing logs. Review their contents before sharing them publicly. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[PR] Backport CAMEL-20790 to 4.4.x [camel]
orpiske opened a new pull request, #14537: URL: https://github.com/apache/camel/pull/14537 (no comment) -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
(camel) branch main updated: CAMEL-20790: prevent an NPE under high concurrency
This is an automated email from the ASF dual-hosted git repository.
orpiske pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/main by this push:
new 942dc647681 CAMEL-20790: prevent an NPE under high concurrency
942dc647681 is described below
commit 942dc647681693aefc9a3554200d4e00a0c3c89d
Author: Otavio Rodolfo Piske
AuthorDate: Tue Jun 11 17:23:36 2024 +0200
CAMEL-20790: prevent an NPE under high concurrency
---
.../support/batching/KafkaRecordBatchingProcessor.java | 16 +---
1 file changed, 9 insertions(+), 7 deletions(-)
diff --git
a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/support/batching/KafkaRecordBatchingProcessor.java
b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/support/batching/KafkaRecordBatchingProcessor.java
index b6bf0a6e2e8..ed924dc78dd 100644
---
a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/support/batching/KafkaRecordBatchingProcessor.java
+++
b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/support/batching/KafkaRecordBatchingProcessor.java
@@ -16,8 +16,9 @@
*/
package org.apache.camel.component.kafka.consumer.support.batching;
-import java.util.ArrayList;
import java.util.List;
+import java.util.Queue;
+import java.util.concurrent.ArrayBlockingQueue;
import org.apache.camel.Exchange;
import org.apache.camel.Message;
@@ -45,7 +46,7 @@ final class KafkaRecordBatchingProcessor extends
KafkaRecordProcessor {
private final Processor processor;
private final CommitManager commitManager;
private final StopWatch watch = new StopWatch();
-private List exchangeList;
+private final Queue exchangeList;
private final class CommitSynchronization implements Synchronization {
private final ExceptionHandler exceptionHandler;
@@ -89,6 +90,8 @@ final class KafkaRecordBatchingProcessor extends
KafkaRecordProcessor {
this.configuration = configuration;
this.processor = processor;
this.commitManager = commitManager;
+
+this.exchangeList = new
ArrayBlockingQueue(configuration.getMaxPollRecords());
}
public Exchange toExchange(
@@ -113,8 +116,7 @@ final class KafkaRecordBatchingProcessor extends
KafkaRecordProcessor {
LOG.debug("There's {} records to process ... max poll is set to {}",
consumerRecords.count(),
configuration.getMaxPollRecords());
// Aggregate all consumer records in a single exchange
-if (exchangeList == null) {
-exchangeList = new ArrayList<>(configuration.getMaxPollRecords());
+if (exchangeList.isEmpty()) {
watch.takenAndRestart();
}
@@ -125,7 +127,7 @@ final class KafkaRecordBatchingProcessor extends
KafkaRecordProcessor {
// poll timeout has elapsed, so check for expired records
processBatch(camelKafkaConsumer);
-exchangeList = null;
+exchangeList.clear();
return ProcessingResult.newUnprocessed();
}
@@ -138,7 +140,7 @@ final class KafkaRecordBatchingProcessor extends
KafkaRecordProcessor {
if (exchangeList.size() == configuration.getMaxPollRecords()) {
processBatch(camelKafkaConsumer);
-exchangeList = null;
+exchangeList.clear();
}
}
@@ -156,7 +158,7 @@ final class KafkaRecordBatchingProcessor extends
KafkaRecordProcessor {
// Create the bundle exchange
final Exchange exchange = camelKafkaConsumer.createExchange(false);
final Message message = exchange.getMessage();
-message.setBody(exchangeList);
+message.setBody(exchangeList.stream().toList());
try {
if (configuration.isAllowManualCommit()) {
Re: [PR] CAMEL-20790: prevent an NPE under high concurrency [camel]
orpiske merged PR #14481: URL: https://github.com/apache/camel/pull/14481 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
(camel) 01/02: Refresh camel-smb
This is an automated email from the ASF dual-hosted git repository.
orpiske pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 44c2167fd36dd88211c9c4321347e6c875993d16
Author: Tom Cunningham
AuthorDate: Wed Jun 12 13:51:53 2024 -0400
Refresh camel-smb
---
.../org/apache/camel/catalog/components/smb.json | 60 +-
.../apache/camel/catalog/schemas/camel-spring.xsd | 50 +-
components/camel-smb/pom.xml | 5 +
.../component/smb/SmbComponentConfigurer.java | 6 +
.../camel/component/smb/SmbEndpointConfigurer.java | 18 +
.../camel/component/smb/SmbEndpointUriFactory.java | 5 +-
.../org/apache/camel/component/smb/smb.json| 60 +-
.../camel-smb/src/main/docs/smb-component.adoc | 2 +-
.../camel/component/smb/SmbConfiguration.java | 31 +
.../apache/camel/component/smb/SmbConstants.java | 25 +
.../apache/camel/component/smb/SmbEndpoint.java| 3 +-
.../apache/camel/component/smb/SmbProducer.java| 239
.../apache/camel/component/smb/SmbComponentIT.java | 16 +
.../component/dsl/SmbComponentBuilderFactory.java | 26 +
.../endpoint/dsl/SmbEndpointBuilderFactory.java| 626 ++---
.../apache/camel/kotlin/components/SmbUriDsl.kt| 59 +-
16 files changed, 1050 insertions(+), 181 deletions(-)
diff --git
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/smb.json
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/smb.json
index 3f9a64b3769..f51cf35fb33 100644
---
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/smb.json
+++
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/smb.json
@@ -17,46 +17,50 @@
"syntax": "smb:hostname:port\/shareName",
"async": false,
"api": false,
-"consumerOnly": true,
+"consumerOnly": false,
"producerOnly": false,
"lenientProperties": false,
"remote": true
},
"componentProperties": {
"bridgeErrorHandler": { "index": 0, "kind": "property", "displayName":
"Bridge Error Handler", "group": "consumer", "label": "consumer", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": false, "description":
"Allows for bridging the consumer to the Camel routing Error Handler, which
mean any exceptions (if possible) occurred while the Camel consumer is trying
to pickup incoming messages, or the like [...]
-"autowiredEnabled": { "index": 1, "kind": "property", "displayName":
"Autowired Enabled", "group": "advanced", "label": "advanced", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": true, "description":
"Whether autowiring is enabled. This is used for automatic autowiring options
(the option must be marked as autowired) by looking up in the registry to find
if there is a single instance of matching t [...]
+"lazyStartProducer": { "index": 1, "kind": "property", "displayName":
"Lazy Start Producer", "group": "producer", "label": "producer", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": false, "description":
"Whether the producer should be started lazy (on the first message). By
starting lazy you can use this to allow CamelContext and routes to startup in
situations where a producer may otherwise fail [...]
+"autowiredEnabled": { "index": 2, "kind": "property", "displayName":
"Autowired Enabled", "group": "advanced", "label": "advanced", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": true, "description":
"Whether autowiring is enabled. This is used for automatic autowiring options
(the option must be marked as autowired) by looking up in the registry to find
if there is a single instance of matching t [...]
},
"properties": {
-"hostname": { "index": 0, "kind": "path", "displayName": "Hostname",
"group": "consumer", "label": "", "required": true, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "deprecationNote": "",
"autowired": false, "secret": false, "description": "The share hostname or IP
address" },
-"port": { "index": 1, "kind": "path", "displayName": "Port", "group":
"consumer", "label": "", "required": false, "type": "integer", "javaType":
"int", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": 445, "description": "The share port number" },
-"shareName": { "index": 2, "kind": "path", "displayName": "Share Name",
"group": "consumer", "label": "", "required": true, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "deprecationNote": "",
"autowired": false, "secret": false, "description":
Re: [PR] CAMEL-20679 Add a camel-smb producer [camel]
orpiske merged PR #14495: URL: https://github.com/apache/camel/pull/14495 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
(camel) 02/02: CAMEL-20679 Make buffer size configurable, file creation HashSets out of process
This is an automated email from the ASF dual-hosted git repository.
orpiske pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 520541a019672fcc21e395654fe2b55c4a851b58
Author: Tom Cunningham
AuthorDate: Fri Jun 14 20:47:24 2024 -0400
CAMEL-20679 Make buffer size configurable, file creation HashSets out of
process
---
.../org/apache/camel/catalog/components/smb.json | 43 +++
.../apache/camel/catalog/schemas/camel-spring.xsd | 50 --
.../camel/component/smb/SmbEndpointConfigurer.java | 6 +++
.../camel/component/smb/SmbEndpointUriFactory.java | 3 +-
.../org/apache/camel/component/smb/smb.json| 43 +++
.../camel/component/smb/SmbConfiguration.java | 12 +
.../apache/camel/component/smb/SmbProducer.java| 61 --
.../endpoint/dsl/SmbEndpointBuilderFactory.java| 30 +++
.../apache/camel/kotlin/components/SmbUriDsl.kt| 14 +
9 files changed, 187 insertions(+), 75 deletions(-)
diff --git
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/smb.json
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/smb.json
index f51cf35fb33..9985bff7376 100644
---
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/smb.json
+++
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/smb.json
@@ -41,26 +41,27 @@
"pollStrategy": { "index": 10, "kind": "parameter", "displayName": "Poll
Strategy", "group": "consumer (advanced)", "label": "consumer,advanced",
"required": false, "type": "object", "javaType":
"org.apache.camel.spi.PollingConsumerPollStrategy", "deprecated": false,
"autowired": false, "secret": false, "description": "A pluggable
org.apache.camel.PollingConsumerPollingStrategy allowing you to provide your
custom implementation to control error handling usually occurred during the po
[...]
"autoCreate": { "index": 11, "kind": "parameter", "displayName": "Auto
Create", "group": "producer", "label": "producer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "deprecationNote": "",
"autowired": false, "secret": false, "defaultValue": false,
"configurationClass": "org.apache.camel.component.smb.SmbConfiguration",
"configurationField": "configuration", "description": "Whether to create parent
directory if it does not exist" },
"fileExist": { "index": 12, "kind": "parameter", "displayName": "File
Exist", "group": "producer", "label": "producer", "required": false, "type":
"object", "javaType": "org.apache.camel.component.file.GenericFileExist",
"enum": [ "Override", "Append", "Fail", "Ignore", "Move", "TryRename" ],
"deprecated": false, "deprecationNote": "", "autowired": false, "secret":
false, "defaultValue": "Ignore", "configurationClass":
"org.apache.camel.component.smb.SmbConfiguration", "configuration [...]
-"lazyStartProducer": { "index": 13, "kind": "parameter", "displayName":
"Lazy Start Producer", "group": "producer (advanced)", "label":
"producer,advanced", "required": false, "type": "boolean", "javaType":
"boolean", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": false, "description": "Whether the producer should be started
lazy (on the first message). By starting lazy you can use this to allow
CamelContext and routes to startup in situations where a produ [...]
-"idempotentRepository": { "index": 14, "kind": "parameter", "displayName":
"Idempotent Repository", "group": "advanced", "label": "advanced", "required":
false, "type": "object", "javaType":
"org.apache.camel.spi.IdempotentRepository", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.smb.SmbConfiguration", "configurationField":
"configuration", "description": "A pluggable repository
org.apache.camel.spi.IdempotentRepository w [...]
-"smbConfig": { "index": 15, "kind": "parameter", "displayName": "Smb
Config", "group": "advanced", "label": "advanced", "required": false, "type":
"object", "javaType": "com.hierynomus.smbj.SmbConfig", "deprecated": false,
"deprecationNote": "", "autowired": true, "secret": false,
"configurationClass": "org.apache.camel.component.smb.SmbConfiguration",
"configurationField": "configuration", "description": "An optional SMB client
configuration, can be used to configure client specific [...]
-"smbIoBean": { "index": 16, "kind": "parameter", "displayName": "Smb Io
Bean", "group": "advanced", "label": "advanced", "required": false, "type":
"object", "javaType": "org.apache.camel.component.smb.SmbIOBean", "deprecated":
false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.smb.SmbConfiguration", "configurationField":
"configuration", "description": "An optional SMB I\/O bean to use to setup the
file access attributes
(camel) branch main updated (77b58e811ea -> 520541a0196)
This is an automated email from the ASF dual-hosted git repository.
orpiske pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
from 77b58e811ea CAMEL-20800: Use cloudant instead of LightCouch
new 44c2167fd36 Refresh camel-smb
new 520541a0196 CAMEL-20679 Make buffer size configurable, file creation
HashSets out of process
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:
.../org/apache/camel/catalog/components/smb.json | 61 +-
components/camel-smb/pom.xml | 5 +
.../component/smb/SmbComponentConfigurer.java | 6 +
.../camel/component/smb/SmbEndpointConfigurer.java | 24 +
.../camel/component/smb/SmbEndpointUriFactory.java | 6 +-
.../org/apache/camel/component/smb/smb.json| 61 +-
.../camel-smb/src/main/docs/smb-component.adoc | 2 +-
.../camel/component/smb/SmbConfiguration.java | 43 ++
.../apache/camel/component/smb/SmbConstants.java} | 14 +-
.../apache/camel/component/smb/SmbEndpoint.java| 3 +-
.../apache/camel/component/smb/SmbProducer.java| 246
.../apache/camel/component/smb/SmbComponentIT.java | 16 +
.../component/dsl/SmbComponentBuilderFactory.java | 26 +
.../endpoint/dsl/SmbEndpointBuilderFactory.java| 656 ++---
.../apache/camel/kotlin/components/SmbUriDsl.kt| 73 ++-
15 files changed, 1097 insertions(+), 145 deletions(-)
copy
components/{camel-pgevent/src/main/java/org/apache/camel/component/pgevent/PgEventConstants.java
=> camel-smb/src/main/java/org/apache/camel/component/smb/SmbConstants.java}
(73%)
create mode 100644
components/camel-smb/src/main/java/org/apache/camel/component/smb/SmbProducer.java
(camel-quarkus) branch quarkus-main updated (a6a06a16b0 -> d91103ef9b)
This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch quarkus-main
in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git
discard a6a06a16b0 Upgrade Quarkus to 3.13.0.CR1
add f6c7a287a5 Bump quarkiverse-groovy.version from 3.10.0 to 3.11.0
(#6187)
add ce6d4b642a Added some small logs to Aws2KinesisFirehoseTest for better
understanding of flaky tests (#6186)
add 4a39b1c11f Add httpclient5 support extension
new d91103ef9b Upgrade Quarkus to 3.13.0.CR1
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 (a6a06a16b0)
\
N -- N -- N refs/heads/quarkus-main (d91103ef9b)
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 1 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:
catalog/pom.xml| 13 +++
extensions-support/httpclient/deployment/pom.xml | 4
.../httpclient/deployment/HttpClientProcessor.java | 24 ---
extensions-support/httpclient/runtime/pom.xml | 27 --
.../deployment/pom.xml | 8 +++
.../deployment/HttpClient5Processor.java | 25
.../{retrofit => httpclient5}/pom.xml | 4 ++--
.../{jetty => httpclient5}/runtime/pom.xml | 14 +++
.../main/resources/META-INF/quarkus-extension.yaml | 4 ++--
extensions-support/pom.xml | 1 +
extensions/arangodb/deployment/pom.xml | 8 ++-
extensions/arangodb/runtime/pom.xml| 6 +
extensions/as2/deployment/pom.xml | 4
extensions/as2/runtime/pom.xml | 4
extensions/box/deployment/pom.xml | 4
extensions/box/runtime/pom.xml | 4
extensions/geocoder/deployment/pom.xml | 2 +-
extensions/geocoder/runtime/pom.xml| 2 +-
extensions/graphql/deployment/pom.xml | 2 +-
extensions/graphql/runtime/pom.xml | 2 +-
extensions/http/deployment/pom.xml | 2 +-
.../component/http/deployment/HttpProcessor.java | 5 ++--
extensions/http/runtime/pom.xml| 2 +-
extensions/oaipmh/deployment/pom.xml | 2 +-
extensions/oaipmh/runtime/pom.xml | 2 +-
extensions/splunk-hec/deployment/pom.xml | 2 +-
extensions/splunk-hec/runtime/pom.xml | 2 +-
extensions/weather/deployment/pom.xml | 6 +
extensions/weather/runtime/pom.xml | 6 +
.../aws2/kinesis/it/Aws2KinesisFirehoseTest.java | 3 ++-
.../kinesis/it/Aws2KinesisTestEnvCustomizer.java | 6 -
.../platform/http/proxy/ssl/it/Routes.java | 2 +-
pom.xml| 2 +-
poms/bom/pom.xml | 10
poms/bom/src/main/generated/flattened-full-pom.xml | 14 +--
.../src/main/generated/flattened-reduced-pom.xml | 14 +--
.../generated/flattened-reduced-verbose-pom.xml| 14 +--
37 files changed, 128 insertions(+), 128 deletions(-)
copy extensions-support/{google-cloud => httpclient5}/deployment/pom.xml (87%)
copy
extensions/jslt/deployment/src/main/java/org/apache/camel/quarkus/component/jslt/deployment/JsltProcessor.java
=>
extensions-support/httpclient5/deployment/src/main/java/org/apache/camel/quarkus/support/httpclient5/deployment/HttpClient5Processor.java
(62%)
copy extensions-support/{retrofit => httpclient5}/pom.xml (91%)
copy extensions-support/{jetty => httpclient5}/runtime/pom.xml (82%)
copy extensions-support/{httpclient =>
httpclient5}/runtime/src/main/resources/META-INF/quarkus-extension.yaml (89%)
(camel-quarkus) 01/01: Upgrade Quarkus to 3.13.0.CR1
This is an automated email from the ASF dual-hosted git repository. github-bot pushed a commit to branch quarkus-main in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git commit d91103ef9bb4e15267c3d613ce7bd919058b27a9 Author: James Netherton AuthorDate: Thu Jun 13 14:23:33 2024 +0100 Upgrade Quarkus to 3.13.0.CR1 --- pom.xml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pom.xml b/pom.xml index 6080bf2c29..a616423171 100644 --- a/pom.xml +++ b/pom.xml @@ -62,7 +62,7 @@ 2.2.2 2.4.0 2.0.2 -3.12.0.CR1 +999-SNAPSHOT 4.0.0 2.6.1
Re: [I] [CI] - Quarkus Main Branch Build Failure [camel-quarkus]
github-actions[bot] closed issue #2926: [CI] - Quarkus Main Branch Build Failure URL: https://github.com/apache/camel-quarkus/issues/2926 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
Re: [I] [CI] - Quarkus Main Branch Build Failure [camel-quarkus]
github-actions[bot] commented on issue #2926: URL: https://github.com/apache/camel-quarkus/issues/2926#issuecomment-2169092664 Build fixed with: * Camel Quarkus Commit: d91103ef9bb4e15267c3d613ce7bd919058b27a9 * Quarkus Main Commit: 4a39b1c11ff5d0a5e2ba573df13f47491b9d04af * Link to build: https://github.com/apache/camel-quarkus/actions/runs/9524723343 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[PR] fix(ci): Removed STAGING_RUNTIME_REPO from Makefile [camel-k]
devesh-2002 opened a new pull request, #5641: URL: https://github.com/apache/camel-k/pull/5641 Issue #5616, Removed STAGING_RUNTIME_REPO from Makefile and `test_staging_hooks.go`. Please let me know, if there are any changes needed. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
(camel-kafka-connector) branch main updated: Updated CHANGELOG.md
This is an automated email from the ASF dual-hosted git repository. github-bot pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git The following commit(s) were added to refs/heads/main by this push: new af8638aae0 Updated CHANGELOG.md af8638aae0 is described below commit af8638aae0aac9d8c8d087f54fafe9d5055a42cc Author: github-actions[bot] <41898282+github-actions[bot]@users.noreply.github.com> AuthorDate: Sat Jun 15 03:04:34 2024 + Updated CHANGELOG.md --- CHANGELOG.md | 1 + 1 file changed, 1 insertion(+) diff --git a/CHANGELOG.md b/CHANGELOG.md index 2b456813da..ae0d32ec7d 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -6,6 +6,7 @@ **Merged pull requests:** +- \[Github Actions\] Periodic Sync Camel-kafka-connector main Branch [\#1651](https://github.com/apache/camel-kafka-connector/pull/1651) ([github-actions[bot]](https://github.com/apps/github-actions)) - Bump com.azure:azure-identity from 1.11.1 to 1.12.2 in /connectors/camel-kafka-azure-schema-registry-sink-kafka-connector [\#1649](https://github.com/apache/camel-kafka-connector/pull/1649) ([dependabot[bot]](https://github.com/apps/dependabot)) - \[Github Actions\] Periodic Sync Camel-kafka-connector main Branch [\#1648](https://github.com/apache/camel-kafka-connector/pull/1648) ([github-actions[bot]](https://github.com/apps/github-actions)) - Fix maven source plugin args after version upgrading. [\#1646](https://github.com/apache/camel-kafka-connector/pull/1646) ([valdar](https://github.com/valdar))
Re: [PR] fix(ci): Removed STAGING_RUNTIME_REPO from Makefile [camel-k]
devesh-2002 closed pull request #5640: fix(ci): Removed STAGING_RUNTIME_REPO from Makefile URL: https://github.com/apache/camel-k/pull/5640 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[PR] fix(ci): Removed STAGING_RUNTIME_REPO from Makefile [camel-k]
devesh-2002 opened a new pull request, #5640: URL: https://github.com/apache/camel-k/pull/5640 Issue #5616 , I have removed STAGING_RUNTIME_REPO from Makefile as well as test_staging_hooks.go. Please let me know if there are any changes needed. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
(camel-kafka-connector) branch automatic-periodic-sync updated (0824a9cb5d -> b521545cd8)
This is an automated email from the ASF dual-hosted git repository. github-bot pushed a change to branch automatic-periodic-sync in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git omit 0824a9cb5d [create-pull-request] automated change add 9819818bf8 Updated CHANGELOG.md add b521545cd8 [create-pull-request] automated change (#1651) 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 (0824a9cb5d) \ N -- N -- N refs/heads/automatic-periodic-sync (b521545cd8) 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. No new revisions were added by this update. Summary of changes: CHANGELOG.md | 1 + 1 file changed, 1 insertion(+)
(camel-k) branch release-2.2.x updated: chore: changelog automatic update
This is an automated email from the ASF dual-hosted git repository. github-bot pushed a commit to branch release-2.2.x in repository https://gitbox.apache.org/repos/asf/camel-k.git The following commit(s) were added to refs/heads/release-2.2.x by this push: new e34127752 chore: changelog automatic update e34127752 is described below commit e341277520adcf02a6f82385d0ecfe46d1bd51d6 Author: github-actions[bot] <41898282+github-actions[bot]@users.noreply.github.com> AuthorDate: Sat Jun 15 01:14:35 2024 + chore: changelog automatic update --- CHANGELOG.md | 3 +++ 1 file changed, 3 insertions(+) diff --git a/CHANGELOG.md b/CHANGELOG.md index eb678b5f2..542c003ba 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -9,12 +9,15 @@ - Service/KService not created for vertx-websocket consumers [\#5628](https://github.com/apache/camel-k/issues/5628) - Modeline container.port trait config set as String value [\#5621](https://github.com/apache/camel-k/issues/5621) - Documentation links to old Camel K examples location [\#5619](https://github.com/apache/camel-k/issues/5619) +- maven-settings-offline-template.xml does not contain license [\#5603](https://github.com/apache/camel-k/issues/5603) - Bring back Quarkus native test in PR [\#5598](https://github.com/apache/camel-k/issues/5598) - Unable to specify any CloudEvent attributes or extensions, except for `type` [\#5537](https://github.com/apache/camel-k/issues/5537) - Move deprecated v1alpha1.KameletBinding tests to v1.Pipe [\#5490](https://github.com/apache/camel-k/issues/5490) - Move tests, examples and documentation from groovy to yaml [\#5489](https://github.com/apache/camel-k/issues/5489) +- Add a deploy make target [\#5460](https://github.com/apache/camel-k/issues/5460) - Remove health readiness workaround when fixed in Camel [\#5451](https://github.com/apache/camel-k/issues/5451) - Dependency Service Discovery for Camel K [\#5196](https://github.com/apache/camel-k/issues/5196) +- Mount configmap/secret resources to a dedicated resources.d durectory [\#5181](https://github.com/apache/camel-k/issues/5181) - Support YAML DSL routes configuration [\#4893](https://github.com/apache/camel-k/issues/4893) - Kustomize installation does not work [\#4528](https://github.com/apache/camel-k/issues/4528) - Kustomize default [\#4135](https://github.com/apache/camel-k/issues/4135)
Re: [PR] CAMEL-20679 Add a camel-smb producer [camel]
cunningt commented on code in PR #14495: URL: https://github.com/apache/camel/pull/14495#discussion_r1640566454 ## catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/schemas/camel-spring.xsd: ## Review Comment: Whoops - copied the current version of camel-spring.xsd from main back into this branch -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
Re: [PR] CAMEL-20679 Add a camel-smb producer [camel]
cunningt commented on code in PR #14495:
URL: https://github.com/apache/camel/pull/14495#discussion_r1640566398
##
components/camel-smb/src/main/java/org/apache/camel/component/smb/SmbProducer.java:
##
@@ -0,0 +1,239 @@
+/*
+ * 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.component.smb;
+
+import java.io.IOException;
+import java.io.InputStream;
+import java.util.Arrays;
+import java.util.HashSet;
+
+import com.hierynomus.msdtyp.AccessMask;
+import com.hierynomus.msfscc.FileAttributes;
+import com.hierynomus.mssmb2.SMB2CreateDisposition;
+import com.hierynomus.mssmb2.SMB2CreateOptions;
+import com.hierynomus.mssmb2.SMB2ShareAccess;
+import com.hierynomus.smbj.SMBClient;
+import com.hierynomus.smbj.auth.AuthenticationContext;
+import com.hierynomus.smbj.connection.Connection;
+import com.hierynomus.smbj.session.Session;
+import com.hierynomus.smbj.share.DiskShare;
+import com.hierynomus.smbj.share.File;
+import com.hierynomus.smbj.utils.SmbFiles;
+import org.apache.camel.Exchange;
+import org.apache.camel.RuntimeCamelException;
+import org.apache.camel.component.file.GenericFileExist;
+import org.apache.camel.support.DefaultProducer;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import static org.apache.camel.util.ObjectHelper.isEmpty;
+
+/**
+ * SMB file producer
+ */
+public class SmbProducer extends DefaultProducer {
+private static final Logger LOGGER =
LoggerFactory.getLogger(SmbProducer.class);
+
+private boolean loggedIn;
+private Session session;
+private final SMBClient smbClient;
+
+protected SmbProducer(final SmbEndpoint endpoint) {
+super(endpoint);
+
+if (getEndpoint().getConfiguration().getSmbConfig() != null) {
+smbClient = new
SMBClient(getEndpoint().getConfiguration().getSmbConfig());
+} else {
+smbClient = new SMBClient();
+}
+}
+
+@Override
+protected void doStop() throws Exception {
+LOGGER.debug("Producer SMB client stopped");
+super.doStop();
+}
+
+@Override
+protected void doStart() throws Exception {
+LOGGER.debug("Producer SMB client started");
+
+super.doStart();
+}
+
+/*
+ * Normalize changes separators for smb
+ */
+public String normalize(String file) {
+String result = file.replace('\\', '/');
+LOGGER.debug("Normalize path {} to {}", file, result);
+return result;
+}
+
+protected void connectIfNecessary(Exchange exchange) throws IOException {
+Connection connection = smbClient.connect(getEndpoint().getHostname(),
getEndpoint().getPort());
+
+if (!loggedIn) {
+LOGGER.debug("Not already connected/logged in. Connecting to: {}",
getEndpoint());
+
+AuthenticationContext ac = new AuthenticationContext(
+getEndpoint().getConfiguration().getUsername(),
+
getEndpoint().getConfiguration().getPassword().toCharArray(),
+getEndpoint().getConfiguration().getDomain());
+session = connection.authenticate(ac);
+
+LOGGER.debug("Connected and logged in to: {}", getEndpoint());
+}
+}
+
+public void disconnect() throws IOException {
+loggedIn = false;
+LOGGER.debug("Disconnecting from: {}", getEndpoint());
+
+session.close();
+
+session = null;
+}
+
+public void createDirectory(DiskShare share, java.io.File file) {
+String parentDir = file.getParent();
+SmbConfiguration configuration = getEndpoint().getConfiguration();
+
+boolean dirExists = share.folderExists(parentDir);
+if (!dirExists && configuration.isAutoCreate()) {
+SmbFiles files = new SmbFiles();
+files.mkdirs(share, normalize(parentDir));
+}
+
+if (!dirExists) {
+throw new RuntimeCamelException("Directory " + parentDir + " does
not exist on share " + share.toString());
+}
+}
+
+private GenericFileExist determineFileExist(Exchange exchange) {
+GenericFileExist gfe =
exchange.getIn().getHeader(SmbConstants.SMB_FILE_EXISTS,
GenericFileExist.class);
+
Re: [PR] CAMEL-20679 Add a camel-smb producer [camel]
cunningt commented on code in PR #14495:
URL: https://github.com/apache/camel/pull/14495#discussion_r1640566266
##
components/camel-smb/src/main/java/org/apache/camel/component/smb/SmbProducer.java:
##
@@ -0,0 +1,239 @@
+/*
+ * 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.component.smb;
+
+import java.io.IOException;
+import java.io.InputStream;
+import java.util.Arrays;
+import java.util.HashSet;
+
+import com.hierynomus.msdtyp.AccessMask;
+import com.hierynomus.msfscc.FileAttributes;
+import com.hierynomus.mssmb2.SMB2CreateDisposition;
+import com.hierynomus.mssmb2.SMB2CreateOptions;
+import com.hierynomus.mssmb2.SMB2ShareAccess;
+import com.hierynomus.smbj.SMBClient;
+import com.hierynomus.smbj.auth.AuthenticationContext;
+import com.hierynomus.smbj.connection.Connection;
+import com.hierynomus.smbj.session.Session;
+import com.hierynomus.smbj.share.DiskShare;
+import com.hierynomus.smbj.share.File;
+import com.hierynomus.smbj.utils.SmbFiles;
+import org.apache.camel.Exchange;
+import org.apache.camel.RuntimeCamelException;
+import org.apache.camel.component.file.GenericFileExist;
+import org.apache.camel.support.DefaultProducer;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import static org.apache.camel.util.ObjectHelper.isEmpty;
+
+/**
+ * SMB file producer
+ */
+public class SmbProducer extends DefaultProducer {
+private static final Logger LOGGER =
LoggerFactory.getLogger(SmbProducer.class);
+
+private boolean loggedIn;
+private Session session;
+private final SMBClient smbClient;
+
+protected SmbProducer(final SmbEndpoint endpoint) {
+super(endpoint);
+
+if (getEndpoint().getConfiguration().getSmbConfig() != null) {
+smbClient = new
SMBClient(getEndpoint().getConfiguration().getSmbConfig());
+} else {
+smbClient = new SMBClient();
+}
+}
+
+@Override
+protected void doStop() throws Exception {
+LOGGER.debug("Producer SMB client stopped");
+super.doStop();
+}
+
+@Override
+protected void doStart() throws Exception {
+LOGGER.debug("Producer SMB client started");
+
+super.doStart();
+}
+
+/*
+ * Normalize changes separators for smb
+ */
+public String normalize(String file) {
+String result = file.replace('\\', '/');
+LOGGER.debug("Normalize path {} to {}", file, result);
+return result;
+}
+
+protected void connectIfNecessary(Exchange exchange) throws IOException {
+Connection connection = smbClient.connect(getEndpoint().getHostname(),
getEndpoint().getPort());
+
+if (!loggedIn) {
+LOGGER.debug("Not already connected/logged in. Connecting to: {}",
getEndpoint());
+
+AuthenticationContext ac = new AuthenticationContext(
+getEndpoint().getConfiguration().getUsername(),
+
getEndpoint().getConfiguration().getPassword().toCharArray(),
+getEndpoint().getConfiguration().getDomain());
+session = connection.authenticate(ac);
+
+LOGGER.debug("Connected and logged in to: {}", getEndpoint());
+}
+}
+
+public void disconnect() throws IOException {
+loggedIn = false;
+LOGGER.debug("Disconnecting from: {}", getEndpoint());
+
+session.close();
+
+session = null;
+}
+
+public void createDirectory(DiskShare share, java.io.File file) {
+String parentDir = file.getParent();
+SmbConfiguration configuration = getEndpoint().getConfiguration();
+
+boolean dirExists = share.folderExists(parentDir);
+if (!dirExists && configuration.isAutoCreate()) {
+SmbFiles files = new SmbFiles();
+files.mkdirs(share, normalize(parentDir));
+}
+
+if (!dirExists) {
+throw new RuntimeCamelException("Directory " + parentDir + " does
not exist on share " + share.toString());
+}
+}
+
+private GenericFileExist determineFileExist(Exchange exchange) {
+GenericFileExist gfe =
exchange.getIn().getHeader(SmbConstants.SMB_FILE_EXISTS,
GenericFileExist.class);
+
Re: [PR] CAMEL-20679 Add a camel-smb producer [camel]
cunningt commented on code in PR #14495:
URL: https://github.com/apache/camel/pull/14495#discussion_r1640566237
##
components/camel-smb/src/main/java/org/apache/camel/component/smb/SmbProducer.java:
##
@@ -0,0 +1,239 @@
+/*
+ * 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.component.smb;
+
+import java.io.IOException;
+import java.io.InputStream;
+import java.util.Arrays;
+import java.util.HashSet;
+
+import com.hierynomus.msdtyp.AccessMask;
+import com.hierynomus.msfscc.FileAttributes;
+import com.hierynomus.mssmb2.SMB2CreateDisposition;
+import com.hierynomus.mssmb2.SMB2CreateOptions;
+import com.hierynomus.mssmb2.SMB2ShareAccess;
+import com.hierynomus.smbj.SMBClient;
+import com.hierynomus.smbj.auth.AuthenticationContext;
+import com.hierynomus.smbj.connection.Connection;
+import com.hierynomus.smbj.session.Session;
+import com.hierynomus.smbj.share.DiskShare;
+import com.hierynomus.smbj.share.File;
+import com.hierynomus.smbj.utils.SmbFiles;
+import org.apache.camel.Exchange;
+import org.apache.camel.RuntimeCamelException;
+import org.apache.camel.component.file.GenericFileExist;
+import org.apache.camel.support.DefaultProducer;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import static org.apache.camel.util.ObjectHelper.isEmpty;
+
+/**
+ * SMB file producer
+ */
+public class SmbProducer extends DefaultProducer {
+private static final Logger LOGGER =
LoggerFactory.getLogger(SmbProducer.class);
+
+private boolean loggedIn;
+private Session session;
+private final SMBClient smbClient;
+
+protected SmbProducer(final SmbEndpoint endpoint) {
+super(endpoint);
+
+if (getEndpoint().getConfiguration().getSmbConfig() != null) {
+smbClient = new
SMBClient(getEndpoint().getConfiguration().getSmbConfig());
+} else {
+smbClient = new SMBClient();
+}
+}
+
+@Override
+protected void doStop() throws Exception {
+LOGGER.debug("Producer SMB client stopped");
+super.doStop();
+}
+
+@Override
+protected void doStart() throws Exception {
+LOGGER.debug("Producer SMB client started");
+
+super.doStart();
+}
+
+/*
+ * Normalize changes separators for smb
+ */
+public String normalize(String file) {
+String result = file.replace('\\', '/');
+LOGGER.debug("Normalize path {} to {}", file, result);
+return result;
+}
+
+protected void connectIfNecessary(Exchange exchange) throws IOException {
+Connection connection = smbClient.connect(getEndpoint().getHostname(),
getEndpoint().getPort());
+
+if (!loggedIn) {
+LOGGER.debug("Not already connected/logged in. Connecting to: {}",
getEndpoint());
+
+AuthenticationContext ac = new AuthenticationContext(
+getEndpoint().getConfiguration().getUsername(),
+
getEndpoint().getConfiguration().getPassword().toCharArray(),
+getEndpoint().getConfiguration().getDomain());
+session = connection.authenticate(ac);
+
+LOGGER.debug("Connected and logged in to: {}", getEndpoint());
+}
+}
+
+public void disconnect() throws IOException {
+loggedIn = false;
+LOGGER.debug("Disconnecting from: {}", getEndpoint());
+
+session.close();
+
+session = null;
+}
+
+public void createDirectory(DiskShare share, java.io.File file) {
+String parentDir = file.getParent();
+SmbConfiguration configuration = getEndpoint().getConfiguration();
+
+boolean dirExists = share.folderExists(parentDir);
+if (!dirExists && configuration.isAutoCreate()) {
+SmbFiles files = new SmbFiles();
+files.mkdirs(share, normalize(parentDir));
+}
+
+if (!dirExists) {
+throw new RuntimeCamelException("Directory " + parentDir + " does
not exist on share " + share.toString());
+}
+}
+
+private GenericFileExist determineFileExist(Exchange exchange) {
+GenericFileExist gfe =
exchange.getIn().getHeader(SmbConstants.SMB_FILE_EXISTS,
GenericFileExist.class);
+
Re: [PR] CAMEL-20679 Add a camel-smb producer [camel]
cunningt commented on code in PR #14495:
URL: https://github.com/apache/camel/pull/14495#discussion_r1640566173
##
components/camel-smb/src/main/java/org/apache/camel/component/smb/SmbProducer.java:
##
@@ -0,0 +1,239 @@
+/*
+ * 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.component.smb;
+
+import java.io.IOException;
+import java.io.InputStream;
+import java.util.Arrays;
+import java.util.HashSet;
+
+import com.hierynomus.msdtyp.AccessMask;
+import com.hierynomus.msfscc.FileAttributes;
+import com.hierynomus.mssmb2.SMB2CreateDisposition;
+import com.hierynomus.mssmb2.SMB2CreateOptions;
+import com.hierynomus.mssmb2.SMB2ShareAccess;
+import com.hierynomus.smbj.SMBClient;
+import com.hierynomus.smbj.auth.AuthenticationContext;
+import com.hierynomus.smbj.connection.Connection;
+import com.hierynomus.smbj.session.Session;
+import com.hierynomus.smbj.share.DiskShare;
+import com.hierynomus.smbj.share.File;
+import com.hierynomus.smbj.utils.SmbFiles;
+import org.apache.camel.Exchange;
+import org.apache.camel.RuntimeCamelException;
+import org.apache.camel.component.file.GenericFileExist;
+import org.apache.camel.support.DefaultProducer;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import static org.apache.camel.util.ObjectHelper.isEmpty;
+
+/**
+ * SMB file producer
+ */
+public class SmbProducer extends DefaultProducer {
+private static final Logger LOGGER =
LoggerFactory.getLogger(SmbProducer.class);
+
+private boolean loggedIn;
+private Session session;
+private final SMBClient smbClient;
+
+protected SmbProducer(final SmbEndpoint endpoint) {
+super(endpoint);
+
+if (getEndpoint().getConfiguration().getSmbConfig() != null) {
+smbClient = new
SMBClient(getEndpoint().getConfiguration().getSmbConfig());
+} else {
+smbClient = new SMBClient();
+}
+}
+
+@Override
+protected void doStop() throws Exception {
+LOGGER.debug("Producer SMB client stopped");
+super.doStop();
+}
+
+@Override
+protected void doStart() throws Exception {
+LOGGER.debug("Producer SMB client started");
+
+super.doStart();
+}
+
+/*
+ * Normalize changes separators for smb
+ */
+public String normalize(String file) {
+String result = file.replace('\\', '/');
+LOGGER.debug("Normalize path {} to {}", file, result);
+return result;
+}
+
+protected void connectIfNecessary(Exchange exchange) throws IOException {
+Connection connection = smbClient.connect(getEndpoint().getHostname(),
getEndpoint().getPort());
+
+if (!loggedIn) {
+LOGGER.debug("Not already connected/logged in. Connecting to: {}",
getEndpoint());
+
+AuthenticationContext ac = new AuthenticationContext(
+getEndpoint().getConfiguration().getUsername(),
+
getEndpoint().getConfiguration().getPassword().toCharArray(),
+getEndpoint().getConfiguration().getDomain());
+session = connection.authenticate(ac);
+
+LOGGER.debug("Connected and logged in to: {}", getEndpoint());
+}
+}
+
+public void disconnect() throws IOException {
+loggedIn = false;
+LOGGER.debug("Disconnecting from: {}", getEndpoint());
+
+session.close();
+
+session = null;
+}
+
+public void createDirectory(DiskShare share, java.io.File file) {
+String parentDir = file.getParent();
+SmbConfiguration configuration = getEndpoint().getConfiguration();
+
+boolean dirExists = share.folderExists(parentDir);
+if (!dirExists && configuration.isAutoCreate()) {
+SmbFiles files = new SmbFiles();
+files.mkdirs(share, normalize(parentDir));
+}
+
+if (!dirExists) {
+throw new RuntimeCamelException("Directory " + parentDir + " does
not exist on share " + share.toString());
+}
+}
+
+private GenericFileExist determineFileExist(Exchange exchange) {
+GenericFileExist gfe =
exchange.getIn().getHeader(SmbConstants.SMB_FILE_EXISTS,
GenericFileExist.class);
+
(camel-k) branch release-2.3.x updated: chore: nightly automatic updates
This is an automated email from the ASF dual-hosted git repository. github-bot pushed a commit to branch release-2.3.x in repository https://gitbox.apache.org/repos/asf/camel-k.git The following commit(s) were added to refs/heads/release-2.3.x by this push: new b64cdfc7f chore: nightly automatic updates b64cdfc7f is described below commit b64cdfc7f93f3f4289961b2f9342eaaf3a7f5376 Author: github-actions[bot] <41898282+github-actions[bot]@users.noreply.github.com> AuthorDate: Sat Jun 15 00:32:43 2024 + chore: nightly automatic updates --- CHANGELOG.md | 3 +++ 1 file changed, 3 insertions(+) diff --git a/CHANGELOG.md b/CHANGELOG.md index eb678b5f2..542c003ba 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -9,12 +9,15 @@ - Service/KService not created for vertx-websocket consumers [\#5628](https://github.com/apache/camel-k/issues/5628) - Modeline container.port trait config set as String value [\#5621](https://github.com/apache/camel-k/issues/5621) - Documentation links to old Camel K examples location [\#5619](https://github.com/apache/camel-k/issues/5619) +- maven-settings-offline-template.xml does not contain license [\#5603](https://github.com/apache/camel-k/issues/5603) - Bring back Quarkus native test in PR [\#5598](https://github.com/apache/camel-k/issues/5598) - Unable to specify any CloudEvent attributes or extensions, except for `type` [\#5537](https://github.com/apache/camel-k/issues/5537) - Move deprecated v1alpha1.KameletBinding tests to v1.Pipe [\#5490](https://github.com/apache/camel-k/issues/5490) - Move tests, examples and documentation from groovy to yaml [\#5489](https://github.com/apache/camel-k/issues/5489) +- Add a deploy make target [\#5460](https://github.com/apache/camel-k/issues/5460) - Remove health readiness workaround when fixed in Camel [\#5451](https://github.com/apache/camel-k/issues/5451) - Dependency Service Discovery for Camel K [\#5196](https://github.com/apache/camel-k/issues/5196) +- Mount configmap/secret resources to a dedicated resources.d durectory [\#5181](https://github.com/apache/camel-k/issues/5181) - Support YAML DSL routes configuration [\#4893](https://github.com/apache/camel-k/issues/4893) - Kustomize installation does not work [\#4528](https://github.com/apache/camel-k/issues/4528) - Kustomize default [\#4135](https://github.com/apache/camel-k/issues/4135)
Re: [I] [CI] - Camel Main Branch Build Failure [camel-quarkus]
github-actions[bot] commented on issue #2927: URL: https://github.com/apache/camel-quarkus/issues/2927#issuecomment-2168975461 The [camel-main](https://github.com/apache/camel-quarkus/tree/camel-main) branch build has failed: * Build ID: 9523835357-1410-2f3f4443-bb53-4c64-94c2-7e6d707128b6 * Camel Quarkus Commit: e951633e33c994d8654cc64c7e3b33fb931d2315 * Camel Main Commit: 4a39b1c11ff5d0a5e2ba573df13f47491b9d04af * Link to build: https://github.com/apache/camel-quarkus/actions/runs/9523835357 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
(camel-k) branch main updated: chore: nightly automatic updates
This is an automated email from the ASF dual-hosted git repository. github-bot pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel-k.git The following commit(s) were added to refs/heads/main by this push: new 865a64ba3 chore: nightly automatic updates 865a64ba3 is described below commit 865a64ba3d583724369e3bef664e87fc141e7d5b Author: github-actions[bot] <41898282+github-actions[bot]@users.noreply.github.com> AuthorDate: Fri Jun 14 23:48:34 2024 + chore: nightly automatic updates --- CHANGELOG.md | 6 ++ 1 file changed, 6 insertions(+) diff --git a/CHANGELOG.md b/CHANGELOG.md index 4c57fe83c..3601fabc4 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -9,11 +9,15 @@ - Service/KService not created for vertx-websocket consumers [\#5628](https://github.com/apache/camel-k/issues/5628) - Modeline container.port trait config set as String value [\#5621](https://github.com/apache/camel-k/issues/5621) - Documentation links to old Camel K examples location [\#5619](https://github.com/apache/camel-k/issues/5619) +- maven-settings-offline-template.xml does not contain license [\#5603](https://github.com/apache/camel-k/issues/5603) - Bring back Quarkus native test in PR [\#5598](https://github.com/apache/camel-k/issues/5598) - Unable to specify any CloudEvent attributes or extensions, except for `type` [\#5537](https://github.com/apache/camel-k/issues/5537) - Move deprecated v1alpha1.KameletBinding tests to v1.Pipe [\#5490](https://github.com/apache/camel-k/issues/5490) - Move tests, examples and documentation from groovy to yaml [\#5489](https://github.com/apache/camel-k/issues/5489) +- Add a deploy make target [\#5460](https://github.com/apache/camel-k/issues/5460) - Remove health readiness workaround when fixed in Camel [\#5451](https://github.com/apache/camel-k/issues/5451) +- Dependency Service Discovery for Camel K [\#5196](https://github.com/apache/camel-k/issues/5196) +- Mount configmap/secret resources to a dedicated resources.d durectory [\#5181](https://github.com/apache/camel-k/issues/5181) - Support YAML DSL routes configuration [\#4893](https://github.com/apache/camel-k/issues/4893) - Kustomize installation does not work [\#4528](https://github.com/apache/camel-k/issues/4528) - Kustomize default [\#4135](https://github.com/apache/camel-k/issues/4135) @@ -21,6 +25,8 @@ **Merged pull requests:** +- chore\(release\): fix missing licenses [\#5630](https://github.com/apache/camel-k/pull/5630) ([gansheer](https://github.com/gansheer)) +- feat\(ci\): local installation procedure [\#5629](https://github.com/apache/camel-k/pull/5629) ([squakez](https://github.com/squakez)) - feat\(ci\): bring back Quarkus native execution on PR and pushes [\#5626](https://github.com/apache/camel-k/pull/5626) ([squakez](https://github.com/squakez)) - doc: Fix Camel K examples links [\#5625](https://github.com/apache/camel-k/pull/5625) ([gansheer](https://github.com/gansheer)) - \(\#5490\) Move deprecated v1alpha1.KameletBinding tests to v1.Pipe [\#5624](https://github.com/apache/camel-k/pull/5624) ([tdiesler](https://github.com/tdiesler))
Re: [PR] Bump quarkiverse-jgit.version from 3.1.0 to 3.1.1 [camel-quarkus]
github-actions[bot] commented on PR #6193: URL: https://github.com/apache/camel-quarkus/pull/6193#issuecomment-2168811171 :warning: :warning: :warning: Branch auto synchronized due to changes in generated files. New workflow run triggered: https://github.com/apache/camel-quarkus/actions/runs/952210 Please check the workflow result before merging. :warning: :warning: :warning: -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
(camel-quarkus) branch dependabot/maven/quarkiverse-jgit.version-3.1.1 updated (b534b66175 -> 9736d736dc)
This is an automated email from the ASF dual-hosted git repository. github-bot pushed a change to branch dependabot/maven/quarkiverse-jgit.version-3.1.1 in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git from b534b66175 Bump quarkiverse-jgit.version from 3.1.0 to 3.1.1 add 9736d736dc Auto generated changes for dependabot commit b534b66175acf6eb115c16bac20c91064aeea3ed No new revisions were added by this update. Summary of changes: poms/bom/src/main/generated/flattened-full-pom.xml| 4 ++-- poms/bom/src/main/generated/flattened-reduced-pom.xml | 4 ++-- poms/bom/src/main/generated/flattened-reduced-verbose-pom.xml | 4 ++-- 3 files changed, 6 insertions(+), 6 deletions(-)
[PR] Bump quarkiverse-jgit.version from 3.1.0 to 3.1.1 [camel-quarkus]
dependabot[bot] opened a new pull request, #6193: URL: https://github.com/apache/camel-quarkus/pull/6193 Bumps `quarkiverse-jgit.version` from 3.1.0 to 3.1.1. Updates `io.quarkiverse.jgit:quarkus-jgit` from 3.1.0 to 3.1.1 Release notes Sourced from https://github.com/quarkiverse/quarkus-jgit/releases;>io.quarkiverse.jgit:quarkus-jgit's releases. 3.1.1 What's Changed Set WindowCache to be initialized during runtime by https://github.com/gastaldi;>@gastaldi in https://redirect.github.com/quarkiverse/quarkus-jgit/pull/124;>quarkiverse/quarkus-jgit#124 docs: add kjq as a contributor for bug by https://github.com/allcontributors;>@allcontributors in https://redirect.github.com/quarkiverse/quarkus-jgit/pull/126;>quarkiverse/quarkus-jgit#126 Release 3.1.1 by https://github.com/gastaldi;>@gastaldi in https://redirect.github.com/quarkiverse/quarkus-jgit/pull/125;>quarkiverse/quarkus-jgit#125 Full Changelog: https://github.com/quarkiverse/quarkus-jgit/compare/3.1.0...3.1.1;>https://github.com/quarkiverse/quarkus-jgit/compare/3.1.0...3.1.1 Commits https://github.com/quarkiverse/quarkus-jgit/commit/6ceff314720498794107eef7885e2b7350067d7c;>6ceff31 [maven-release-plugin] prepare release 3.1.1 https://github.com/quarkiverse/quarkus-jgit/commit/c097cad14bbd5d8303e49d4abf7e0f85ad9f12c8;>c097cad Update the latest release version 3.1.1 in documentation https://github.com/quarkiverse/quarkus-jgit/commit/679e4b6f44bbe38d11e338e48210929f62de22f5;>679e4b6 Release 3.1.1 (https://redirect.github.com/quarkiverse/quarkus-jgit/issues/125;>#125) https://github.com/quarkiverse/quarkus-jgit/commit/7eaea6e3868f9fa4839fd36231ba00a7407d2b07;>7eaea6e docs: add kjq as a contributor for bug (https://redirect.github.com/quarkiverse/quarkus-jgit/issues/126;>#126) https://github.com/quarkiverse/quarkus-jgit/commit/9d0e4288ca223380953d6f27132307021c1fcf39;>9d0e428 Set WindowCache to be initialized during runtime (https://redirect.github.com/quarkiverse/quarkus-jgit/issues/124;>#124) https://github.com/quarkiverse/quarkus-jgit/commit/49c9763ae490fc7bc188040a09df25e989367060;>49c9763 [maven-release-plugin] prepare for next development iteration See full diff in https://github.com/quarkiverse/quarkus-jgit/compare/3.1.0...3.1.1;>compare view Updates `io.quarkiverse.jgit:quarkus-jgit-deployment` from 3.1.0 to 3.1.1 Release notes Sourced from https://github.com/quarkiverse/quarkus-jgit/releases;>io.quarkiverse.jgit:quarkus-jgit-deployment's releases. 3.1.1 What's Changed Set WindowCache to be initialized during runtime by https://github.com/gastaldi;>@gastaldi in https://redirect.github.com/quarkiverse/quarkus-jgit/pull/124;>quarkiverse/quarkus-jgit#124 docs: add kjq as a contributor for bug by https://github.com/allcontributors;>@allcontributors in https://redirect.github.com/quarkiverse/quarkus-jgit/pull/126;>quarkiverse/quarkus-jgit#126 Release 3.1.1 by https://github.com/gastaldi;>@gastaldi in https://redirect.github.com/quarkiverse/quarkus-jgit/pull/125;>quarkiverse/quarkus-jgit#125 Full Changelog: https://github.com/quarkiverse/quarkus-jgit/compare/3.1.0...3.1.1;>https://github.com/quarkiverse/quarkus-jgit/compare/3.1.0...3.1.1 Commits https://github.com/quarkiverse/quarkus-jgit/commit/6ceff314720498794107eef7885e2b7350067d7c;>6ceff31 [maven-release-plugin] prepare release 3.1.1 https://github.com/quarkiverse/quarkus-jgit/commit/c097cad14bbd5d8303e49d4abf7e0f85ad9f12c8;>c097cad Update the latest release version 3.1.1 in documentation https://github.com/quarkiverse/quarkus-jgit/commit/679e4b6f44bbe38d11e338e48210929f62de22f5;>679e4b6 Release 3.1.1 (https://redirect.github.com/quarkiverse/quarkus-jgit/issues/125;>#125) https://github.com/quarkiverse/quarkus-jgit/commit/7eaea6e3868f9fa4839fd36231ba00a7407d2b07;>7eaea6e docs: add kjq as a contributor for bug (https://redirect.github.com/quarkiverse/quarkus-jgit/issues/126;>#126) https://github.com/quarkiverse/quarkus-jgit/commit/9d0e4288ca223380953d6f27132307021c1fcf39;>9d0e428 Set WindowCache to be initialized during runtime (https://redirect.github.com/quarkiverse/quarkus-jgit/issues/124;>#124) https://github.com/quarkiverse/quarkus-jgit/commit/49c9763ae490fc7bc188040a09df25e989367060;>49c9763 [maven-release-plugin] prepare for next development iteration See full diff in https://github.com/quarkiverse/quarkus-jgit/compare/3.1.0...3.1.1;>compare view Dependabot will resolve any conflicts with this PR as long as you don't alter it yourself. You can also trigger a rebase manually by commenting `@dependabot rebase`. [//]: # (dependabot-automerge-start) [//]: # (dependabot-automerge-end) --- Dependabot commands and options You can trigger Dependabot actions by commenting on this PR: - `@dependabot rebase` will rebase this PR
(camel-quarkus) branch dependabot/maven/quarkiverse-jgit.version-3.1.1 created (now b534b66175)
This is an automated email from the ASF dual-hosted git repository. github-bot pushed a change to branch dependabot/maven/quarkiverse-jgit.version-3.1.1 in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git at b534b66175 Bump quarkiverse-jgit.version from 3.1.0 to 3.1.1 No new revisions were added by this update.
Re: [PR] Bump quarkiverse-minio.version from 3.7.2 to 3.7.3 [camel-quarkus]
github-actions[bot] commented on PR #6192: URL: https://github.com/apache/camel-quarkus/pull/6192#issuecomment-2168788950 :warning: :warning: :warning: Branch auto synchronized due to changes in generated files. New workflow run triggered: https://github.com/apache/camel-quarkus/actions/runs/9522586850 Please check the workflow result before merging. :warning: :warning: :warning: -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
(camel-quarkus) branch dependabot/maven/quarkiverse-minio.version-3.7.3 updated (43819c2631 -> 01276fee64)
This is an automated email from the ASF dual-hosted git repository. github-bot pushed a change to branch dependabot/maven/quarkiverse-minio.version-3.7.3 in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git from 43819c2631 Bump quarkiverse-minio.version from 3.7.2 to 3.7.3 add 01276fee64 Auto generated changes for dependabot commit 43819c2631fbac3f8ce259e80be7bdc5492d7323 No new revisions were added by this update. Summary of changes: poms/bom/src/main/generated/flattened-full-pom.xml| 8 poms/bom/src/main/generated/flattened-reduced-pom.xml | 4 ++-- poms/bom/src/main/generated/flattened-reduced-verbose-pom.xml | 4 ++-- 3 files changed, 8 insertions(+), 8 deletions(-)
(camel-quarkus) branch dependabot/maven/quarkiverse-minio.version-3.7.3 created (now 43819c2631)
This is an automated email from the ASF dual-hosted git repository. github-bot pushed a change to branch dependabot/maven/quarkiverse-minio.version-3.7.3 in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git at 43819c2631 Bump quarkiverse-minio.version from 3.7.2 to 3.7.3 No new revisions were added by this update.
[PR] Bump quarkiverse-minio.version from 3.7.2 to 3.7.3 [camel-quarkus]
dependabot[bot] opened a new pull request, #6192: URL: https://github.com/apache/camel-quarkus/pull/6192 Bumps `quarkiverse-minio.version` from 3.7.2 to 3.7.3. Updates `io.quarkiverse.minio:quarkus-minio` from 3.7.2 to 3.7.3 Updates `io.quarkiverse.minio:quarkus-minio-deployment` from 3.7.2 to 3.7.3 Updates `io.quarkiverse.minio:quarkus-minio-native` from 3.7.2 to 3.7.3 Updates `io.quarkiverse.minio:quarkus-minio-native-deployment` from 3.7.2 to 3.7.3 Dependabot will resolve any conflicts with this PR as long as you don't alter it yourself. You can also trigger a rebase manually by commenting `@dependabot rebase`. [//]: # (dependabot-automerge-start) [//]: # (dependabot-automerge-end) --- Dependabot commands and options You can trigger Dependabot actions by commenting on this PR: - `@dependabot rebase` will rebase this PR - `@dependabot recreate` will recreate this PR, overwriting any edits that have been made to it - `@dependabot merge` will merge this PR after your CI passes on it - `@dependabot squash and merge` will squash and merge this PR after your CI passes on it - `@dependabot cancel merge` will cancel a previously requested merge and block automerging - `@dependabot reopen` will reopen this PR if it is closed - `@dependabot close` will close this PR and stop Dependabot recreating it. You can achieve the same result by closing it manually - `@dependabot show ignore conditions` will show all of the ignore conditions of the specified dependency - `@dependabot ignore this major version` will close this PR and stop Dependabot creating any more for this major version (unless you reopen the PR or upgrade to it yourself) - `@dependabot ignore this minor version` will close this PR and stop Dependabot creating any more for this minor version (unless you reopen the PR or upgrade to it yourself) - `@dependabot ignore this dependency` will close this PR and stop Dependabot creating any more for this dependency (unless you reopen the PR or upgrade to it yourself) -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
Re: [PR] Add camel-saxon integration test [camel-karaf]
f2par0 commented on code in PR #353:
URL: https://github.com/apache/camel-karaf/pull/353#discussion_r1640349766
##
tests/features/camel-saxon/src/main/java/org/apache/karaf/camel/test/CamelSaxonRouteSupplier.java:
##
@@ -0,0 +1,56 @@
+/*
+ * 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.karaf.camel.test;
+
+import org.apache.camel.builder.RouteBuilder;
+import org.apache.camel.model.RouteDefinition;
+import
org.apache.karaf.camel.itests.AbstractCamelSingleFeatureResultMockBasedRouteSupplier;
+import org.apache.karaf.camel.itests.CamelRouteSupplier;
+import org.osgi.service.component.annotations.Component;
+
+@Component(
+name = "karaf-camel-saxon-test",
+immediate = true,
+service = CamelRouteSupplier.class
+)
+public class CamelSaxonRouteSupplier extends
AbstractCamelSingleFeatureResultMockBasedRouteSupplier {
+
+
+@Override
+protected boolean consumerEnabled() {
+return false;
+}
+
+@Override
+protected void configureProducer(RouteBuilder builder, RouteDefinition
producerRoute) {
+producerRoute.log("calling xquery endpoint")
+
.setBody(builder.constant("London"))
+.choice()
+.when().xpath("person/city = 'London'")
Review Comment:
Fixed, it was a copy of the test in the camel project.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
[PR] Bump the maven group across 22 directories with 3 updates [camel-quarkus-examples]
dependabot[bot] opened a new pull request, #232: URL: https://github.com/apache/camel-quarkus-examples/pull/232 Bumps the maven group with 2 updates in the /aws-lambda directory: [org.apache.maven.plugins:maven-surefire-plugin](https://github.com/apache/maven-surefire) and [org.apache.maven.plugins:maven-failsafe-plugin](https://github.com/apache/maven-surefire). Bumps the maven group with 2 updates in the /cluster-leader-election directory: [org.apache.maven.plugins:maven-surefire-plugin](https://github.com/apache/maven-surefire) and [org.apache.maven.plugins:maven-failsafe-plugin](https://github.com/apache/maven-surefire). Bumps the maven group with 2 updates in the /cxf-soap directory: [org.apache.maven.plugins:maven-surefire-plugin](https://github.com/apache/maven-surefire) and [org.apache.maven.plugins:maven-failsafe-plugin](https://github.com/apache/maven-surefire). Bumps the maven group with 2 updates in the /file-bindy-ftp directory: [org.apache.maven.plugins:maven-surefire-plugin](https://github.com/apache/maven-surefire) and [org.apache.maven.plugins:maven-failsafe-plugin](https://github.com/apache/maven-surefire). Bumps the maven group with 2 updates in the /file-split-log-xml directory: [org.apache.maven.plugins:maven-surefire-plugin](https://github.com/apache/maven-surefire) and [org.apache.maven.plugins:maven-failsafe-plugin](https://github.com/apache/maven-surefire). Bumps the maven group with 2 updates in the /health directory: [org.apache.maven.plugins:maven-surefire-plugin](https://github.com/apache/maven-surefire) and [org.apache.maven.plugins:maven-failsafe-plugin](https://github.com/apache/maven-surefire). Bumps the maven group with 2 updates in the /http-log directory: [org.apache.maven.plugins:maven-surefire-plugin](https://github.com/apache/maven-surefire) and [org.apache.maven.plugins:maven-failsafe-plugin](https://github.com/apache/maven-surefire). Bumps the maven group with 2 updates in the /jdbc-datasource directory: [org.apache.maven.plugins:maven-surefire-plugin](https://github.com/apache/maven-surefire) and [org.apache.maven.plugins:maven-failsafe-plugin](https://github.com/apache/maven-surefire). Bumps the maven group with 2 updates in the /jms-jpa directory: [org.apache.maven.plugins:maven-surefire-plugin](https://github.com/apache/maven-surefire) and [org.apache.maven.plugins:maven-failsafe-plugin](https://github.com/apache/maven-surefire). Bumps the maven group with 2 updates in the /jpa-idempotent-repository directory: [org.apache.maven.plugins:maven-surefire-plugin](https://github.com/apache/maven-surefire) and [org.apache.maven.plugins:maven-failsafe-plugin](https://github.com/apache/maven-surefire). Bumps the maven group with 2 updates in the /jta-jpa directory: [org.apache.maven.plugins:maven-surefire-plugin](https://github.com/apache/maven-surefire) and [org.apache.maven.plugins:maven-failsafe-plugin](https://github.com/apache/maven-surefire). Bumps the maven group with 2 updates in the /kafka directory: [org.apache.maven.plugins:maven-surefire-plugin](https://github.com/apache/maven-surefire) and [org.apache.maven.plugins:maven-failsafe-plugin](https://github.com/apache/maven-surefire). Bumps the maven group with 2 updates in the /kamelet-chucknorris directory: [org.apache.maven.plugins:maven-surefire-plugin](https://github.com/apache/maven-surefire) and [org.apache.maven.plugins:maven-failsafe-plugin](https://github.com/apache/maven-surefire). Bumps the maven group with 2 updates in the /message-bridge directory: [org.apache.maven.plugins:maven-surefire-plugin](https://github.com/apache/maven-surefire) and [org.apache.maven.plugins:maven-failsafe-plugin](https://github.com/apache/maven-surefire). Bumps the maven group with 2 updates in the /observability directory: [org.apache.maven.plugins:maven-surefire-plugin](https://github.com/apache/maven-surefire) and [org.apache.maven.plugins:maven-failsafe-plugin](https://github.com/apache/maven-surefire). Bumps the maven group with 3 updates in the /openapi-contract-first directory: net.revelc.code:impsort-maven-plugin, [org.apache.maven.plugins:maven-surefire-plugin](https://github.com/apache/maven-surefire) and [org.apache.maven.plugins:maven-failsafe-plugin](https://github.com/apache/maven-surefire). Bumps the maven group with 2 updates in the /platform-http-security-keycloak directory: [org.apache.maven.plugins:maven-surefire-plugin](https://github.com/apache/maven-surefire) and [org.apache.maven.plugins:maven-failsafe-plugin](https://github.com/apache/maven-surefire). Bumps the maven group with 2 updates in the /rest-json directory: [org.apache.maven.plugins:maven-surefire-plugin](https://github.com/apache/maven-surefire) and [org.apache.maven.plugins:maven-failsafe-plugin](https://github.com/apache/maven-surefire). Bumps the maven group with 2 updates in the /timer-log directory:
(camel-quarkus-examples) branch dependabot/maven/aws-lambda/camel-quarkus-main/maven-76e1679127 created (now fb01f5f)
This is an automated email from the ASF dual-hosted git repository. github-bot pushed a change to branch dependabot/maven/aws-lambda/camel-quarkus-main/maven-76e1679127 in repository https://gitbox.apache.org/repos/asf/camel-quarkus-examples.git at fb01f5f Bump the maven group across 22 directories with 3 updates No new revisions were added by this update.
(camel-kamelets) branch regen_bot updated (5dfda255 -> d12155f3)
This is an automated email from the ASF dual-hosted git repository. github-bot pushed a change to branch regen_bot in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git omit 5dfda255 Regen for commit d2a560ff60c517343929668cda23210603178e98 add d12155f3 Regen for commit d2a560ff60c517343929668cda23210603178e98 (#2077) 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 (5dfda255) \ N -- N -- N refs/heads/regen_bot (d12155f3) 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. No new revisions were added by this update. Summary of changes:
(camel-kamelets) branch main updated: Regen for commit d2a560ff60c517343929668cda23210603178e98 (#2077)
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
The following commit(s) were added to refs/heads/main by this push:
new d12155f3 Regen for commit d2a560ff60c517343929668cda23210603178e98
(#2077)
d12155f3 is described below
commit d12155f396158cd5c6124af1d97ddaf7f8a8c9c6
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Fri Jun 14 19:24:00 2024 +0200
Regen for commit d2a560ff60c517343929668cda23210603178e98 (#2077)
Signed-off-by: GitHub
Co-authored-by: claudio4j
---
.../kamelets/salesforce-update-sink.kamelet.yaml | 31 +-
1 file changed, 19 insertions(+), 12 deletions(-)
diff --git
a/library/camel-kamelets/src/main/resources/kamelets/salesforce-update-sink.kamelet.yaml
b/library/camel-kamelets/src/main/resources/kamelets/salesforce-update-sink.kamelet.yaml
index 5e987a73..f3eac11d 100644
---
a/library/camel-kamelets/src/main/resources/kamelets/salesforce-update-sink.kamelet.yaml
+++
b/library/camel-kamelets/src/main/resources/kamelets/salesforce-update-sink.kamelet.yaml
@@ -31,16 +31,16 @@ spec:
definition:
title: "Salesforce Update Sink"
description: |-
- Update an object in Salesforce.
-
- The body received must contain a JSON key-value pair for each property
to update inside the payload attribute, for example:
-
+ Update an object in Salesforce.
+
+ The body received must contain a JSON key-value pair for each property
to update inside the payload attribute, for example:
+
`{ "payload": { "Phone": "1234567890", "Name": "Antonia" } }`
-
+
The body received must include the `sObjectName` and `sObjectId`
properties, for example:
`{ "payload": { "Phone": "1234567890", "Name": "Antonia" }, "sObjectId":
"sObjectId", "sObjectName": "sObjectName" }`
-
+
required:
- clientId
- clientSecret
@@ -101,14 +101,21 @@ spec:
from:
uri: kamelet:source
steps:
-- setProperty:
+- setHeader:
name: sObjectId
-jsonpath: "$['sObjectId']"
-- setProperty:
+jsonpath: "$.sObjectId"
+- setHeader:
name: sObjectName
-jsonpath: "$['sObjectName']"
+jsonpath: "$.sObjectName"
- transform:
-jsonpath: "$['payload']"
+jsonpath: "$.payload"
- marshal:
json: {}
-- toD:
"{{local-salesforce}}:updateSObject?sObjectId=${exchangeProperty.sObjectId}=${exchangeProperty.sObjectName}=true"
+- to:
+uri: "{{local-salesforce}}:updateSObject"
+parameters:
+ rawPayload: "true"
+- removeHeader:
+name: sObjectId
+- removeHeader:
+name: sObjectName
Re: [PR] Generated sources regen [camel-kamelets]
oscerd merged PR #2077: URL: https://github.com/apache/camel-kamelets/pull/2077 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[PR] Generated sources regen [camel-kamelets]
github-actions[bot] opened a new pull request, #2077: URL: https://github.com/apache/camel-kamelets/pull/2077 Regen bot :robot: found some uncommited changes after running build on :camel: kamelets main. Please do not delete `regen_bot` branch after merge/rebase. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
(camel-kamelets) branch regen_bot updated (791443d1 -> 5dfda255)
This is an automated email from the ASF dual-hosted git repository. github-bot pushed a change to branch regen_bot in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git from 791443d1 fix: Avoid Class cast errors in TimestampRouter add d2a560ff Fix salesforce-update-sink.kamelet (#2076) add 5dfda255 Regen for commit d2a560ff60c517343929668cda23210603178e98 No new revisions were added by this update. Summary of changes: kamelets/salesforce-update-sink.kamelet.yaml | 31 +- .../kamelets/salesforce-update-sink.kamelet.yaml | 31 +- 2 files changed, 38 insertions(+), 24 deletions(-)
(camel-kamelets) branch main updated: Fix salesforce-update-sink.kamelet (#2076)
This is an automated email from the ASF dual-hosted git repository.
claudio4j pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
The following commit(s) were added to refs/heads/main by this push:
new d2a560ff Fix salesforce-update-sink.kamelet (#2076)
d2a560ff is described below
commit d2a560ff60c517343929668cda23210603178e98
Author: Claudio Miranda
AuthorDate: Fri Jun 14 14:22:15 2024 -0300
Fix salesforce-update-sink.kamelet (#2076)
Fix https://github.com/apache/camel-kamelets/issues/1590
At runtime the bean is renamed which seems to cause the
NoSuchEndpointException: No endpoint could be found for: local-salesforce-1
---
kamelets/salesforce-update-sink.kamelet.yaml | 31 +---
1 file changed, 19 insertions(+), 12 deletions(-)
diff --git a/kamelets/salesforce-update-sink.kamelet.yaml
b/kamelets/salesforce-update-sink.kamelet.yaml
index 5e987a73..f3eac11d 100644
--- a/kamelets/salesforce-update-sink.kamelet.yaml
+++ b/kamelets/salesforce-update-sink.kamelet.yaml
@@ -31,16 +31,16 @@ spec:
definition:
title: "Salesforce Update Sink"
description: |-
- Update an object in Salesforce.
-
- The body received must contain a JSON key-value pair for each property
to update inside the payload attribute, for example:
-
+ Update an object in Salesforce.
+
+ The body received must contain a JSON key-value pair for each property
to update inside the payload attribute, for example:
+
`{ "payload": { "Phone": "1234567890", "Name": "Antonia" } }`
-
+
The body received must include the `sObjectName` and `sObjectId`
properties, for example:
`{ "payload": { "Phone": "1234567890", "Name": "Antonia" }, "sObjectId":
"sObjectId", "sObjectName": "sObjectName" }`
-
+
required:
- clientId
- clientSecret
@@ -101,14 +101,21 @@ spec:
from:
uri: kamelet:source
steps:
-- setProperty:
+- setHeader:
name: sObjectId
-jsonpath: "$['sObjectId']"
-- setProperty:
+jsonpath: "$.sObjectId"
+- setHeader:
name: sObjectName
-jsonpath: "$['sObjectName']"
+jsonpath: "$.sObjectName"
- transform:
-jsonpath: "$['payload']"
+jsonpath: "$.payload"
- marshal:
json: {}
-- toD:
"{{local-salesforce}}:updateSObject?sObjectId=${exchangeProperty.sObjectId}=${exchangeProperty.sObjectName}=true"
+- to:
+uri: "{{local-salesforce}}:updateSObject"
+parameters:
+ rawPayload: "true"
+- removeHeader:
+name: sObjectId
+- removeHeader:
+name: sObjectName
Re: [PR] Fix salesforce-update-sink.kamelet [camel-kamelets]
claudio4j merged PR #2076: URL: https://github.com/apache/camel-kamelets/pull/2076 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
Re: [PR] camel-velocity integration test [camel-karaf]
essobedo commented on code in PR #356:
URL: https://github.com/apache/camel-karaf/pull/356#discussion_r1640101886
##
tests/features/camel-velocity/src/test/test/org/apache/karaf/camel/itest/CamelVelocityITest.java:
##
@@ -0,0 +1,42 @@
+/*
+ * Licensed 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.karaf.camel.itest;
+
+import org.apache.camel.component.mock.MockEndpoint;
+import
org.apache.karaf.camel.itests.AbstractCamelSingleFeatureResultMockBasedRouteITest;
+import org.apache.karaf.camel.itests.CamelKarafTestHint;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.ops4j.pax.exam.junit.PaxExam;
+import org.ops4j.pax.exam.spi.reactors.ExamReactorStrategy;
+import org.ops4j.pax.exam.spi.reactors.PerClass;
+
+
+@CamelKarafTestHint(isBlueprintTest = true)
+@RunWith(PaxExam.class)
+@ExamReactorStrategy(PerClass.class)
+public class CamelVelocityITest extends
AbstractCamelSingleFeatureResultMockBasedRouteITest {
+
+@Override
+public void configureMock(MockEndpoint mock) {
+mock.expectedBodiesReceived("World");
Review Comment:
It should be "Hello, World!" so there is something wrong somewhere
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
Re: [PR] camel-velocity integration test [camel-karaf]
essobedo commented on code in PR #356:
URL: https://github.com/apache/camel-karaf/pull/356#discussion_r1640101886
##
tests/features/camel-velocity/src/test/test/org/apache/karaf/camel/itest/CamelVelocityITest.java:
##
@@ -0,0 +1,42 @@
+/*
+ * Licensed 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.karaf.camel.itest;
+
+import org.apache.camel.component.mock.MockEndpoint;
+import
org.apache.karaf.camel.itests.AbstractCamelSingleFeatureResultMockBasedRouteITest;
+import org.apache.karaf.camel.itests.CamelKarafTestHint;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.ops4j.pax.exam.junit.PaxExam;
+import org.ops4j.pax.exam.spi.reactors.ExamReactorStrategy;
+import org.ops4j.pax.exam.spi.reactors.PerClass;
+
+
+@CamelKarafTestHint(isBlueprintTest = true)
+@RunWith(PaxExam.class)
+@ExamReactorStrategy(PerClass.class)
+public class CamelVelocityITest extends
AbstractCamelSingleFeatureResultMockBasedRouteITest {
+
+@Override
+public void configureMock(MockEndpoint mock) {
+mock.expectedBodiesReceived("World");
Review Comment:
It should be "Hello, World" so there is something wrong somwhere
##
tests/features/camel-velocity/src/test/test/org/apache/karaf/camel/itest/CamelVelocityITest.java:
##
@@ -0,0 +1,42 @@
+/*
+ * Licensed 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.karaf.camel.itest;
+
+import org.apache.camel.component.mock.MockEndpoint;
+import
org.apache.karaf.camel.itests.AbstractCamelSingleFeatureResultMockBasedRouteITest;
+import org.apache.karaf.camel.itests.CamelKarafTestHint;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.ops4j.pax.exam.junit.PaxExam;
+import org.ops4j.pax.exam.spi.reactors.ExamReactorStrategy;
+import org.ops4j.pax.exam.spi.reactors.PerClass;
+
+
+@CamelKarafTestHint(isBlueprintTest = true)
+@RunWith(PaxExam.class)
+@ExamReactorStrategy(PerClass.class)
+public class CamelVelocityITest extends
AbstractCamelSingleFeatureResultMockBasedRouteITest {
+
+@Override
+public void configureMock(MockEndpoint mock) {
+mock.expectedBodiesReceived("World");
Review Comment:
It should be "Hello, World" so there is something wrong somewhere
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
[PR] Fix salesforce-update-sink.kamelet [camel-kamelets]
claudio4j opened a new pull request, #2076: URL: https://github.com/apache/camel-kamelets/pull/2076 Fix https://github.com/apache/camel-kamelets/issues/1590 At runtime the "local-salesforce" bean is renamed which seems to cause the NoSuchEndpointException: No endpoint could be found for: local-salesforce-1 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
Re: [PR] camel-velocity integration test [camel-karaf]
essobedo commented on code in PR #356:
URL: https://github.com/apache/camel-karaf/pull/356#discussion_r1640092490
##
tests/features/camel-velocity/src/main/java/org/apache/karaf/camel/test/CamelVelocityRouteSupplier.java:
##
@@ -0,0 +1,51 @@
+
+/*
+ * 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.karaf.camel.test;
+
+import org.apache.camel.builder.RouteBuilder;
+import org.apache.camel.model.RouteDefinition;
+import
org.apache.karaf.camel.itests.AbstractCamelSingleFeatureResultMockBasedRouteSupplier;
+import org.apache.karaf.camel.itests.CamelRouteSupplier;
+import org.osgi.service.component.annotations.Component;
+
+import static org.apache.camel.builder.Builder.constant;
+
+@Component(
+name = "karaf-camel-saxon-test",
+immediate = true,
+service = CamelRouteSupplier.class
+)
+public class CamelVelocityRouteSupplier extends
AbstractCamelSingleFeatureResultMockBasedRouteSupplier {
+
+
+@Override
+protected boolean consumerEnabled() {
+return false;
Review Comment:
```suggestion
return false;
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
Re: [PR] Add camel-xslt-saxon integration test [camel-karaf]
essobedo commented on code in PR #355:
URL: https://github.com/apache/camel-karaf/pull/355#discussion_r1640084719
##
tests/features/camel-xslt-saxon/src/main/java/org/apache/karaf/camel/test/CamelXsltSaxonRouteSupplier.java:
##
@@ -0,0 +1,53 @@
+/*
+ * 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.karaf.camel.test;
+
+import org.apache.camel.CamelContext;
+import org.apache.camel.builder.RouteBuilder;
+import org.apache.camel.model.RouteDefinition;
+import
org.apache.karaf.camel.itests.AbstractCamelSingleFeatureResultMockBasedRouteSupplier;
+import org.apache.karaf.camel.itests.CamelRouteSupplier;
+import org.osgi.service.component.annotations.Component;
+
+import net.sf.saxon.TransformerFactoryImpl;
+
+@Component(
+name = "karaf-camel-xslt-saxon-test",
+immediate = true,
+service = CamelRouteSupplier.class
+)
+public class CamelXsltSaxonRouteSupplier extends
AbstractCamelSingleFeatureResultMockBasedRouteSupplier {
+
+@Override
+public void configure(CamelContext camelContext) {
+camelContext.getRegistry().bind("factory",
TransformerFactoryImpl.newInstance());
+}
+
+@Override
+protected boolean consumerEnabled() {
+return false;
Review Comment:
```suggestion
return false;
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
Re: [PR] Add camel-saxon integration test [camel-karaf]
essobedo commented on code in PR #353:
URL: https://github.com/apache/camel-karaf/pull/353#discussion_r1640076359
##
tests/features/camel-saxon/src/main/java/org/apache/karaf/camel/test/CamelSaxonRouteSupplier.java:
##
@@ -0,0 +1,56 @@
+/*
+ * 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.karaf.camel.test;
+
+import org.apache.camel.builder.RouteBuilder;
+import org.apache.camel.model.RouteDefinition;
+import
org.apache.karaf.camel.itests.AbstractCamelSingleFeatureResultMockBasedRouteSupplier;
+import org.apache.karaf.camel.itests.CamelRouteSupplier;
+import org.osgi.service.component.annotations.Component;
+
+@Component(
+name = "karaf-camel-saxon-test",
+immediate = true,
+service = CamelRouteSupplier.class
+)
+public class CamelSaxonRouteSupplier extends
AbstractCamelSingleFeatureResultMockBasedRouteSupplier {
+
+
+@Override
+protected boolean consumerEnabled() {
+return false;
+}
+
+@Override
+protected void configureProducer(RouteBuilder builder, RouteDefinition
producerRoute) {
+producerRoute.log("calling xquery endpoint")
+
.setBody(builder.constant("London"))
+.choice()
+.when().xpath("person/city = 'London'")
Review Comment:
Why don't you use an XQuery predicate?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
(camel-website-pub) branch asf-site updated (5ee25291d -> c4a02b1fc)
This is an automated email from the ASF dual-hosted git repository. git-site-role pushed a change to branch asf-site in repository https://gitbox.apache.org/repos/asf/camel-website-pub.git discard 5ee25291d Website updated to f305e6c63249579cd09d04b96d72ffe6d59f3eb6 discard d06fee896 Website updated to 325e929157412b27394080f4d4dba3d821476ddf new a21c35046 Website updated to 325e929157412b27394080f4d4dba3d821476ddf new c4a02b1fc Website updated to 83b62b584548f1b41590d464302248d3570a15eb 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 (5ee25291d) \ N -- N -- N refs/heads/asf-site (c4a02b1fc) 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: .htaccess | 172 +- .well-known/security.txt |2 +- camel-k/next/configuration/runtime-resources.html |8 +- camel-k/next/contributing/local-development.html |5 +- components/next/couchdb-component.html|2 +- components/next/pubnub-component.html |2 +- manual/camel-4x-upgrade-guide-4_7.html|4 +- releases/release-4.0.0/index.html |2 +- site-manifest.json|2 +- sitemap-camel-core.xml| 16 +- sitemap-camel-k.xml | 906 ++-- sitemap-camel-kafka-connector.xml | 832 +-- sitemap-camel-kamelets.xml| 1408 ++--- sitemap-camel-karaf.xml | 24 +- sitemap-camel-quarkus.xml | 2026 sitemap-camel-spring-boot.xml | 56 +- sitemap-components.xml| 5784 ++--- sitemap-manual.xml| 428 +- 18 files changed, 5842 insertions(+), 5837 deletions(-)
Error while running github feature from refs/heads/asf-site:.asf.yaml in camel-website-pub!
An error occurred while running github feature in .asf.yaml!:
422 {"message": "Validation Failed", "errors": [{"message": "Sorry, you need to
allow at least one merge strategy. (no_merge_method)", "resource":
"Repository", "field": "merge_commit_allowed", "code": "invalid"}],
"documentation_url":
"https://docs.github.com/rest/repos/repos#update-a-repository;, "status": "422"}
[PR] camel-velocity integration test [camel-karaf]
ozgurkisir-qlik opened a new pull request, #356: URL: https://github.com/apache/camel-karaf/pull/356 camel-velocity integration test added -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
Re: [PR] Add camel-saxon integration test [camel-karaf]
essobedo commented on code in PR #353:
URL: https://github.com/apache/camel-karaf/pull/353#discussion_r1640006576
##
tests/features/camel-saxon/src/main/java/org/apache/karaf/camel/test/CamelSaxonRouteSupplier.java:
##
@@ -0,0 +1,56 @@
+/*
+ * 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.karaf.camel.test;
+
+import org.apache.camel.builder.RouteBuilder;
+import org.apache.camel.model.RouteDefinition;
+import
org.apache.karaf.camel.itests.AbstractCamelSingleFeatureResultMockBasedRouteSupplier;
+import org.apache.karaf.camel.itests.CamelRouteSupplier;
+import org.osgi.service.component.annotations.Component;
+
+@Component(
+name = "karaf-camel-saxon-test",
+immediate = true,
+service = CamelRouteSupplier.class
+)
+public class CamelSaxonRouteSupplier extends
AbstractCamelSingleFeatureResultMockBasedRouteSupplier {
+
+
+@Override
+protected boolean consumerEnabled() {
+return false;
Review Comment:
```suggestion
return false;
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
(camel-website) 02/02: dedupe dependencies
This is an automated email from the ASF dual-hosted git repository.
zregvart pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-website.git
commit 83b62b584548f1b41590d464302248d3570a15eb
Author: Aurélien Pupier
AuthorDate: Thu Jun 13 16:47:03 2024 +0200
dedupe dependencies
after upgrading netlify, needs to call `yarn dedupe` to dedupe
dependencies as it is a requirement sin the build
Signed-off-by: Aurélien Pupier
---
.pnp.cjs | 632 +
...code-frame-npm-7.23.5-cb10d08de6-44e58529c9.zip | Bin 9307 -> 0 bytes
...ing-parser-npm-7.23.4-b1f0d030c3-c352082474.zip | Bin 10061 -> 0 bytes
...dentifier-npm-7.22.20-18305bb306-df882d2675.zip | Bin 17964 -> 0 bytes
...-highlight-npm-7.23.4-2a9f2d2538-62fef9b5bc.zip | Bin 7947 -> 0 bytes
...abel-types-npm-7.23.6-4e68ac9e9b-07e70bb94d.zip | Bin 331944 -> 0 bytes
...ag-browser-npm-7.22.3-7c38cb0a91-bacf2d6e6c.zip | Bin 147942 -> 0 bytes
...gsnag-core-npm-7.19.0-20de7ebabf-d70106675a.zip | Bin 38337 -> 0 bytes
...bugsnag-js-npm-7.22.3-8e30acd558-22960017e8.zip | Bin 3416 -> 0 bytes
...gsnag-node-npm-7.22.3-a6d1183220-ae68a37f2a.zip | Bin 62130 -> 0 bytes
...y-deepmerge-npm-1.3.0-72eb1f634c-6ddfc230ed.zip | Bin 6324 -> 0 bytes
...ypes-node-npm-20.11.0-cb757f0c2a-8da60a8ccb.zip | Bin 784585 -> 0 bytes
...ackage-data-npm-2.4.1-c31c56ae6a-e87bccbf11.zip | Bin 3401 -> 0 bytes
...nsi-escapes-npm-6.2.0-acda9c0a5d-442f91b046.zip | Bin 7522 -> 0 bytes
.../chokidar-npm-3.5.3-c5f9b0a56a-863e3ff78e.zip | Bin 31255 -> 0 bytes
.../citty-npm-0.1.5-35fec712f4-ae577a1ff4.zip | Bin 14570 -> 0 bytes
...cron-parser-npm-4.8.1-53e673fffa-5deb3f8216.zip | Bin 36352 -> 0 bytes
.../debug-npm-4.3.4-4513954577-0073c3bcbd.zip | Bin 15798 -> 0 bytes
.../destr-npm-2.0.2-1e34356a60-ed8c963cd6.zip | Bin 6572 -> 0 bytes
.../dotenv-npm-16.3.1-e6d380a398-dbb778237e.zip| Bin 26540 -> 0 bytes
...-stringify-npm-5.10.0-894a5b8403-897563f4af.zip | Bin 87201 -> 0 bytes
.../fastq-npm-1.16.0-88070bb399-de151543aa.zip | Bin 12457 -> 0 bytes
...nction-bind-npm-1.1.1-b56b322ae9-d83f296803.zip | Bin 8530 -> 0 bytes
.../glob-npm-10.3.10-da1ef8b112-38bdb2c9ce.zip | Bin 132456 -> 0 bytes
.../cache/h3-npm-1.10.0-bbe345e147-33c84658ad.zip | Bin 63017 -> 0 bytes
...proxy-agent-npm-7.0.2-83ea6a5d42-9ec844f78f.zip | Bin 12064 -> 0 bytes
...core-module-npm-2.8.1-ce21740d1b-80b33fbd45.zip | Bin 9931 -> 0 bytes
.../is-stream-npm-2.0.0-1401f82ad7-4dc47738e2.zip | Bin 3065 -> 0 bytes
.../jackspeak-npm-2.3.6-42e1233172-6e6490d676.zip | Bin 65779 -> 0 bytes
.../lru-cache-npm-10.1.0-f3d3a0f0ab-207278d6fa.zip | Bin 106997 -> 0 bytes
.../minimatch-npm-9.0.3-69d7d6fad5-c81b47d281.zip | Bin 127294 -> 0 bytes
.../minipass-npm-7.0.4-eacb4e042e-e864bd02ce.zip | Bin 73520 -> 0 bytes
...etch-native-npm-1.6.1-3d17da8352-83fbe9abea.zip | Bin 221780 -> 0 bytes
.../path-parse-npm-1.0.6-4a4c90546c-962a85dd38.zip | Bin 4251 -> 0 bytes
...ath-scurry-npm-1.10.1-52bd946f2e-eebfb8304f.zip | Bin 109900 -> 0 bytes
...t-transport-npm-1.1.0-178ca571bf-39b4496c9e.zip | Bin 9799 -> 0 bytes
.../resolve-npm-1.20.0-1bc5878aa9-5a2cc3254c.zip | Bin 52643 -> 0 bytes
.../cache/resolve-patch-63f1eb0464-197ca6b762.zip | Bin 53894 -> 0 bytes
.../cache/rfdc-npm-1.3.0-272f288ad8-76dedd9700.zip | Bin 7596 -> 0 bytes
.../semver-npm-7.5.4-c4ad957fcd-985dec0d37.zip | Bin 39956 -> 0 bytes
.../type-fest-npm-3.13.1-4bd562882d-9a8a2359ad.zip | Bin 119968 -> 0 bytes
.../cache/ufo-npm-1.3.2-dcaf8105d0-7133290d49.zip | Bin 19784 -> 0 bytes
.../node_modules/unix-dgram/build/Makefile | 2 +-
.../Release/obj.target/unix_dgram/src/unix_dgram.o | Bin 180208 -> 180208 bytes
yarn.lock | 467 ++-
45 files changed, 170 insertions(+), 931 deletions(-)
diff --git a/.pnp.cjs b/.pnp.cjs
index 4f0f4323..73a9874d 100644
--- a/.pnp.cjs
+++ b/.pnp.cjs
@@ -485,15 +485,6 @@ const RAW_RUNTIME_STATE =
}]\
]],\
["@babel/code-frame", [\
- ["npm:7.23.5", {\
-"packageLocation":
"./.yarn/cache/@babel-code-frame-npm-7.23.5-cb10d08de6-44e58529c9.zip/node_modules/@babel/code-frame/",\
-"packageDependencies": [\
- ["@babel/code-frame", "npm:7.23.5"],\
- ["@babel/highlight", "npm:7.23.4"],\
- ["chalk", "npm:2.4.2"]\
-],\
-"linkType": "HARD"\
- }],\
["npm:7.24.7", {\
"packageLocation":
"./.yarn/cache/@babel-code-frame-npm-7.24.7-315a600a58-4812e94885.zip/node_modules/@babel/code-frame/",\
"packageDependencies": [\
@@ -505,13 +496,6 @@ const RAW_RUNTIME_STATE =
}]\
]],\
["@babel/helper-string-parser", [\
- ["npm:7.23.4", {\
-"packageLocation":
"./.yarn/cache/@babel-helper-string-parser-npm-7.23.4-b1f0d030c3-c352082474.zip/node_modules/@babel/helper-string-parser/",\
-"packageDependencies":
Re: [PR] chore(deps-dev): Bump gulp from 4.0.2 to 5.0.0 in /docs [camel]
zregvart commented on PR #14514: URL: https://github.com/apache/camel/pull/14514#issuecomment-2168250630 Not sure if this is related to the Gulp upgrade: ``` [INFO] [13:45:07] 'symlink:asciidoc:languages' errored after 70 ms [INFO] [13:45:07] Error: ENOENT: no such file or directory, scandir '/home/runner/work/camel/camel/core/camel-xml-jaxp/src/main/docs/modules/languages/pages' ``` -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
Re: [PR] Upgrade netlify to have fix to have preview back [camel-website]
zregvart merged PR #1194: URL: https://github.com/apache/camel-website/pull/1194 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
(camel) branch dependabot/npm_and_yarn/docs/gulp-5.0.0 updated (63485a75239 -> ceea3f2c121)
This is an automated email from the ASF dual-hosted git repository. github-bot pushed a change to branch dependabot/npm_and_yarn/docs/gulp-5.0.0 in repository https://gitbox.apache.org/repos/asf/camel.git omit 63485a75239 chore(deps-dev): Bump gulp from 4.0.2 to 5.0.0 in /docs add a90996f452f Upgrade camel-pubnub to v9 client (#14515) add da694a7a0fd CAMEL-20788: Update camel to use a newer protobuf-maven-plugin for gR… (#14516) add a590bb55e10 CAMEL-20830: Upgrade jetty. Remove ServletRequest/ServletResponse object in Camel headers as they should only be accessible via the HttpMessage class. (#14518) add 5a13a089dd2 chore(deps): Bump com.googlecode.libphonenumber:libphonenumber add d23f7bab7f7 chore(deps): Bump com.slack.api:slack-api-client from 1.39.3 to 1.40.0 add 37b34865208 chore(deps): Bump io.camunda:zeebe-client-java from 8.5.2 to 8.5.3 add 535eedfea45 chore(deps-dev): Bump jakarta.servlet:jakarta.servlet-api add 4b0af1aee1e chore(deps): Bump spring-ldap-version from 3.2.3 to 3.2.4 add 754dd83024a chore(deps): Bump org.apache.jackrabbit:jackrabbit-core add f13cc051e1e chore(deps): Bump com.apptasticsoftware:rssreader from 3.6.0 to 3.7.0 add 9c8b65d0889 CAMEL-20215 - reactivate MllpTcpServerConsumerOptionalEndOfDataWithValidationTest add 73d1a66f209 Update MongoDB container used for IT tests to 7.0.11 add 309de7ee038 CAMEL-20798: EndpointServiceLocation on components to make it possible to know which remote system Camel connects to to assist for monitoring and observability - AWS EC2 (#14528) add fe43c9eeedf CAMEL-20798: EndpointServiceLocation on components to make it possible to know which remote system Camel connects to to assist for monitoring and observability - AWS ECS (#14529) add 2bfc3eec342 CAMEL-19523 - remove Thread.sleep in iec60870 test add fac987b287c CAMEL-19546 - remove Thread.sleep in Tarfile component test add f737805b933 chore: remove usage of deprecated methods in tarfile component add 71722a5af97 CAMEL-19544 - remove Thread.sleep in sql component test add 77b58e811ea CAMEL-20800: Use cloudant instead of LightCouch add ceea3f2c121 chore(deps-dev): Bump gulp from 4.0.2 to 5.0.0 in /docs 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 (63485a75239) \ N -- N -- N refs/heads/dependabot/npm_and_yarn/docs/gulp-5.0.0 (ceea3f2c121) 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. No new revisions were added by this update. Summary of changes: .../apache/camel/catalog/components/couchdb.json | 17 +-- .../apache/camel/catalog/components/pubnub.json| 4 +- .../camel/component/aws2/ec2/AWS2EC2Endpoint.java | 20 ++- .../camel/component/aws2/ecs/ECS2Endpoint.java | 20 ++- components/camel-couchdb/pom.xml | 13 +- .../couchdb/CouchDbEndpointConfigurer.java | 6 + .../couchdb/CouchDbEndpointUriFactory.java | 3 +- .../apache/camel/component/couchdb/couchdb.json| 17 +-- .../component/couchdb/CouchDbChangesetTracker.java | 144 - .../component/couchdb/CouchDbClientWrapper.java| 118 +++-- .../camel/component/couchdb/CouchDbConsumer.java | 78 +++ .../camel/component/couchdb/CouchDbEndpoint.java | 41 -- .../camel/component/couchdb/CouchDbProducer.java | 55 +--- .../couchdb/CouchDbChangesetTrackerTest.java | 122 - .../component/couchdb/CouchDbProducerTest.java | 54 +--- .../couchdb/integration/CouchDbCrudIT.java | 12 +- .../cxf/jaxrs/CxfRsSpringConsumerTest.java | 1 - .../message/DefaultCxfMessageMapperTest.java | 7 +- components/camel-cxf/camel-cxf-transport/pom.xml | 9 +- .../transport/message/DefaultCxfMessageMapper.java | 14 +- .../message/DefaultCxfMessageMapperTest.java | 7 +- components/camel-grpc/pom.xml | 42 -- .../apache/camel/http/common/HttpConverter.java| 12 +- .../org/apache/camel/http/common/HttpMessage.java | 3 - .../camel/component/iec60870/ConnectionTest.java | 3 - .../component/jetty/JettyConverterLoader.java | 5 - .../camel/component/jetty/JettyConverter.java | 9 +- .../camel/component/jetty/HttpConverterTest.java | 33 + .../component/jetty/HttpGZipEncodingTest.java | 4 +- .../camel/component/jetty/HttpHeaderTest.java | 4 +-
Re: [PR] chore(deps-dev): Bump gulp from 4.0.2 to 5.0.0 in /docs [camel]
zregvart commented on PR #14514: URL: https://github.com/apache/camel/pull/14514#issuecomment-2168251098 @dependabot rebase -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
Re: [I] Website preview action is broken [camel-website]
zregvart closed issue #1170: Website preview action is broken URL: https://github.com/apache/camel-website/issues/1170 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
Re: [I] How to set the "camel.sink.endpoint.sslContextParameters" in the CamelHttpsSinkConnector.properties [camel-kafka-connector]
KevinMengSF commented on issue #1610: URL: https://github.com/apache/camel-kafka-connector/issues/1610#issuecomment-2168223537 > It doesn't expose those parameters. We need a specialized kamelet for that purpose and we need to support camel 4.4.x Hi @oscerd and @valdar, Just checked the version 4.4.2 already released, could help confirm that "sslContextParameters" and "oauth2 related parameters" whether exposed or not? Thanks a lot. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
Re: [PR] Fix numeric field bug: Backspace not removing last value [camel-karavan]
mgubaidullin commented on PR #1314: URL: https://github.com/apache/camel-karavan/pull/1314#issuecomment-2168175582 I have jus copy-pasted code from Component to Kamelets and DSL to support placeholders https://github.com/apache/camel-karavan/commit/25449b1fc4577e012882a176d44f638089456e85 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
(camel-karavan) branch main updated: Fix #1319
This is an automated email from the ASF dual-hosted git repository.
marat pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-karavan.git
The following commit(s) were added to refs/heads/main by this push:
new 25449b1f Fix #1319
25449b1f is described below
commit 25449b1fc4577e012882a176d44f638089456e85
Author: Marat Gubaidullin
AuthorDate: Fri Jun 14 10:31:20 2024 -0400
Fix #1319
---
.../property/property/DslPropertyField.tsx | 69 +++--
.../property/property/KameletPropertyField.tsx | 99 +--
.../property/PropertyPlaceholderDropdown.tsx | 9 +-
karavan-designer/public/example/demo.camel.yaml| 109 -
.../property/property/DslPropertyField.tsx | 69 +++--
.../property/property/KameletPropertyField.tsx | 99 +--
.../property/PropertyPlaceholderDropdown.tsx | 9 +-
.../property/property/DslPropertyField.tsx | 69 +++--
.../property/property/KameletPropertyField.tsx | 99 +--
.../property/PropertyPlaceholderDropdown.tsx | 9 +-
10 files changed, 362 insertions(+), 278 deletions(-)
diff --git
a/karavan-app/src/main/webui/src/designer/property/property/DslPropertyField.tsx
b/karavan-app/src/main/webui/src/designer/property/property/DslPropertyField.tsx
index 67de1077..f669aa84 100644
---
a/karavan-app/src/main/webui/src/designer/property/property/DslPropertyField.tsx
+++
b/karavan-app/src/main/webui/src/designer/property/property/DslPropertyField.tsx
@@ -275,7 +275,7 @@ export function DslPropertyField(props: Props) {
return
- {
if (selected) {
@@ -287,7 +287,7 @@ export function DslPropertyField(props: Props) {
}
}}
/>
- {
@@ -331,8 +331,47 @@ export function DslPropertyField(props: Props) {
}
-function isNumeric (num: any) {
-return (typeof(num) === 'number' || typeof(num) === "string" &&
num.trim() !== '') && !isNaN(num as number);
+function isNumeric(num: any) {
+return (typeof (num) === 'number' || typeof (num) === "string" &&
num.trim() !== '') && !isNaN(num as number);
+}
+
+function getSpecialStringInput(property: PropertyMeta) {
+return (
+
+
+{property.type} : undefined}
+onBlur={_ => {
+if (isNumeric((textValue))) {
+propertyChanged(property.name,
Number(textValue))
+} else {
+propertyChanged(property.name, textValue)
+}
+}}
+onFocus={_ => setCheckChanges(true)}
+onChange={(_, v) => {
+setTextValue(v);
+setCheckChanges(true);
+}}
+/>
+
+
+ {
+setTextValue(v);
+propertyChanged(property.name, v)
+setCheckChanges(true);
+}}/>
+
+
+)
}
function getStringInput(property: PropertyMeta) {
@@ -365,13 +404,11 @@ export function DslPropertyField(props: Props) {
if (isNumber && isNumeric((textValue))) {
propertyChanged(property.name,
Number(textValue))
} else if (!isNumber) {
- console.log("onBlur", property.name,
textValue)
propertyChanged(property.name, textValue)
}
}}
onFocus={_ => setCheckChanges(true)}
onChange={(_, v) => {
-
if (isNumber && isNumeric(v)) {
setTextValue(v);
setCheckChanges(true);
@@ -403,6 +440,15 @@ export function DslPropertyField(props: Props) {
setShowEditor(false);
}}/>
}
+
+ {
+setTextValue(v);
+propertyChanged(property.name, v)
+setCheckChanges(true);
+}}/>
+
}
@@ -985,7 +1031,16 @@ export function DslPropertyField(props: Props) {
&& getMediaTypeSelect(property, value)}
{javaTypeGenerated(property)
&&
Re: [I] Karavan should support placeholders in DSL and Kamelet properties [camel-karavan]
mgubaidullin closed issue #1319: Karavan should support placeholders in DSL and Kamelet properties URL: https://github.com/apache/camel-karavan/issues/1319 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[PR] Add camel-saxon integration test [camel-karaf]
f2par0 opened a new pull request, #353: URL: https://github.com/apache/camel-karaf/pull/353 fixes #352 camel-saxon integration test -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[PR] - Fixes #6190 [camel-quarkus]
radcortez opened a new pull request, #6191: URL: https://github.com/apache/camel-quarkus/pull/6191 (no comment) -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[I] Jasypt SecretKeyHandler config cannot use configuration coming from Configurable Config sources [camel-quarkus]
radcortez opened a new issue, #6190: URL: https://github.com/apache/camel-quarkus/issues/6190 ### Bug description From https://github.com/quarkusio/quarkus/issues/40767 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
Re: [PR] CAMEL-19659 - reactivate FHIR Integration tests [camel]
github-actions[bot] commented on PR #14536: URL: https://github.com/apache/camel/pull/14536#issuecomment-2168108446 :star2: Thank you for your contribution to the Apache Camel project! :star2: :robot: CI automation will test this PR automatically. :camel: Apache Camel Committers, please review the following items: * First-time contributors **require MANUAL approval** for the GitHub Actions to run * You can use the command `/component-test (camel-)component-name1 (camel-)component-name2..` to request a test from the test bot. * You can label PRs using `build-all`, `build-dependents`, `skip-tests` and `test-dependents` to fine-tune the checks executed by this PR. * Build and test logs are available in the Summary page. **Only** [Apache Camel committers](https://camel.apache.org/community/team/#committers) have access to the summary. * :warning: Be careful when sharing logs. Review their contents before sharing them publicly. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[PR] CAMEL-19659 - reactivate FHIR Integration tests [camel]
apupier opened a new pull request, #14536: URL: https://github.com/apache/camel/pull/14536 - upgrade container version, locally gained 20 seconds on 2 minutes test execution - provide a retry startup attempt to improve stability # Description # Target - [ ] I checked that the commit is targeting the correct branch (note that Camel 3 uses `camel-3.x`, whereas Camel 4 uses the `main` branch) # Tracking - [ ] If this is a large change, bug fix, or code improvement, I checked there is a [JIRA issue](https://issues.apache.org/jira/browse/CAMEL) filed for the change (usually before you start working on it). # Apache Camel coding standards and style - [ ] I checked that each commit in the pull request has a meaningful subject line and body. - [ ] I have run `mvn clean install -DskipTests` locally and I have committed all auto-generated changes -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
(camel-spring-boot) branch main updated: Regen
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-spring-boot.git
The following commit(s) were added to refs/heads/main by this push:
new bd8a1874b07 Regen
bd8a1874b07 is described below
commit bd8a1874b072472a0025d2d6d5c6bcc28ace78b2
Author: Claus Ibsen
AuthorDate: Fri Jun 14 15:44:28 2024 +0200
Regen
---
.../camel/springboot/catalog/components/couchdb.json| 17 +
components-starter/camel-couchdb-starter/pom.xml| 8
2 files changed, 9 insertions(+), 16 deletions(-)
diff --git
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/couchdb.json
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/couchdb.json
index d2941900196..831b3e4411d 100644
---
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/couchdb.json
+++
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/couchdb.json
@@ -43,13 +43,14 @@
"createDatabase": { "index": 4, "kind": "parameter", "displayName":
"Create Database", "group": "common", "label": "", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "description": "Creates the database if
it does not already exist" },
"deletes": { "index": 5, "kind": "parameter", "displayName": "Deletes",
"group": "consumer", "label": "consumer", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "autowired": false, "secret":
false, "defaultValue": true, "description": "Document deletes are published as
events" },
"heartbeat": { "index": 6, "kind": "parameter", "displayName":
"Heartbeat", "group": "consumer", "label": "consumer", "required": false,
"type": "duration", "javaType": "long", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "3", "description": "How often to
send an empty message to keep socket alive in millis" },
-"style": { "index": 7, "kind": "parameter", "displayName": "Style",
"group": "consumer", "label": "consumer", "required": false, "type": "string",
"javaType": "java.lang.String", "enum": [ "all_docs", "main_only" ],
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
"main_only", "description": "Specifies how many revisions are returned in the
changes array. The default, main_only, will only return the current winning
revision; all_docs will return all leaf revi [...]
-"updates": { "index": 8, "kind": "parameter", "displayName": "Updates",
"group": "consumer", "label": "consumer", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "autowired": false, "secret":
false, "defaultValue": true, "description": "Document inserts\/updates are
published as events" },
-"bridgeErrorHandler": { "index": 9, "kind": "parameter", "displayName":
"Bridge Error Handler", "group": "consumer (advanced)", "label":
"consumer,advanced", "required": false, "type": "boolean", "javaType":
"boolean", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": false, "description": "Allows for bridging the consumer to the
Camel routing Error Handler, which mean any exceptions (if possible) occurred
while the Camel consumer is trying to pickup incoming [...]
-"exceptionHandler": { "index": 10, "kind": "parameter", "displayName":
"Exception Handler", "group": "consumer (advanced)", "label":
"consumer,advanced", "required": false, "type": "object", "javaType":
"org.apache.camel.spi.ExceptionHandler", "optionalPrefix": "consumer.",
"deprecated": false, "autowired": false, "secret": false, "description": "To
let the consumer use a custom ExceptionHandler. Notice if the option
bridgeErrorHandler is enabled then this option is not in use. By de [...]
-"exchangePattern": { "index": 11, "kind": "parameter", "displayName":
"Exchange Pattern", "group": "consumer (advanced)", "label":
"consumer,advanced", "required": false, "type": "object", "javaType":
"org.apache.camel.ExchangePattern", "enum": [ "InOnly", "InOut" ],
"deprecated": false, "autowired": false, "secret": false, "description": "Sets
the exchange pattern when the consumer creates an exchange." },
-"lazyStartProducer": { "index": 12, "kind": "parameter", "displayName":
"Lazy Start Producer", "group": "producer (advanced)", "label":
"producer,advanced", "required": false, "type": "boolean", "javaType":
"boolean", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": false, "description": "Whether the producer should be started
lazy (on the first message). By starting lazy you can use this to allow
CamelContext and routes to startup in situations
(camel) branch main updated: CAMEL-20800: Use cloudant instead of LightCouch
This is an automated email from the ASF dual-hosted git repository.
fmariani pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/main by this push:
new 77b58e811ea CAMEL-20800: Use cloudant instead of LightCouch
77b58e811ea is described below
commit 77b58e811eadca9da3a08ab1eaf109041af3a06b
Author: Croway
AuthorDate: Fri Jun 14 11:59:22 2024 +0200
CAMEL-20800: Use cloudant instead of LightCouch
---
.../apache/camel/catalog/components/couchdb.json | 17 +--
components/camel-couchdb/pom.xml | 13 +-
.../couchdb/CouchDbEndpointConfigurer.java | 6 +
.../couchdb/CouchDbEndpointUriFactory.java | 3 +-
.../apache/camel/component/couchdb/couchdb.json| 17 +--
.../component/couchdb/CouchDbChangesetTracker.java | 144 -
.../component/couchdb/CouchDbClientWrapper.java| 118 +++--
.../camel/component/couchdb/CouchDbConsumer.java | 78 +++
.../camel/component/couchdb/CouchDbEndpoint.java | 41 --
.../camel/component/couchdb/CouchDbProducer.java | 55 +---
.../couchdb/CouchDbChangesetTrackerTest.java | 122 -
.../component/couchdb/CouchDbProducerTest.java | 54 +---
.../couchdb/integration/CouchDbCrudIT.java | 12 +-
.../dsl/CouchDbEndpointBuilderFactory.java | 36 ++
.../camel/kotlin/components/CouchdbUriDsl.kt | 18 +++
15 files changed, 324 insertions(+), 410 deletions(-)
diff --git
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/couchdb.json
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/couchdb.json
index cc5807374a3..c7a44cc4fa1 100644
---
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/couchdb.json
+++
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/couchdb.json
@@ -43,13 +43,14 @@
"createDatabase": { "index": 4, "kind": "parameter", "displayName":
"Create Database", "group": "common", "label": "", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "description": "Creates the database if
it does not already exist" },
"deletes": { "index": 5, "kind": "parameter", "displayName": "Deletes",
"group": "consumer", "label": "consumer", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "autowired": false, "secret":
false, "defaultValue": true, "description": "Document deletes are published as
events" },
"heartbeat": { "index": 6, "kind": "parameter", "displayName":
"Heartbeat", "group": "consumer", "label": "consumer", "required": false,
"type": "duration", "javaType": "long", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "3", "description": "How often to
send an empty message to keep socket alive in millis" },
-"style": { "index": 7, "kind": "parameter", "displayName": "Style",
"group": "consumer", "label": "consumer", "required": false, "type": "string",
"javaType": "java.lang.String", "enum": [ "all_docs", "main_only" ],
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
"main_only", "description": "Specifies how many revisions are returned in the
changes array. The default, main_only, will only return the current winning
revision; all_docs will return all leaf revi [...]
-"updates": { "index": 8, "kind": "parameter", "displayName": "Updates",
"group": "consumer", "label": "consumer", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "autowired": false, "secret":
false, "defaultValue": true, "description": "Document inserts\/updates are
published as events" },
-"bridgeErrorHandler": { "index": 9, "kind": "parameter", "displayName":
"Bridge Error Handler", "group": "consumer (advanced)", "label":
"consumer,advanced", "required": false, "type": "boolean", "javaType":
"boolean", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": false, "description": "Allows for bridging the consumer to the
Camel routing Error Handler, which mean any exceptions (if possible) occurred
while the Camel consumer is trying to pickup incoming [...]
-"exceptionHandler": { "index": 10, "kind": "parameter", "displayName":
"Exception Handler", "group": "consumer (advanced)", "label":
"consumer,advanced", "required": false, "type": "object", "javaType":
"org.apache.camel.spi.ExceptionHandler", "optionalPrefix": "consumer.",
"deprecated": false, "autowired": false, "secret": false, "description": "To
let the consumer use a custom ExceptionHandler. Notice if the option
bridgeErrorHandler is enabled then this option is not in use. By de [...]
-"exchangePattern": { "index": 11, "kind": "parameter", "displayName":
"Exchange Pattern",
Re: [PR] CAMEL-20800: Use cloudant instead of LightCouch [camel]
Croway merged PR #14531: URL: https://github.com/apache/camel/pull/14531 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
(camel-karaf) branch release/3.21.5 updated: [maven-release-plugin] prepare for next development iteration
This is an automated email from the ASF dual-hosted git repository. gzurowski pushed a commit to branch release/3.21.5 in repository https://gitbox.apache.org/repos/asf/camel-karaf.git The following commit(s) were added to refs/heads/release/3.21.5 by this push: new b94691ed [maven-release-plugin] prepare for next development iteration b94691ed is described below commit b94691ed5d7dcb42f02a4d75c525c3593b0b86c3 Author: Gregor Zurowski AuthorDate: Fri Jun 14 13:14:04 2024 + [maven-release-plugin] prepare for next development iteration --- archetypes/camel-archetype-blueprint/pom.xml | 2 +- archetypes/pom.xml | 2 +- bom/camel-karaf-bom/pom.xml| 2 +- bom/pom.xml| 2 +- catalog/camel-catalog-provider-karaf/pom.xml | 2 +- catalog/pom.xml| 2 +- components/camel-bean-validator-osgi/pom.xml | 2 +- components/camel-blueprint-main/pom.xml| 2 +- components/camel-blueprint/pom.xml | 2 +- components/camel-cxf-blueprint/pom.xml | 2 +- components/camel-cxf-transport-blueprint/pom.xml | 2 +- components/camel-eventadmin/pom.xml| 2 +- components/camel-jcache-osgi/pom.xml | 2 +- components/camel-kura/pom.xml | 2 +- components/camel-paxlogging/pom.xml| 2 +- components/camel-servlet-osgi/pom.xml | 2 +- components/camel-test-blueprint-junit5/pom.xml | 2 +- components/camel-test-blueprint/pom.xml| 2 +- components/camel-test-karaf/pom.xml| 2 +- components/camel-zookeeper-master-osgi/pom.xml | 2 +- components/pom.xml | 2 +- core/camel-core-osgi/pom.xml | 2 +- core/pom.xml | 2 +- platforms/commands/commands-core/pom.xml | 2 +- platforms/commands/pom.xml | 2 +- platforms/karaf/commands/pom.xml | 2 +- platforms/karaf/features/pom.xml | 2 +- platforms/karaf/pom.xml| 2 +- platforms/pom.xml | 2 +- pom.xml| 4 ++-- tests/camel-blueprint-cxf-test/pom.xml | 2 +- tests/camel-blueprint-test/pom.xml | 2 +- tests/camel-itest-osgi/pom.xml | 2 +- tests/pom.xml | 2 +- tooling/camel-catalog-generator-karaf-maven-plugin/pom.xml | 2 +- tooling/camel-karaf-maven-plugin/pom.xml | 2 +- tooling/pom.xml| 2 +- 37 files changed, 38 insertions(+), 38 deletions(-) diff --git a/archetypes/camel-archetype-blueprint/pom.xml b/archetypes/camel-archetype-blueprint/pom.xml index 3d750bc7..7bb3ecf3 100644 --- a/archetypes/camel-archetype-blueprint/pom.xml +++ b/archetypes/camel-archetype-blueprint/pom.xml @@ -24,7 +24,7 @@ org.apache.camel.karaf archetypes -3.21.5 +3.21.6-SNAPSHOT org.apache.camel.archetypes diff --git a/archetypes/pom.xml b/archetypes/pom.xml index b5ad8920..76e97e3c 100644 --- a/archetypes/pom.xml +++ b/archetypes/pom.xml @@ -24,7 +24,7 @@ org.apache.camel.karaf karaf -3.21.5 +3.21.6-SNAPSHOT .. diff --git a/bom/camel-karaf-bom/pom.xml b/bom/camel-karaf-bom/pom.xml index 556132c3..4c9c06d3 100644 --- a/bom/camel-karaf-bom/pom.xml +++ b/bom/camel-karaf-bom/pom.xml @@ -22,7 +22,7 @@ org.apache.camel.karaf karaf -3.21.5 +3.21.6-SNAPSHOT ../../ camel-karaf-bom diff --git a/bom/pom.xml b/bom/pom.xml index c201df3b..6aca27fd 100644 --- a/bom/pom.xml +++ b/bom/pom.xml @@ -23,7 +23,7 @@ org.apache.camel.karaf karaf -3.21.5 +3.21.6-SNAPSHOT .. diff --git a/catalog/camel-catalog-provider-karaf/pom.xml b/catalog/camel-catalog-provider-karaf/pom.xml index 29758c8f..62a270cd 100644 --- a/catalog/camel-catalog-provider-karaf/pom.xml +++ b/catalog/camel-catalog-provider-karaf/pom.xml @@ -23,7 +23,7 @@ org.apache.camel.karaf catalog -3.21.5 +3.21.6-SNAPSHOT camel-catalog-provider-karaf diff --git a/catalog/pom.xml b/catalog/pom.xml index 6919011a..9ec93bbf 100644 --- a/catalog/pom.xml +++ b/catalog/pom.xml @@ -24,7 +24,7 @@ org.apache.camel.karaf karaf -3.21.5 +3.21.6-SNAPSHOT .. diff --git
(camel-karaf) annotated tag camel-karaf-3.21.5 created (now 090692c9)
This is an automated email from the ASF dual-hosted git repository. gzurowski pushed a change to annotated tag camel-karaf-3.21.5 in repository https://gitbox.apache.org/repos/asf/camel-karaf.git at 090692c9 (tag) tagging 68e4d7835bb89929f2b3faef3b4fc829f00cc2b5 (commit) replaces camel-karaf-3.21.4 by Gregor Zurowski on Fri Jun 14 13:14:00 2024 + - Log - [maven-release-plugin] copy for tag camel-karaf-3.21.5 --- No new revisions were added by this update.
(camel-karaf) 02/02: [maven-release-plugin] prepare release camel-karaf-3.21.5
This is an automated email from the ASF dual-hosted git repository. gzurowski pushed a commit to branch release/3.21.5 in repository https://gitbox.apache.org/repos/asf/camel-karaf.git commit 68e4d7835bb89929f2b3faef3b4fc829f00cc2b5 Author: Gregor Zurowski AuthorDate: Fri Jun 14 13:13:56 2024 + [maven-release-plugin] prepare release camel-karaf-3.21.5 --- archetypes/camel-archetype-blueprint/pom.xml | 2 +- archetypes/pom.xml | 2 +- bom/camel-karaf-bom/pom.xml| 2 +- bom/pom.xml| 2 +- catalog/camel-catalog-provider-karaf/pom.xml | 2 +- catalog/pom.xml| 2 +- components/camel-bean-validator-osgi/pom.xml | 2 +- components/camel-blueprint-main/pom.xml| 2 +- components/camel-blueprint/pom.xml | 2 +- components/camel-cxf-blueprint/pom.xml | 2 +- components/camel-cxf-transport-blueprint/pom.xml | 2 +- components/camel-eventadmin/pom.xml| 2 +- components/camel-jcache-osgi/pom.xml | 2 +- components/camel-kura/pom.xml | 2 +- components/camel-paxlogging/pom.xml| 2 +- components/camel-servlet-osgi/pom.xml | 2 +- components/camel-test-blueprint-junit5/pom.xml | 2 +- components/camel-test-blueprint/pom.xml| 2 +- components/camel-test-karaf/pom.xml| 2 +- components/camel-zookeeper-master-osgi/pom.xml | 2 +- components/pom.xml | 2 +- core/camel-core-osgi/pom.xml | 2 +- core/pom.xml | 2 +- platforms/commands/commands-core/pom.xml | 2 +- platforms/commands/pom.xml | 2 +- platforms/karaf/commands/pom.xml | 2 +- platforms/karaf/features/pom.xml | 2 +- platforms/karaf/pom.xml| 2 +- platforms/pom.xml | 2 +- pom.xml| 4 ++-- tests/camel-blueprint-cxf-test/pom.xml | 2 +- tests/camel-blueprint-test/pom.xml | 2 +- tests/camel-itest-osgi/pom.xml | 2 +- tests/pom.xml | 2 +- tooling/camel-catalog-generator-karaf-maven-plugin/pom.xml | 2 +- tooling/camel-karaf-maven-plugin/pom.xml | 2 +- tooling/pom.xml| 2 +- 37 files changed, 38 insertions(+), 38 deletions(-) diff --git a/archetypes/camel-archetype-blueprint/pom.xml b/archetypes/camel-archetype-blueprint/pom.xml index 0244dab9..3d750bc7 100644 --- a/archetypes/camel-archetype-blueprint/pom.xml +++ b/archetypes/camel-archetype-blueprint/pom.xml @@ -24,7 +24,7 @@ org.apache.camel.karaf archetypes -3.21.5-SNAPSHOT +3.21.5 org.apache.camel.archetypes diff --git a/archetypes/pom.xml b/archetypes/pom.xml index b2af381b..b5ad8920 100644 --- a/archetypes/pom.xml +++ b/archetypes/pom.xml @@ -24,7 +24,7 @@ org.apache.camel.karaf karaf -3.21.5-SNAPSHOT +3.21.5 .. diff --git a/bom/camel-karaf-bom/pom.xml b/bom/camel-karaf-bom/pom.xml index 9563bdf0..556132c3 100644 --- a/bom/camel-karaf-bom/pom.xml +++ b/bom/camel-karaf-bom/pom.xml @@ -22,7 +22,7 @@ org.apache.camel.karaf karaf -3.21.5-SNAPSHOT +3.21.5 ../../ camel-karaf-bom diff --git a/bom/pom.xml b/bom/pom.xml index 4b3d7829..c201df3b 100644 --- a/bom/pom.xml +++ b/bom/pom.xml @@ -23,7 +23,7 @@ org.apache.camel.karaf karaf -3.21.5-SNAPSHOT +3.21.5 .. diff --git a/catalog/camel-catalog-provider-karaf/pom.xml b/catalog/camel-catalog-provider-karaf/pom.xml index 617393dc..29758c8f 100644 --- a/catalog/camel-catalog-provider-karaf/pom.xml +++ b/catalog/camel-catalog-provider-karaf/pom.xml @@ -23,7 +23,7 @@ org.apache.camel.karaf catalog -3.21.5-SNAPSHOT +3.21.5 camel-catalog-provider-karaf diff --git a/catalog/pom.xml b/catalog/pom.xml index 0057ca49..6919011a 100644 --- a/catalog/pom.xml +++ b/catalog/pom.xml @@ -24,7 +24,7 @@ org.apache.camel.karaf karaf -3.21.5-SNAPSHOT +3.21.5 .. diff --git a/components/camel-bean-validator-osgi/pom.xml b/components/camel-bean-validator-osgi/pom.xml index 03e45772..ca8956f4 100644 --- a/components/camel-bean-validator-osgi/pom.xml +++
(camel-karaf) branch release/3.21.5 created (now 68e4d783)
This is an automated email from the ASF dual-hosted git repository. gzurowski pushed a change to branch release/3.21.5 in repository https://gitbox.apache.org/repos/asf/camel-karaf.git at 68e4d783 [maven-release-plugin] prepare release camel-karaf-3.21.5 This branch includes the following new commits: new 539fb2ab Target Camel 3.21.5 for release new 68e4d783 [maven-release-plugin] prepare release camel-karaf-3.21.5 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.
(camel-karaf) 01/02: Target Camel 3.21.5 for release
This is an automated email from the ASF dual-hosted git repository. gzurowski pushed a commit to branch release/3.21.5 in repository https://gitbox.apache.org/repos/asf/camel-karaf.git commit 539fb2ab964a85ef5ee802e752ca9e93f7ed161a Author: Gregor Zurowski AuthorDate: Fri Jun 14 13:09:06 2024 + Target Camel 3.21.5 for release --- pom.xml | 8 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/pom.xml b/pom.xml index 530145cc..5aa62e78 100644 --- a/pom.xml +++ b/pom.xml @@ -23,7 +23,7 @@ org.apache.camel camel-dependencies -3.21.5-SNAPSHOT +3.21.5 org.apache.camel.karaf @@ -108,7 +108,7 @@ 4.4.4 -3.21.5-SNAPSHOT +3.21.5 2.12.3 1.7.0_6 @@ -276,7 +276,7 @@ 0.17.0 31.1-jre 3.1.0 -3.21.5-SNAPSHOT +3.21.5 0.9.12_1 1.4_1 2.1.0 @@ -781,7 +781,7 @@ dev -3.21.5-SNAPSHOT +3.21.5
(camel-karaf) branch 350/replace-hard-coded-versions deleted (was 6aa47f2b)
This is an automated email from the ASF dual-hosted git repository. nfilotto pushed a change to branch 350/replace-hard-coded-versions in repository https://gitbox.apache.org/repos/asf/camel-karaf.git was 6aa47f2b Ref #350: Replace hard-coded versions with maven properties The revisions that were on this branch are still contained in other references; therefore, this change does not discard any commits from the repository.
Re: [I] Replace hard-coded versions with maven properties [camel-karaf]
essobedo closed issue #350: Replace hard-coded versions with maven properties URL: https://github.com/apache/camel-karaf/issues/350 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
Re: [PR] Ref #350: Replace hard-coded versions with maven properties [camel-karaf]
essobedo merged PR #351: URL: https://github.com/apache/camel-karaf/pull/351 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
Re: [PR] chore(deps): Bump mongo-java-driver-version from 4.11.1 to 5.1.1 [camel]
orpiske commented on PR #14499: URL: https://github.com/apache/camel/pull/14499#issuecomment-2167999718 > 烙 ❌ Test result with component components/camel-mongodb (failed) I may need to look closely at the log for this one. I can't do this today, but I'll do it on Monday. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
(camel) branch CAMEL-20798-AWS-2 updated (7187c6e8f0c -> 053399d15ba)
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a change to branch CAMEL-20798-AWS-2 in repository https://gitbox.apache.org/repos/asf/camel.git from 7187c6e8f0c CAMEL-20798: EndpointServiceLocation on components to make it possible to know which remote system Camel connects to to assist for monitoring and observability - AWS Eventbridge add 053399d15ba CAMEL-20798: EndpointServiceLocation on components to make it possible to know which remote system Camel connects to to assist for monitoring and observability No new revisions were added by this update. Summary of changes: .../apache/camel/component/aws2/eventbridge/EventbridgeEndpoint.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-)
Re: [PR] chore(deps): Bump mongo-java-driver-version from 4.11.1 to 5.1.1 [camel]
orpiske commented on PR #14499: URL: https://github.com/apache/camel/pull/14499#issuecomment-2167959490 Sure thing. I am currently on a conference, but I'll try to do as soon as I get a chance. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
Re: [I] Add TLS configuration in the ingress trait [camel-k]
squakez commented on issue #5635: URL: https://github.com/apache/camel-k/issues/5635#issuecomment-2167957877 > I've never done Go development, I may look at it this weekend or monday From what I saw, I mainly on > > * pkg/apis/camel/v1/trait/ingress.go > > * pkg/trait/ingress.go > > * pkg/trait/ingress_test.go Yeah, that's correct. This particular development should not require the knowledge of the entire operator. If the unit tests are passing, then, we should be fine. Have a look at https://camel.apache.org/camel-k/next/contributing/developers.html and feel free to ping either here on in Zulip chat to get any support. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
Re: [I] Add TLS configuration in the ingress trait [camel-k]
romain-pfund commented on issue #5635: URL: https://github.com/apache/camel-k/issues/5635#issuecomment-2167953597 I've never done Go development, I may look at it this weekend or monday From what I saw, I mainly on - pkg/apis/camel/v1/trait/ingress.go - pkg/trait/ingress.go - pkg/trait/ingress_test.go -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
Re: [PR] CAMEL-19544 - remove Thread.sleep in sql component test [camel]
apupier merged PR #14534: URL: https://github.com/apache/camel/pull/14534 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
(camel) branch main updated: chore: remove usage of deprecated methods in tarfile component
This is an automated email from the ASF dual-hosted git repository.
apupier pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/main by this push:
new f737805b933 chore: remove usage of deprecated methods in tarfile
component
f737805b933 is described below
commit f737805b933fbc1ed57e08356c29d1ffdc99e1ca
Author: Aurélien Pupier
AuthorDate: Fri Jun 14 13:34:56 2024 +0200
chore: remove usage of deprecated methods in tarfile component
Signed-off-by: Aurélien Pupier
---
.../java/org/apache/camel/dataformat/tarfile/TarFileDataFormat.java | 4 ++--
.../main/java/org/apache/camel/dataformat/tarfile/TarIterator.java | 2 +-
.../camel/processor/aggregate/tarfile/TarAggregationStrategy.java | 2 +-
.../org/apache/camel/dataformat/tarfile/TarFileDataFormatTest.java | 6 --
4 files changed, 4 insertions(+), 10 deletions(-)
diff --git
a/components/camel-tarfile/src/main/java/org/apache/camel/dataformat/tarfile/TarFileDataFormat.java
b/components/camel-tarfile/src/main/java/org/apache/camel/dataformat/tarfile/TarFileDataFormat.java
index 59a199a190c..397996c2951 100644
---
a/components/camel-tarfile/src/main/java/org/apache/camel/dataformat/tarfile/TarFileDataFormat.java
+++
b/components/camel-tarfile/src/main/java/org/apache/camel/dataformat/tarfile/TarFileDataFormat.java
@@ -110,7 +110,7 @@ public class TarFileDataFormat extends ServiceSupport
implements DataFormat, Dat
OutputStreamBuilder osb =
OutputStreamBuilder.withExchange(exchange);
try {
-TarArchiveEntry entry = tis.getNextTarEntry();
+TarArchiveEntry entry = tis.getNextEntry();
if (entry != null) {
exchange.getMessage().setHeader(FILE_NAME,
entry.getName());
IOHelper.copy(tis, osb, IOHelper.DEFAULT_BUFFER_SIZE,
false, maxDecompressedSize);
@@ -118,7 +118,7 @@ public class TarFileDataFormat extends ServiceSupport
implements DataFormat, Dat
throw new IllegalStateException("Unable to untar the file,
it may be corrupted.");
}
-entry = tis.getNextTarEntry();
+entry = tis.getNextEntry();
if (entry != null) {
throw new IllegalStateException("Tar file has more than 1
entry.");
}
diff --git
a/components/camel-tarfile/src/main/java/org/apache/camel/dataformat/tarfile/TarIterator.java
b/components/camel-tarfile/src/main/java/org/apache/camel/dataformat/tarfile/TarIterator.java
index 3015842c80f..032a3eacaca 100644
---
a/components/camel-tarfile/src/main/java/org/apache/camel/dataformat/tarfile/TarIterator.java
+++
b/components/camel-tarfile/src/main/java/org/apache/camel/dataformat/tarfile/TarIterator.java
@@ -157,7 +157,7 @@ public class TarIterator implements Iterator,
Closeable {
private TarArchiveEntry getNextEntry() throws IOException {
TarArchiveEntry entry;
-while ((entry = tarInputStream.getNextTarEntry()) != null) {
+while ((entry = tarInputStream.getNextEntry()) != null) {
if (!entry.isDirectory()) {
return entry;
} else {
diff --git
a/components/camel-tarfile/src/main/java/org/apache/camel/processor/aggregate/tarfile/TarAggregationStrategy.java
b/components/camel-tarfile/src/main/java/org/apache/camel/processor/aggregate/tarfile/TarAggregationStrategy.java
index 2b671b04b69..67ba2968dfb 100644
---
a/components/camel-tarfile/src/main/java/org/apache/camel/processor/aggregate/tarfile/TarAggregationStrategy.java
+++
b/components/camel-tarfile/src/main/java/org/apache/camel/processor/aggregate/tarfile/TarAggregationStrategy.java
@@ -40,7 +40,7 @@ import
org.apache.commons.compress.archivers.ArchiveStreamFactory;
import org.apache.commons.compress.archivers.tar.TarArchiveEntry;
import org.apache.commons.compress.archivers.tar.TarArchiveInputStream;
import org.apache.commons.compress.archivers.tar.TarArchiveOutputStream;
-import org.apache.commons.compress.utils.IOUtils;
+import org.apache.commons.io.IOUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
diff --git
a/components/camel-tarfile/src/test/java/org/apache/camel/dataformat/tarfile/TarFileDataFormatTest.java
b/components/camel-tarfile/src/test/java/org/apache/camel/dataformat/tarfile/TarFileDataFormatTest.java
index 958509a756b..50db4a01bf3 100644
---
a/components/camel-tarfile/src/test/java/org/apache/camel/dataformat/tarfile/TarFileDataFormatTest.java
+++
b/components/camel-tarfile/src/test/java/org/apache/camel/dataformat/tarfile/TarFileDataFormatTest.java
@@ -321,12 +321,6 @@ public class TarFileDataFormatTest extends
CamelTestSupport {
}
}
-private static void copy(File file, OutputStream out) throws IOException {
-try (InputStream in = new FileInputStream(file)) {
-copy(in,
Re: [PR] chore: remove usage of deprecated methods in tarfile component [camel]
apupier merged PR #14533: URL: https://github.com/apache/camel/pull/14533 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
(camel) branch main updated: CAMEL-19544 - remove Thread.sleep in sql component test
This is an automated email from the ASF dual-hosted git repository.
apupier pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/main by this push:
new 71722a5af97 CAMEL-19544 - remove Thread.sleep in sql component test
71722a5af97 is described below
commit 71722a5af97cde7cd4d0da88c8d8004f92dba0ff
Author: Aurélien Pupier
AuthorDate: Fri Jun 14 14:17:28 2024 +0200
CAMEL-19544 - remove Thread.sleep in sql component test
Gain 800ms locally but easier to read code
It remains several Thread.sleep but that are testing timeouts of the sql
component or trying to simulate a little delay so I guess we need to
keep them.
Signed-off-by: Aurélien Pupier
---
.../sql/SqlConsumerDeleteBatchCompleteTest.java| 18 ++
.../component/sql/SqlConsumerDeleteFailedTest.java | 8 +++-
.../camel/component/sql/SqlConsumerDeleteTest.java | 14 +++---
.../component/sql/SqlConsumerDeleteTransformTest.java | 15 +++
4 files changed, 15 insertions(+), 40 deletions(-)
diff --git
a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlConsumerDeleteBatchCompleteTest.java
b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlConsumerDeleteBatchCompleteTest.java
index 935357d5915..dc0715f43e7 100644
---
a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlConsumerDeleteBatchCompleteTest.java
+++
b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlConsumerDeleteBatchCompleteTest.java
@@ -16,6 +16,8 @@
*/
package org.apache.camel.component.sql;
+import java.util.concurrent.TimeUnit;
+
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.component.mock.MockEndpoint;
import org.apache.camel.test.junit5.CamelTestSupport;
@@ -27,7 +29,7 @@ import
org.springframework.jdbc.datasource.embedded.EmbeddedDatabase;
import org.springframework.jdbc.datasource.embedded.EmbeddedDatabaseBuilder;
import org.springframework.jdbc.datasource.embedded.EmbeddedDatabaseType;
-import static org.junit.jupiter.api.Assertions.assertEquals;
+import static org.awaitility.Awaitility.await;
/**
*
@@ -67,17 +69,9 @@ public class SqlConsumerDeleteBatchCompleteTest extends
CamelTestSupport {
MockEndpoint.assertIsSatisfied(context);
-// some servers may be a bit slow for this
-for (int i = 0; i < 5; i++) {
-// give it a little time to delete
-Thread.sleep(200);
-int rows = jdbcTemplate.queryForObject("select count(*) from
projects", Integer.class);
-if (rows == 0) {
-break;
-}
-}
-assertEquals(Integer.valueOf(0), jdbcTemplate.queryForObject("select
count(*) from projects", Integer.class),
-"Should have deleted all 3 rows");
+await("Should have deleted all 3 rows")
+.timeout(1, TimeUnit.SECONDS)
+.until(() -> jdbcTemplate.queryForObject("select count(*) from
projects", Integer.class) == 0);
}
@Override
diff --git
a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlConsumerDeleteFailedTest.java
b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlConsumerDeleteFailedTest.java
index e31f41b4f2a..3a20073614a 100644
---
a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlConsumerDeleteFailedTest.java
+++
b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlConsumerDeleteFailedTest.java
@@ -32,6 +32,7 @@ import
org.springframework.jdbc.datasource.embedded.EmbeddedDatabase;
import org.springframework.jdbc.datasource.embedded.EmbeddedDatabaseBuilder;
import org.springframework.jdbc.datasource.embedded.EmbeddedDatabaseType;
+import static org.awaitility.Awaitility.await;
import static org.junit.jupiter.api.Assertions.assertEquals;
/**
@@ -80,11 +81,8 @@ public class SqlConsumerDeleteFailedTest extends
CamelTestSupport {
assertEquals(3, exchanges.get(1).getIn().getBody(Map.class).get("ID"));
assertEquals("Linux",
exchanges.get(1).getIn().getBody(Map.class).get("PROJECT"));
-// give it a little tine to delete
-Thread.sleep(500);
-
-assertEquals(Integer.valueOf(1), jdbcTemplate.queryForObject("select
count(*) from projects", Integer.class),
-"Should have deleted 2 rows");
+await("Should have deleted 2 rows, keeping 1")
+.until(() -> jdbcTemplate.queryForObject("select count(*) from
projects", Integer.class) == 1);
assertEquals("AMQ", jdbcTemplate.queryForObject("select PROJECT from
projects where license = 'BAD'", String.class),
"Should be AMQ project that is BAD");
}
diff --git
a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlConsumerDeleteTest.java
Re: [PR] CAMEL-20798: EndpointServiceLocation on components to make it possible to know which remote system Camel connects to to assist for monitoring and observability - AWS Eventbridge and EKS [came
github-actions[bot] commented on PR #14535: URL: https://github.com/apache/camel/pull/14535#issuecomment-2167908323 :star2: Thank you for your contribution to the Apache Camel project! :star2: :robot: CI automation will test this PR automatically. :camel: Apache Camel Committers, please review the following items: * First-time contributors **require MANUAL approval** for the GitHub Actions to run * You can use the command `/component-test (camel-)component-name1 (camel-)component-name2..` to request a test from the test bot. * You can label PRs using `build-all`, `build-dependents`, `skip-tests` and `test-dependents` to fine-tune the checks executed by this PR. * Build and test logs are available in the Summary page. **Only** [Apache Camel committers](https://camel.apache.org/community/team/#committers) have access to the summary. * :warning: Be careful when sharing logs. Review their contents before sharing them publicly. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[PR] CAMEL-20798: EndpointServiceLocation on components to make it possible to know which remote system Camel connects to to assist for monitoring and observability - AWS Eventbridge and EKS [camel]
oscerd opened a new pull request, #14535: URL: https://github.com/apache/camel/pull/14535 # Description # Target - [x] I checked that the commit is targeting the correct branch (note that Camel 3 uses `camel-3.x`, whereas Camel 4 uses the `main` branch) # Tracking - [x] If this is a large change, bug fix, or code improvement, I checked there is a [JIRA issue](https://issues.apache.org/jira/browse/CAMEL) filed for the change (usually before you start working on it). # Apache Camel coding standards and style - [x] I checked that each commit in the pull request has a meaningful subject line and body. - [x] I have run `mvn clean install -DskipTests` locally and I have committed all auto-generated changes -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
Re: [PR] (#5522) Enhance environment trait to include values from secrets/conf… [camel-k]
squakez commented on code in PR #5639:
URL: https://github.com/apache/camel-k/pull/5639#discussion_r1639728624
##
e2e/advanced/environment_test.go:
##
@@ -39,7 +40,58 @@ import (
"github.com/apache/camel-k/v2/pkg/util/defaults"
)
-func TestEnvironmentTrait(t *testing.T) {
+func TestEnvironmentTraitVars(t *testing.T) {
+ t.Parallel()
+
+ WithNewTestNamespace(t, func(ctx context.Context, g *WithT, ns string) {
+ operatorID := "camel-k-trait-environment"
+ g.Expect(CopyCamelCatalog(t, ctx, ns, operatorID)).To(Succeed())
+ g.Expect(CopyIntegrationKits(t, ctx, ns,
operatorID)).To(Succeed())
+ g.Expect(KamelInstallWithID(t, ctx, operatorID,
ns)).To(Succeed())
+
+ g.Eventually(SelectedPlatformPhase(t, ctx, ns, operatorID),
TestTimeoutMedium).Should(Equal(v1.IntegrationPlatformPhaseReady))
+
+ // Create configmap
+ var cmData = make(map[string]string)
+ cmData["my-cm-key"] = "hello configmap"
+ err := CreatePlainTextConfigmap(t, ctx, ns, "my-cm", cmData)
+ require.NoError(t, err)
+
+ // Create secret
+ var secData = make(map[string]string)
+ secData["my-sec-key"] = "very top secret"
+ err = CreatePlainTextSecret(t, ctx, ns, "my-sec", secData)
+ require.NoError(t, err)
Review Comment:
ditto
##
pkg/util/property/property.go:
##
@@ -53,6 +57,52 @@ func EncodePropertyFile(sourceProperties map[string]string)
(string, error) {
return buf.String(), nil
}
+func FromMapToProperties(data interface{}, toString func(reflect.Value)
string, loadProperties func(reflect.Value) (*properties.Properties, error))
(*properties.Properties, error) {
+ result := properties.NewProperties()
+ m := reflect.ValueOf(data)
+ for _, k := range m.MapKeys() {
+ key := k.String()
+ value := m.MapIndex(k)
+ if strings.HasSuffix(key, ".properties") {
+ p, err := loadProperties(value)
+ if err == nil {
+ result.Merge(p)
+ } else if _, _, err = result.Set(key, toString(value));
err != nil {
+ return nil, fmt.Errorf("cannot assign %s to
%s", value, key)
+ }
+ } else if _, _, err := result.Set(key, toString(value)); err !=
nil {
+ return nil, fmt.Errorf("cannot assign %s to %s", value,
key)
+ }
+ }
+ return result, nil
+}
+
+func LoadPropertiesFromString(value string) (*properties.Properties, error) {
+ return properties.Load([]byte(value), properties.UTF8)
+}
+
+func LoadPropertiesFromConfigMap(ctx context.Context, c client.Client, ns
string, name string) (*properties.Properties, error) {
+ cm := kubernetes.LookupConfigmap(ctx, c, ns, name)
+ if cm == nil {
+ return nil, fmt.Errorf("%s configmap not found in %s namespace,
make sure to provide it before the Integration can run", name, ns)
+ }
+ return FromMapToProperties(cm.Data,
+ func(v reflect.Value) string { return v.String() },
+ func(v reflect.Value) (*properties.Properties, error) { return
LoadPropertiesFromString(v.String()) })
+}
+
+func LoadPropertiesFromSecret(ctx context.Context, c client.Client, ns string,
name string) (*properties.Properties, error) {
+ secret := kubernetes.LookupSecret(ctx, c, ns, name)
+ if secret == nil {
+ return nil, fmt.Errorf("%s secret not found in %s namespace,
make sure to provide it before the Integration can run", name, ns)
+ }
+ return FromMapToProperties(secret.Data,
Review Comment:
The operator should not read any data. Above all for secrets.
##
pkg/apis/camel/v1/trait/environment.go:
##
@@ -29,6 +29,7 @@ type EnvironmentTrait struct {
HTTPProxy *bool `property:"http-proxy" json:"httpProxy,omitempty"`
// A list of environment variables to be added to the integration
container.
// The syntax is KEY=VALUE, e.g., `MY_VAR="my value"`.
+ // The value may also be a reference to a configmap or secret, e.g.
`MY_VAR=configmap:my-cm/my-cm-key`
Review Comment:
You need to perform `make generate` to regen the spec and documentation.
##
pkg/trait/environment.go:
##
@@ -18,8 +18,11 @@ limitations under the License.
package trait
import (
+ "fmt"
"os"
+ "strings"
+ "github.com/magiconair/properties"
Review Comment:
We should try not to depend on this library any longer. It could have been
find for CLI, but the operator should limit the exposure to third party
libraries.
##
e2e/advanced/environment_test.go:
##
@@ -39,7 +40,58 @@ import (
(camel) branch CAMEL-20798-AWS-2 created (now 7187c6e8f0c)
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a change to branch CAMEL-20798-AWS-2 in repository https://gitbox.apache.org/repos/asf/camel.git at 7187c6e8f0c CAMEL-20798: EndpointServiceLocation on components to make it possible to know which remote system Camel connects to to assist for monitoring and observability - AWS Eventbridge This branch includes the following new commits: new 82fb701f414 CAMEL-20798: EndpointServiceLocation on components to make it possible to know which remote system Camel connects to to assist for monitoring and observability - AWS EKS new 7187c6e8f0c CAMEL-20798: EndpointServiceLocation on components to make it possible to know which remote system Camel connects to to assist for monitoring and observability - AWS Eventbridge 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.
(camel) 01/02: CAMEL-20798: EndpointServiceLocation on components to make it possible to know which remote system Camel connects to to assist for monitoring and observability - AWS EKS
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch CAMEL-20798-AWS-2
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 82fb701f414a901ee6c7b1e5440ed4ac91877ce8
Author: Andrea Cosentino
AuthorDate: Fri Jun 14 13:04:45 2024 +0200
CAMEL-20798: EndpointServiceLocation on components to make it possible to
know which remote system Camel connects to to assist for monitoring and
observability - AWS EKS
Signed-off-by: Andrea Cosentino
---
.../camel/component/aws2/eks/EKS2Endpoint.java | 20 +++-
1 file changed, 19 insertions(+), 1 deletion(-)
diff --git
a/components/camel-aws/camel-aws2-eks/src/main/java/org/apache/camel/component/aws2/eks/EKS2Endpoint.java
b/components/camel-aws/camel-aws2-eks/src/main/java/org/apache/camel/component/aws2/eks/EKS2Endpoint.java
index 714a9104704..ea54c814f8b 100644
---
a/components/camel-aws/camel-aws2-eks/src/main/java/org/apache/camel/component/aws2/eks/EKS2Endpoint.java
+++
b/components/camel-aws/camel-aws2-eks/src/main/java/org/apache/camel/component/aws2/eks/EKS2Endpoint.java
@@ -22,6 +22,7 @@ import org.apache.camel.Consumer;
import org.apache.camel.Processor;
import org.apache.camel.Producer;
import org.apache.camel.component.aws2.eks.client.EKS2ClientFactory;
+import org.apache.camel.spi.EndpointServiceLocation;
import org.apache.camel.spi.UriEndpoint;
import org.apache.camel.spi.UriParam;
import org.apache.camel.support.ScheduledPollEndpoint;
@@ -34,7 +35,7 @@ import software.amazon.awssdk.services.eks.EksClient;
@UriEndpoint(firstVersion = "3.1.0", scheme = "aws2-eks", title = "AWS Elastic
Kubernetes Service (EKS)",
syntax = "aws2-eks:label", producerOnly = true, category = {
Category.CLOUD, Category.MANAGEMENT },
headersClass = EKS2Constants.class)
-public class EKS2Endpoint extends ScheduledPollEndpoint {
+public class EKS2Endpoint extends ScheduledPollEndpoint implements
EndpointServiceLocation {
private EksClient eksClient;
@@ -86,4 +87,21 @@ public class EKS2Endpoint extends ScheduledPollEndpoint {
public EksClient getEksClient() {
return eksClient;
}
+
+@Override
+public String getServiceUrl() {
+if (!configuration.isOverrideEndpoint()) {
+if (ObjectHelper.isNotEmpty(configuration.getRegion())) {
+return configuration.getRegion();
+}
+} else if
(ObjectHelper.isNotEmpty(configuration.getUriEndpointOverride())) {
+return configuration.getUriEndpointOverride();
+}
+return null;
+}
+
+@Override
+public String getServiceProtocol() {
+return "eks";
+}
}
(camel) 02/02: CAMEL-20798: EndpointServiceLocation on components to make it possible to know which remote system Camel connects to to assist for monitoring and observability - AWS Eventbridge
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch CAMEL-20798-AWS-2
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 7187c6e8f0cbbbd8da5919e0fe2f6b79c942700b
Author: Andrea Cosentino
AuthorDate: Fri Jun 14 13:07:10 2024 +0200
CAMEL-20798: EndpointServiceLocation on components to make it possible to
know which remote system Camel connects to to assist for monitoring and
observability - AWS Eventbridge
Signed-off-by: Andrea Cosentino
---
.../aws2/eventbridge/EventbridgeEndpoint.java | 34 ++
1 file changed, 29 insertions(+), 5 deletions(-)
diff --git
a/components/camel-aws/camel-aws2-eventbridge/src/main/java/org/apache/camel/component/aws2/eventbridge/EventbridgeEndpoint.java
b/components/camel-aws/camel-aws2-eventbridge/src/main/java/org/apache/camel/component/aws2/eventbridge/EventbridgeEndpoint.java
index 3b7a7b76e3e..3bd5a813b95 100644
---
a/components/camel-aws/camel-aws2-eventbridge/src/main/java/org/apache/camel/component/aws2/eventbridge/EventbridgeEndpoint.java
+++
b/components/camel-aws/camel-aws2-eventbridge/src/main/java/org/apache/camel/component/aws2/eventbridge/EventbridgeEndpoint.java
@@ -22,14 +22,13 @@ import org.apache.camel.Consumer;
import org.apache.camel.Processor;
import org.apache.camel.Producer;
import
org.apache.camel.component.aws2.eventbridge.client.EventbridgeClientFactory;
-import org.apache.camel.spi.Metadata;
-import org.apache.camel.spi.UriEndpoint;
-import org.apache.camel.spi.UriParam;
-import org.apache.camel.spi.UriPath;
+import org.apache.camel.spi.*;
import org.apache.camel.support.DefaultEndpoint;
import org.apache.camel.util.ObjectHelper;
import software.amazon.awssdk.services.eventbridge.EventBridgeClient;
+import java.util.Map;
+
/**
* Send events to AWS Eventbridge cluster instances.
*/
@@ -38,7 +37,7 @@ import
software.amazon.awssdk.services.eventbridge.EventBridgeClient;
Category.CLOUD,
Category.MANAGEMENT },
headersClass = EventbridgeConstants.class)
-public class EventbridgeEndpoint extends DefaultEndpoint {
+public class EventbridgeEndpoint extends DefaultEndpoint implements
EndpointServiceLocation {
private EventBridgeClient eventbridgeClient;
@@ -94,4 +93,29 @@ public class EventbridgeEndpoint extends DefaultEndpoint {
public EventBridgeClient getEventbridgeClient() {
return eventbridgeClient;
}
+
+@Override
+public String getServiceUrl() {
+if (!configuration.isOverrideEndpoint()) {
+if (ObjectHelper.isNotEmpty(configuration.getRegion())) {
+return configuration.getRegion();
+}
+} else if
(ObjectHelper.isNotEmpty(configuration.getUriEndpointOverride())) {
+return configuration.getUriEndpointOverride();
+}
+return null;
+}
+
+@Override
+public String getServiceProtocol() {
+return "eventbridge";
+}
+
+@Override
+public Map getServiceMetadata() {
+if (configuration.getEventbusName() != null) {
+return Map.of("eventbus", configuration.getEventbusName());
+}
+return null;
+}
}
[PR] CAMEL-19544 - remove Thread.sleep in sql component test [camel]
apupier opened a new pull request, #14534: URL: https://github.com/apache/camel/pull/14534 Gain 800ms locally but easier to read code It remains several Thread.sleep but that are testing timeouts of the sql component or trying to simulate a little delay so I guess we need to keep them. # Description # Target - [ ] I checked that the commit is targeting the correct branch (note that Camel 3 uses `camel-3.x`, whereas Camel 4 uses the `main` branch) # Tracking - [ ] If this is a large change, bug fix, or code improvement, I checked there is a [JIRA issue](https://issues.apache.org/jira/browse/CAMEL) filed for the change (usually before you start working on it). # Apache Camel coding standards and style - [ ] I checked that each commit in the pull request has a meaningful subject line and body. - [ ] I have run `mvn clean install -DskipTests` locally and I have committed all auto-generated changes -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
Re: [PR] CAMEL-19544 - remove Thread.sleep in sql component test [camel]
github-actions[bot] commented on PR #14534: URL: https://github.com/apache/camel/pull/14534#issuecomment-2167903187 :star2: Thank you for your contribution to the Apache Camel project! :star2: :robot: CI automation will test this PR automatically. :camel: Apache Camel Committers, please review the following items: * First-time contributors **require MANUAL approval** for the GitHub Actions to run * You can use the command `/component-test (camel-)component-name1 (camel-)component-name2..` to request a test from the test bot. * You can label PRs using `build-all`, `build-dependents`, `skip-tests` and `test-dependents` to fine-tune the checks executed by this PR. * Build and test logs are available in the Summary page. **Only** [Apache Camel committers](https://camel.apache.org/community/team/#committers) have access to the summary. * :warning: Be careful when sharing logs. Review their contents before sharing them publicly. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
