RE: AWS_S3 consumer unable to delect object with another S3 producer

[Yi Yan]

Hi Willem,

Thanks for your reply, it contains the 'aws-s3:' prefix actually just missing 
it when I renamed the bucket name, the result is the same.

from("aws-s3:source_bucket?amazonS3Client=#AWSConnection1=test1.txt=true")
 
.setHeader("CamelAwsS3Key", constant("test1_copy.txt"))
.setHeader("CamelAwsS3ContentLength", constant(5)) 
.to("aws-s3:target_bucket?amazonS3Client=#AWSConnection1=false");


Thanks,

Yi Yan

-Original Message-
From: Willem Jiang [mailto:willem.ji...@gmail.com] 
Sent: Wednesday, January 03, 2018 10:41
To: users@camel.apache.org
Subject: Re: AWS_S3 consumer unable to delect object with another S3 producer

Hi,

I don't see the aws-s3: prefix in you to endpoint. Can you double check it?


Willem Jiang

Blog: http://willemjiang.blogspot.com (English)
  http://jnn.iteye.com  (Chinese)
Twitter: willemjiang
Weibo: 姜宁willem

On Wed, Jan 3, 2018 at 10:06 AM, Yi Yan <y...@talend.com> wrote:

> Hi,
>
> I want to move(copy+delete) some objects from one AWS S3 bucket to 
> another, so I created the configuration like below, but the source 
> object was not deleted after running.
>
> from("aws-s3:SOURCE_BUCKET_NAME?amazonS3Client=#s3_
> client=test1.txt =true") 
> .setHeader("CamelAwsS3Key", constant("test1_copy.txt")) 
> .setHeader("CamelAwsS3ContentLength", constant(5)) 
> .to("TARGET_BUCKET_NAME?amazonS3Client=#s3_client=false);
>
>
> Thanks,
> Yi Yan
>
>

AWS_S3 consumer unable to delect object with another S3 producer

[Yi Yan]

Hi,

I want to move(copy+delete) some objects from one AWS S3 bucket to another, so 
I created the configuration like below, but the source object was not deleted 
after running.

from("aws-s3:SOURCE_BUCKET_NAME?amazonS3Client=#s3_client=test1.txt
 =true")
.setHeader("CamelAwsS3Key", constant("test1_copy.txt"))
.setHeader("CamelAwsS3ContentLength", constant(5))
.to("TARGET_BUCKET_NAME?amazonS3Client=#s3_client=false);


Thanks,
Yi Yan

How to delete messages by AWS-SQS Component with deleteAfterRead

[Yi Yan]

Hi,

I'm using camel-aws version 2.17.3, the deleteAfterRead options works well when 
I only set it by true, but when I use deleteIfFiltered(false) together, the 
message will not be deleted, then I changed them both as true the message can 
be deleted in queue. Is there any relationship between deleteAfterRead and 
deleteAfterRead? Does it mean if I use deleteAfterRead with deleteAfterRead 
together, I need to set them both with true when I want to delete the messages 
after read it?

No message will not be delete
[code]
from("aws-sqs:myQueue"
+ "?amazonSQSClient=#myClient "
+ "= true=false + 
"=All")
.filter().simple("${body} == 'foo'").to("log:qs_route.cLog_1" + 
"?level=WARN");

from("timer:cTimer_1" + "?repeatCount=" + 2 + "=" + 1000)
.routeId("qs_route_cTimer_1")
.setBody()
.constant("bar").to("aws-sqs:myQueue "
+ "? amazonSQSClient=#myClient")

from("timer:cTimer_2" + "?repeatCount=" + 2 + "=" + 1000)
.setBody()
.constant("foo").to("aws-sqs:myQueue "
+ "? amazonSQSClient=#myClient");
 [/code]


Thanks,
Yi