You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by gz...@apache.org on 2019/06/04 07:08:12 UTC
[camel] branch master updated (2331a41 -> 6ac6a15)
This is an automated email from the ASF dual-hosted git repository.
gzurowski pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git.
from 2331a41 CAMEL-13605 Support setup proxy host and port on Telegram.
new 4e42dd2 Simplify code
new 6ac6a15 Simplify code: Use lambda expression
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:
.../java/org/apache/camel/component/aws/sqs/SqsConfiguration.java | 5 +----
.../main/java/org/apache/camel/component/aws/sqs/SqsConsumer.java | 7 +------
2 files changed, 2 insertions(+), 10 deletions(-)
[camel] 01/02: Simplify code
Posted by gz...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
gzurowski pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 4e42dd21de1da9b34dbe874f2f2da76ee84eccee
Author: Gregor Zurowski <gr...@zurowski.org>
AuthorDate: Tue Jun 4 09:06:25 2019 +0200
Simplify code
---
.../java/org/apache/camel/component/aws/sqs/SqsConfiguration.java | 5 +----
1 file changed, 1 insertion(+), 4 deletions(-)
diff --git a/components/camel-aws-sqs/src/main/java/org/apache/camel/component/aws/sqs/SqsConfiguration.java b/components/camel-aws-sqs/src/main/java/org/apache/camel/component/aws/sqs/SqsConfiguration.java
index 894a7b1..c665fb5 100644
--- a/components/camel-aws-sqs/src/main/java/org/apache/camel/component/aws/sqs/SqsConfiguration.java
+++ b/components/camel-aws-sqs/src/main/java/org/apache/camel/component/aws/sqs/SqsConfiguration.java
@@ -107,10 +107,7 @@ public class SqsConfiguration implements Cloneable {
boolean isFifoQueue() {
// AWS docs suggest this is valid derivation.
// FIFO queue names must end with .fifo, and standard queues cannot
- if (queueName.endsWith(".fifo")) {
- return true;
- }
- return false;
+ return queueName.endsWith(".fifo");
}
public String getAmazonAWSHost() {
[camel] 02/02: Simplify code: Use lambda expression
Posted by gz...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
gzurowski pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 6ac6a152543b2f33c59454532deb457e8c094a00
Author: Gregor Zurowski <gr...@zurowski.org>
AuthorDate: Tue Jun 4 09:07:32 2019 +0200
Simplify code: Use lambda expression
---
.../main/java/org/apache/camel/component/aws/sqs/SqsConsumer.java | 7 +------
1 file changed, 1 insertion(+), 6 deletions(-)
diff --git a/components/camel-aws-sqs/src/main/java/org/apache/camel/component/aws/sqs/SqsConsumer.java b/components/camel-aws-sqs/src/main/java/org/apache/camel/component/aws/sqs/SqsConsumer.java
index be11e6b..c9ac68a 100644
--- a/components/camel-aws-sqs/src/main/java/org/apache/camel/component/aws/sqs/SqsConsumer.java
+++ b/components/camel-aws-sqs/src/main/java/org/apache/camel/component/aws/sqs/SqsConsumer.java
@@ -202,12 +202,7 @@ public class SqsConsumer extends ScheduledBatchPollingConsumer {
});
log.trace("Processing exchange [{}]...", exchange);
- getAsyncProcessor().process(exchange, new AsyncCallback() {
- @Override
- public void done(boolean doneSync) {
- log.trace("Processing exchange [{}] done.", exchange);
- }
- });
+ getAsyncProcessor().process(exchange, doneSync -> log.trace("Processing exchange [{}] done.", exchange));
}
return total;