You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2018/07/12 05:51:30 UTC
[camel] branch master updated: CAMEL-12641 : Aws-sns and aws-sqs
components not accepting Date type message attributes
This is an automated email from the ASF dual-hosted git repository.
acosentino 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 56837d6 CAMEL-12641 : Aws-sns and aws-sqs components not accepting Date type message attributes
56837d6 is described below
commit 56837d64866ab8a076a11ccb5117bceb7a43aff3
Author: Saravanakumar Selvaraj <sa...@gmail.com>
AuthorDate: Wed Jul 11 20:48:10 2018 +0530
CAMEL-12641 : Aws-sns and aws-sqs components not accepting Date type message attributes
---
.../main/java/org/apache/camel/component/aws/sns/SnsProducer.java | 6 ++++++
.../main/java/org/apache/camel/component/aws/sqs/SqsProducer.java | 6 ++++++
2 files changed, 12 insertions(+)
diff --git a/components/camel-aws/src/main/java/org/apache/camel/component/aws/sns/SnsProducer.java b/components/camel-aws/src/main/java/org/apache/camel/component/aws/sns/SnsProducer.java
index cdfd52d..2b447e1 100644
--- a/components/camel-aws/src/main/java/org/apache/camel/component/aws/sns/SnsProducer.java
+++ b/components/camel-aws/src/main/java/org/apache/camel/component/aws/sns/SnsProducer.java
@@ -17,6 +17,7 @@
package org.apache.camel.component.aws.sns;
import java.nio.ByteBuffer;
+import java.util.Date;
import java.util.HashMap;
import java.util.Map;
import java.util.Map.Entry;
@@ -104,6 +105,11 @@ public class SnsProducer extends DefaultProducer {
mav.setDataType("Binary");
mav.withBinaryValue((ByteBuffer)value);
result.put(entry.getKey(), mav);
+ } else if (value instanceof Date) {
+ MessageAttributeValue mav = new MessageAttributeValue();
+ mav.setDataType("String");
+ mav.withStringValue(value.toString());
+ result.put(entry.getKey(), mav);
} else {
// cannot translate the message header to message attribute value
LOG.warn("Cannot put the message header key={}, value={} into Sns MessageAttribute", entry.getKey(), entry.getValue());
diff --git a/components/camel-aws/src/main/java/org/apache/camel/component/aws/sqs/SqsProducer.java b/components/camel-aws/src/main/java/org/apache/camel/component/aws/sqs/SqsProducer.java
index 74c8868..74b3e02 100644
--- a/components/camel-aws/src/main/java/org/apache/camel/component/aws/sqs/SqsProducer.java
+++ b/components/camel-aws/src/main/java/org/apache/camel/component/aws/sqs/SqsProducer.java
@@ -17,6 +17,7 @@
package org.apache.camel.component.aws.sqs;
import java.nio.ByteBuffer;
+import java.util.Date;
import java.util.HashMap;
import java.util.Map;
import java.util.Map.Entry;
@@ -161,6 +162,11 @@ public class SqsProducer extends DefaultProducer {
mav.setDataType(dataType);
mav.withStringValue(((Number)value).toString());
result.put(entry.getKey(), mav);
+ } else if (value instanceof Date) {
+ MessageAttributeValue mav = new MessageAttributeValue();
+ mav.setDataType("String");
+ mav.withStringValue(value.toString());
+ result.put(entry.getKey(), mav);
} else {
// cannot translate the message header to message attribute value
LOG.warn("Cannot put the message header key={}, value={} into Sqs MessageAttribute", entry.getKey(), entry.getValue());