This is a known issue and already fixed for Camel 2.10.3 and 2.11.0:
https://issues.apache.org/jira/browse/CAMEL-5782
The workaround is to provide an option like "defaultVisibilityTimeout" so
that the queue update request to AWS contains at least one attribute.
Sorry for the inconvinience...
Best,
Christian
On Wed, Nov 21, 2012 at 1:14 AM, rbogdanoff <ron.bogdan...@gmail.com> wrote:
> Hi,
>
> Am trying to use camel aws-sqs endpoint to send a message. I can do this
> no
> problem with Java AWS API directly, but with camel I am having trouble.
> Here is my code...
>
> package com.equilar.camelexamples;
>
> import org.apache.camel.CamelContext;
> import org.apache.camel.builder.RouteBuilder;
> import org.apache.camel.impl.DefaultCamelContext;
> import org.apache.camel.impl.SimpleRegistry;
>
> import com.amazonaws.ClientConfiguration;
> import com.amazonaws.auth.AWSCredentials;
> import com.amazonaws.auth.BasicAWSCredentials;
> import com.amazonaws.services.sqs.AmazonSQSClient;
>
>
> public class SQS {
>
>
> public void exec(String command) {
> try {
> // create CamelContext
> SimpleRegistry registry = new SimpleRegistry();
> AWSCredentials awsCredentials = new
> BasicAWSCredentials("mykey",
> "mysecretkey");
> ClientConfiguration clientConfiguration = new
> ClientConfiguration();
> AmazonSQSClient client = new
> AmazonSQSClient(awsCredentials,
> clientConfiguration);
> registry.put("amazonSQSClient" , client);
> CamelContext context = new DefaultCamelContext(registry);
>
> // add our route to the CamelContext
> context.addRoutes(new RouteBuilder() {
> public void configure() {
>
> from("file:/tmp/mydir?fileName=myfile.txt")
>
> .to("aws-sqs://MyQueue?amazonSQSClient=#amazonSQSClient");
> }
> });
>
>
> context.start();
>
> context.stop();
> } catch ( Exception e ) {
> throw new RuntimeException(e);
> }
>
> }
>
> }
>
> I get this exception...
>
> java.lang.RuntimeException: org.apache.camel.FailedToCreateRouteException:
> Failed to create route route1 at: >>>
> To[aws-sqs://MyQueue?amazonSQSClient=#amazonSQSClient] <<< in route:
> Route[[From[file:/tmp/mydir?fileName=myfile.txt]] -> [To[aws... because of
> Failed to resolve endpoint:
> aws-sqs://MyQueue?amazonSQSClient=%23amazonSQSClient due to: The request
> must contain the parameter Attribute.Name.
> at com.equilar.camelexamples.SQS.exec(SQS.java:58)
> at com.equilar.camelexamples.SQSTest.test2(SQSTest.java:21)
> at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> at
>
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
> at
>
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
> at java.lang.reflect.Method.invoke(Method.java:597)
> at
>
> org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:45)
> at
>
> org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:15)
> at
>
> org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:42)
> at
>
> org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:20)
> at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:263)
> at
>
> org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:68)
> at
>
> org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:47)
> at org.junit.runners.ParentRunner$3.run(ParentRunner.java:231)
> at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:60)
> at
> org.junit.runners.ParentRunner.runChildren(ParentRunner.java:229)
> at org.junit.runners.ParentRunner.access$000(ParentRunner.java:50)
> at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:222)
> at org.junit.runners.ParentRunner.run(ParentRunner.java:300)
> at
>
> org.eclipse.jdt.internal.junit4.runner.JUnit4TestReference.run(JUnit4TestReference.java:50)
> at
>
> org.eclipse.jdt.internal.junit.runner.TestExecution.run(TestExecution.java:38)
> at
>
> org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:467)
> at
>
> org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:683)
> at
>
> org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.run(RemoteTestRunner.java:390)
> at
>
> org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.main(RemoteTestRunner.java:197)
> Caused by: org.apache.camel.FailedToCreateRouteException: Failed to create
> route route1 at: >>> To[aws-sqs://MyQueue?amazonSQSClient=#amazonSQSClient]
> <<< in route: Route[[From[file:/tmp/mydir?fileName=myfile.txt]] ->
> [To[aws... because of Failed to resolve endpoint:
> aws-sqs://MyQueue?amazonSQSClient=%23amazonSQSClient due to: The request
> must contain the parameter Attribute.Name.
> at
> org.apache.camel.model.RouteDefinition.addRoutes(RouteDefinition.java:873)
> at
> org.apache.camel.model.RouteDefinition.addRoutes(RouteDefinition.java:171)
> at
>
> org.apache.camel.impl.DefaultCamelContext.startRoute(DefaultCamelContext.java:722)
> at
>
> org.apache.camel.impl.DefaultCamelContext.startRouteDefinitions(DefaultCamelContext.java:1789)
> at
>
> org.apache.camel.impl.DefaultCamelContext.doStartCamel(DefaultCamelContext.java:1575)
> at
>
> org.apache.camel.impl.DefaultCamelContext.doStart(DefaultCamelContext.java:1444)
> at
> org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:60)
> at
>
> org.apache.camel.impl.DefaultCamelContext.start(DefaultCamelContext.java:1412)
> at com.equilar.camelexamples.SQS.exec(SQS.java:54)
> ... 24 more
> Caused by: org.apache.camel.ResolveEndpointFailedException: Failed to
> resolve endpoint: aws-sqs://MyQueue?amazonSQSClient=%23amazonSQSClient due
> to: The request must contain the parameter Attribute.Name.
> at
>
> org.apache.camel.impl.DefaultCamelContext.getEndpoint(DefaultCamelContext.java:479)
> at
>
> org.apache.camel.util.CamelContextHelper.getMandatoryEndpoint(CamelContextHelper.java:50)
> at
>
> org.apache.camel.model.RouteDefinition.resolveEndpoint(RouteDefinition.java:186)
> at
>
> org.apache.camel.impl.DefaultRouteContext.resolveEndpoint(DefaultRouteContext.java:108)
> at
>
> org.apache.camel.impl.DefaultRouteContext.resolveEndpoint(DefaultRouteContext.java:114)
> at
>
> org.apache.camel.model.SendDefinition.resolveEndpoint(SendDefinition.java:61)
> at
>
> org.apache.camel.model.SendDefinition.createProcessor(SendDefinition.java:55)
> at
>
> org.apache.camel.model.ProcessorDefinition.makeProcessor(ProcessorDefinition.java:441)
> at
>
> org.apache.camel.model.ProcessorDefinition.addRoutes(ProcessorDefinition.java:179)
> at
> org.apache.camel.model.RouteDefinition.addRoutes(RouteDefinition.java:870)
> ... 32 more
> Caused by: Status Code: 400, AWS Service: AmazonSQS, AWS Request ID:
> cd5d1220-0524-5cf8-aed7-5b061e896d5c, AWS Error Code: MissingParameter, AWS
> Error Message: The request must contain the parameter Attribute.Name.
> at
>
> com.amazonaws.http.AmazonHttpClient.handleErrorResponse(AmazonHttpClient.java:556)
> at
>
> com.amazonaws.http.AmazonHttpClient.executeHelper(AmazonHttpClient.java:289)
> at
> com.amazonaws.http.AmazonHttpClient.execute(AmazonHttpClient.java:170)
> at
> com.amazonaws.services.sqs.AmazonSQSClient.invoke(AmazonSQSClient.java:812)
> at
>
> com.amazonaws.services.sqs.AmazonSQSClient.setQueueAttributes(AmazonSQSClient.java:246)
> at
>
> org.apache.camel.component.aws.sqs.SqsEndpoint.updateQueueAttributes(SqsEndpoint.java:139)
> at
> org.apache.camel.component.aws.sqs.SqsEndpoint.doStart(SqsEndpoint.java:93)
> at
> org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:60)
> at
>
> org.apache.camel.impl.DefaultCamelContext.startService(DefaultCamelContext.java:1763)
> at
>
> org.apache.camel.impl.DefaultCamelContext.doAddService(DefaultCamelContext.java:931)
> at
>
> org.apache.camel.impl.DefaultCamelContext.addService(DefaultCamelContext.java:892)
> at
>
> org.apache.camel.impl.DefaultCamelContext.getEndpoint(DefaultCamelContext.java:475)
> ... 41 more
>
> What could be the problem?
>
> Regards
> Ron Bogdanoff
>
>
>
> --
> View this message in context:
> http://camel.465427.n5.nabble.com/aws-sqs-returns-exception-The-request-must-contain-the-parameter-Attribute-Name-tp5723036.html
> Sent from the Camel - Users mailing list archive at Nabble.com.
>
--
