This is an automated email from the ASF dual-hosted git repository.
oalsafi pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/master by this push:
new f5fb2d6 Fix code style
f5fb2d6 is described below
commit f5fb2d6a02b87055f13f683fdb48a499e5262fb6
Author: Omar Al-Safi <omars...@gmail.com>
AuthorDate: Fri Jan 29 17:00:26 2021 +0100
Fix code style
---
.../camel/component/azure/storage/queue/QueueConsumer.java | 9 +++------
1 file changed, 3 insertions(+), 6 deletions(-)
diff --git
a/components/camel-azure-storage-queue/src/main/java/org/apache/camel/component/azure/storage/queue/QueueConsumer.java
b/components/camel-azure-storage-queue/src/main/java/org/apache/camel/component/azure/storage/queue/QueueConsumer.java
index f391e0a..28d2428 100644
---
a/components/camel-azure-storage-queue/src/main/java/org/apache/camel/component/azure/storage/queue/QueueConsumer.java
+++
b/components/camel-azure-storage-queue/src/main/java/org/apache/camel/component/azure/storage/queue/QueueConsumer.java
@@ -114,12 +114,9 @@ public class QueueConsumer extends
ScheduledBatchPollingConsumer {
// copy messageId, popReceipt, timeout for fix exchange override
case
// azure storage blob can override this headers
- final String messageId = exchange.getIn()
- .getHeader(QueueConstants.MESSAGE_ID, String.class);
- final String popReceipt = exchange.getIn()
- .getHeader(QueueConstants.POP_RECEIPT, String.class);
- final Duration timeout = exchange.getIn()
- .getHeader(QueueConstants.TIMEOUT, Duration.class);
+ final String messageId =
exchange.getIn().getHeader(QueueConstants.MESSAGE_ID, String.class);
+ final String popReceipt =
exchange.getIn().getHeader(QueueConstants.POP_RECEIPT, String.class);
+ final Duration timeout =
exchange.getIn().getHeader(QueueConstants.TIMEOUT, Duration.class);
// add on completion to handle after work when the exchange is done
exchange.adapt(ExtendedExchange.class).addOnCompletion(new
Synchronization() {
