You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2022/05/11 19:49:05 UTC
[camel] branch main updated (0ee230f90a3 -> 13f33061c24)
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
from 0ee230f90a3 CAMEL-17913: camel-kafka - Add isolationLevel option for consumer
new b2f3caef158 Polished
new 13f33061c24 Polished
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:
.../src/main/java/org/apache/camel/resume/ResumeAdapter.java | 1 +
.../src/main/java/org/apache/camel/resume/ResumeStrategy.java | 2 --
.../src/main/java/org/apache/camel/resume/cache/ResumeCache.java | 2 --
.../src/main/java/org/apache/camel/resume/cache/SingleEntryCache.java | 1 +
.../src/main/java/org/apache/camel/model/OnExceptionDefinition.java | 4 +---
5 files changed, 3 insertions(+), 7 deletions(-)
[camel] 01/02: Polished
Posted by da...@apache.org.
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.git
commit b2f3caef1587bf042e6fa45f481deed6f36cd875
Author: Claus Ibsen <cl...@gmail.com>
AuthorDate: Wed May 11 21:46:20 2022 +0200
Polished
---
.../src/main/java/org/apache/camel/model/OnExceptionDefinition.java | 4 +---
1 file changed, 1 insertion(+), 3 deletions(-)
diff --git a/core/camel-core-model/src/main/java/org/apache/camel/model/OnExceptionDefinition.java b/core/camel-core-model/src/main/java/org/apache/camel/model/OnExceptionDefinition.java
index fb533c4db7a..c96ccebcf2f 100644
--- a/core/camel-core-model/src/main/java/org/apache/camel/model/OnExceptionDefinition.java
+++ b/core/camel-core-model/src/main/java/org/apache/camel/model/OnExceptionDefinition.java
@@ -33,7 +33,6 @@ import org.apache.camel.LoggingLevel;
import org.apache.camel.Predicate;
import org.apache.camel.Processor;
import org.apache.camel.builder.ExpressionBuilder;
-import org.apache.camel.processor.errorhandler.RedeliveryPolicy;
import org.apache.camel.spi.AsPredicate;
import org.apache.camel.spi.Metadata;
import org.apache.camel.support.ExpressionToPredicateAdapter;
@@ -374,7 +373,6 @@ public class OnExceptionDefinition extends OutputDefinition<OnExceptionDefinitio
/**
* Allow asynchronous delayed redelivery.
*
- * @see RedeliveryPolicy#setAsyncDelayedRedelivery(boolean)
* @return the builder
*/
public OnExceptionDefinition asyncDelayedRedelivery() {
@@ -631,7 +629,7 @@ public class OnExceptionDefinition extends OutputDefinition<OnExceptionDefinitio
}
/**
- * Sets a reference to a {@link RedeliveryPolicy} to lookup in the {@link org.apache.camel.spi.Registry} to be used.
+ * Sets a reference to a redelivery policy to lookup in the {@link org.apache.camel.spi.Registry} to be used.
*
* @param redeliveryPolicyRef reference to use for lookup
* @return the builder
[camel] 02/02: Polished
Posted by da...@apache.org.
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.git
commit 13f33061c2405be4f736aa4e31c218668be26201
Author: Claus Ibsen <cl...@gmail.com>
AuthorDate: Wed May 11 21:48:53 2022 +0200
Polished
---
core/camel-api/src/main/java/org/apache/camel/resume/ResumeAdapter.java | 1 +
.../camel-api/src/main/java/org/apache/camel/resume/ResumeStrategy.java | 2 --
.../src/main/java/org/apache/camel/resume/cache/ResumeCache.java | 2 --
.../src/main/java/org/apache/camel/resume/cache/SingleEntryCache.java | 1 +
4 files changed, 2 insertions(+), 4 deletions(-)
diff --git a/core/camel-api/src/main/java/org/apache/camel/resume/ResumeAdapter.java b/core/camel-api/src/main/java/org/apache/camel/resume/ResumeAdapter.java
index 53221ac7d10..1966c815c58 100644
--- a/core/camel-api/src/main/java/org/apache/camel/resume/ResumeAdapter.java
+++ b/core/camel-api/src/main/java/org/apache/camel/resume/ResumeAdapter.java
@@ -25,6 +25,7 @@ package org.apache.camel.resume;
* resume API, as well as to offer component-specific interfaces that can be specialized by other integrations.
*/
public interface ResumeAdapter {
+
/**
* Execute the resume logic for the adapter
*/
diff --git a/core/camel-api/src/main/java/org/apache/camel/resume/ResumeStrategy.java b/core/camel-api/src/main/java/org/apache/camel/resume/ResumeStrategy.java
index 06096be3b1e..15e38fa0621 100644
--- a/core/camel-api/src/main/java/org/apache/camel/resume/ResumeStrategy.java
+++ b/core/camel-api/src/main/java/org/apache/camel/resume/ResumeStrategy.java
@@ -27,8 +27,6 @@ public interface ResumeStrategy extends Service {
/**
* Gets an adapter for resuming operations
- *
- * @return
*/
ResumeAdapter getAdapter();
diff --git a/core/camel-api/src/main/java/org/apache/camel/resume/cache/ResumeCache.java b/core/camel-api/src/main/java/org/apache/camel/resume/cache/ResumeCache.java
index c2ce3758f33..c5fbedd1fa5 100644
--- a/core/camel-api/src/main/java/org/apache/camel/resume/cache/ResumeCache.java
+++ b/core/camel-api/src/main/java/org/apache/camel/resume/cache/ResumeCache.java
@@ -53,8 +53,6 @@ public interface ResumeCache<K, V> {
/**
* Gets the cache pool size
- *
- * @return
*/
long capacity();
}
diff --git a/core/camel-api/src/main/java/org/apache/camel/resume/cache/SingleEntryCache.java b/core/camel-api/src/main/java/org/apache/camel/resume/cache/SingleEntryCache.java
index e8b243846e7..2928dd8a26f 100644
--- a/core/camel-api/src/main/java/org/apache/camel/resume/cache/SingleEntryCache.java
+++ b/core/camel-api/src/main/java/org/apache/camel/resume/cache/SingleEntryCache.java
@@ -26,6 +26,7 @@ import java.util.Optional;
* @param <V> the type of the entry
*/
public interface SingleEntryCache<K, V> extends ResumeCache<K, V> {
+
/**
* Gets the offset value for the key
*