bibryam / camel-swf-demo

Amazon Simple Workflow Service with Apache Camel Demo

Camel AWS Simple Workflow Service Demo

WorkflowProducer will schedule 10 workflow executions

WorkflowConsumer will complete the first 5, and schedule activity tasks for the rest

ActivityConsumer will process activity tasks and return an incremented number as result.

License

ASLv2

camel-swf-demo's Issues

Fail

Having this problem I don't know why i'm getting an unable to parse error:

2015-07-09 15:34:40,027 [main ] INFO MainSupport - Apache Camel 2.15.2 starting
2015-07-09 15:34:40,570 [main ] INFO DefaultCamelContext - Apache Camel 2.15.2 (CamelContext: camel-1) is starting
2015-07-09 15:34:40,574 [main ] INFO ManagedManagementStrategy - JMX is enabled
2015-07-09 15:34:40,985 [main ] INFO DefaultTypeConverter - Loaded 182 type converters
2015-07-09 15:34:42,453 [main ] INFO DefaultCamelContext - AllowUseOriginalMessage is enabled. If access to the original message is not needed, then its recommended to turn this option off as it may improve performance.
2015-07-09 15:34:42,453 [main ] INFO DefaultCamelContext - StreamCaching is not in use. If using streams then its recommended to enable stream caching. See more details at http://camel.apache.org/stream-caching.html
2015-07-09 15:34:42,516 [main ] INFO GenericWorker - start: GenericActivityWorker [super=GenericActivityWorker[service=com.amazonaws.services.simpleworkflow.AmazonSimpleWorkflowClient@6e9a5ed8, domain=demo, taskListToPoll=demo-alist, identity=1100@U1ASW-ATAD001, backoffInitialInterval=100, backoffMaximumInterval=60000, backoffCoefficient=2.0], taskExecutorThreadPoolSize=100]
2015-07-09 15:34:43,360 [main ] WARN AmazonHttpClient - Unable to parse clock skew offset from response: null
java.lang.StringIndexOutOfBoundsException: String index out of range: -409
at java.lang.String.substring(String.java:1954)[:1.8.0_31]
at com.amazonaws.http.AmazonHttpClient.getServerDateFromException(AmazonHttpClient.java:1031)[aws-java-sdk-1.8.9.1.jar:]
at com.amazonaws.http.AmazonHttpClient.parseClockSkewOffset(AmazonHttpClient.java:1045)[aws-java-sdk-1.8.9.1.jar:]
at com.amazonaws.http.AmazonHttpClient.executeHelper(AmazonHttpClient.java:534)[aws-java-sdk-1.8.9.1.jar:]
at com.amazonaws.http.AmazonHttpClient.execute(AmazonHttpClient.java:273)[aws-java-sdk-1.8.9.1.jar:]
at com.amazonaws.services.simpleworkflow.AmazonSimpleWorkflowClient.invoke(AmazonSimpleWorkflowClient.java:3264)[aws-java-sdk-1.8.9.1.jar:]
at com.amazonaws.services.simpleworkflow.AmazonSimpleWorkflowClient.registerActivityType(AmazonSimpleWorkflowClient.java:2396)[aws-java-sdk-1.8.9.1.jar:]
at com.amazonaws.services.simpleworkflow.flow.worker.GenericActivityWorker.registerActivityType(GenericActivityWorker.java:153)[aws-java-sdk-1.8.9.1.jar:]
at com.amazonaws.services.simpleworkflow.flow.worker.GenericActivityWorker.registerActivityTypes(GenericActivityWorker.java:118)[aws-java-sdk-1.8.9.1.jar:]
at com.amazonaws.services.simpleworkflow.flow.worker.GenericActivityWorker.registerTypesToPoll(GenericActivityWorker.java:105)[aws-java-sdk-1.8.9.1.jar:]
at com.amazonaws.services.simpleworkflow.flow.worker.GenericWorker.start(GenericWorker.java:367)[aws-java-sdk-1.8.9.1.jar:]
at org.apache.camel.component.aws.swf.SWFActivityConsumer.doStart(SWFActivityConsumer.java:55)[camel-aws-2.15.2.jar:2.15.2]
at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:61)[camel-core-2.15.2.jar:2.15.2]
at org.apache.camel.impl.DefaultCamelContext.startService(DefaultCamelContext.java:2869)[camel-core-2.15.2.jar:2.15.2]
at org.apache.camel.impl.DefaultCamelContext.doStartOrResumeRouteConsumers(DefaultCamelContext.java:3163)[camel-core-2.15.2.jar:2.15.2]
at org.apache.camel.impl.DefaultCamelContext.doStartRouteConsumers(DefaultCamelContext.java:3099)[camel-core-2.15.2.jar:2.15.2]
at org.apache.camel.impl.DefaultCamelContext.safelyStartRouteServices(DefaultCamelContext.java:3029)[camel-core-2.15.2.jar:2.15.2]
at org.apache.camel.impl.DefaultCamelContext.doStartOrResumeRoutes(DefaultCamelContext.java:2797)[camel-core-2.15.2.jar:2.15.2]
at org.apache.camel.impl.DefaultCamelContext.doStartCamel(DefaultCamelContext.java:2653)[camel-core-2.15.2.jar:2.15.2]
at org.apache.camel.impl.DefaultCamelContext.access$000(DefaultCamelContext.java:167)[camel-core-2.15.2.jar:2.15.2]
at org.apache.camel.impl.DefaultCamelContext$2.call(DefaultCamelContext.java:2467)[camel-core-2.15.2.jar:2.15.2]
at org.apache.camel.impl.DefaultCamelContext$2.call(DefaultCamelContext.java:2463)[camel-core-2.15.2.jar:2.15.2]
at org.apache.camel.impl.DefaultCamelContext.doWithDefinedClassLoader(DefaultCamelContext.java:2486)[camel-core-2.15.2.jar:2.15.2]
at org.apache.camel.impl.DefaultCamelContext.doStart(DefaultCamelContext.java:2463)[camel-core-2.15.2.jar:2.15.2]
at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:61)[camel-core-2.15.2.jar:2.15.2]
at org.apache.camel.impl.DefaultCamelContext.start(DefaultCamelContext.java:2432)[camel-core-2.15.2.jar:2.15.2]
at org.apache.camel.main.Main.doStart(Main.java:124)[camel-core-2.15.2.jar:2.15.2]
at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:61)[camel-core-2.15.2.jar:2.15.2]
at org.apache.camel.main.MainSupport.run(MainSupport.java:150)[camel-core-2.15.2.jar:2.15.2]
at ActivityConsumer.main(ActivityConsumer.java:13)[file:///target/classes/:]
2015-07-09 15:34:43,438 [main ] WARN AmazonHttpClient - Unable to parse clock skew offset from response: null
java.lang.StringIndexOutOfBoundsException: String index out of range: -409
at java.lang.String.substring(String.java:1954)[:1.8.0_31]
at com.amazonaws.http.AmazonHttpClient.getServerDateFromException(AmazonHttpClient.java:1031)[aws-java-sdk-1.8.9.1.jar:]
at com.amazonaws.http.AmazonHttpClient.parseClockSkewOffset(AmazonHttpClient.java:1045)[aws-java-sdk-1.8.9.1.jar:]
at com.amazonaws.http.AmazonHttpClient.executeHelper(AmazonHttpClient.java:534)[aws-java-sdk-1.8.9.1.jar:]
at com.amazonaws.http.AmazonHttpClient.execute(AmazonHttpClient.java:273)[aws-java-sdk-1.8.9.1.jar:]
at com.amazonaws.services.simpleworkflow.AmazonSimpleWorkflowClient.invoke(AmazonSimpleWorkflowClient.java:3264)[aws-java-sdk-1.8.9.1.jar:]
at com.amazonaws.services.simpleworkflow.AmazonSimpleWorkflowClient.registerActivityType(AmazonSimpleWorkflowClient.java:2396)[aws-java-sdk-1.8.9.1.jar:]
at com.amazonaws.services.simpleworkflow.flow.worker.GenericActivityWorker.registerActivityType(GenericActivityWorker.java:153)[aws-java-sdk-1.8.9.1.jar:]
at com.amazonaws.services.simpleworkflow.flow.worker.GenericActivityWorker.registerActivityTypes(GenericActivityWorker.java:118)[aws-java-sdk-1.8.9.1.jar:]
at com.amazonaws.services.simpleworkflow.flow.worker.GenericActivityWorker.registerTypesToPoll(GenericActivityWorker.java:105)[aws-java-sdk-1.8.9.1.jar:]
at com.amazonaws.services.simpleworkflow.flow.worker.GenericWorker.start(GenericWorker.java:367)[aws-java-sdk-1.8.9.1.jar:]
at org.apache.camel.component.aws.swf.SWFActivityConsumer.doStart(SWFActivityConsumer.java:55)[camel-aws-2.15.2.jar:2.15.2]
at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:61)[camel-core-2.15.2.jar:2.15.2]
at org.apache.camel.impl.DefaultCamelContext.startService(DefaultCamelContext.java:2869)[camel-core-2.15.2.jar:2.15.2]
at org.apache.camel.impl.DefaultCamelContext.doStartOrResumeRouteConsumers(DefaultCamelContext.java:3163)[camel-core-2.15.2.jar:2.15.2]
at org.apache.camel.impl.DefaultCamelContext.doStartRouteConsumers(DefaultCamelContext.java:3099)[camel-core-2.15.2.jar:2.15.2]
at org.apache.camel.impl.DefaultCamelContext.safelyStartRouteServices(DefaultCamelContext.java:3029)[camel-core-2.15.2.jar:2.15.2]
at org.apache.camel.impl.DefaultCamelContext.doStartOrResumeRoutes(DefaultCamelContext.java:2797)[camel-core-2.15.2.jar:2.15.2]
at org.apache.camel.impl.DefaultCamelContext.doStartCamel(DefaultCamelContext.java:2653)[camel-core-2.15.2.jar:2.15.2]
at org.apache.camel.impl.DefaultCamelContext.access$000(DefaultCamelContext.java:167)[camel-core-2.15.2.jar:2.15.2]
at org.apache.camel.impl.DefaultCamelContext$2.call(DefaultCamelContext.java:2467)[camel-core-2.15.2.jar:2.15.2]
at org.apache.camel.impl.DefaultCamelContext$2.call(DefaultCamelContext.java:2463)[camel-core-2.15.2.jar:2.15.2]
at org.apache.camel.impl.DefaultCamelContext.doWithDefinedClassLoader(DefaultCamelContext.java:2486)[camel-core-2.15.2.jar:2.15.2]
at org.apache.camel.impl.DefaultCamelContext.doStart(DefaultCamelContext.java:2463)[camel-core-2.15.2.jar:2.15.2]
at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:61)[camel-core-2.15.2.jar:2.15.2]
at org.apache.camel.impl.DefaultCamelContext.start(DefaultCamelContext.java:2432)[camel-core-2.15.2.jar:2.15.2]
at org.apache.camel.main.Main.doStart(Main.java:124)[camel-core-2.15.2.jar:2.15.2]
at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:61)[camel-core-2.15.2.jar:2.15.2]
at org.apache.camel.main.MainSupport.run(MainSupport.java:150)[camel-core-2.15.2.jar:2.15.2]
at ActivityConsumer.main(ActivityConsumer.java:13)[file:///target/classes/:]
2015-07-09 15:34:44,052 [main ] WARN AmazonHttpClient - Unable to parse clock skew offset from response: null
java.lang.StringIndexOutOfBoundsException: String index out of range: -409
at java.lang.String.substring(String.java:1954)[:1.8.0_31]
at com.amazonaws.http.AmazonHttpClient.getServerDateFromException(AmazonHttpClient.java:1031)[aws-java-sdk-1.8.9.1.jar:]
at com.amazonaws.http.AmazonHttpClient.parseClockSkewOffset(AmazonHttpClient.java:1045)[aws-java-sdk-1.8.9.1.jar:]
at com.amazonaws.http.AmazonHttpClient.executeHelper(AmazonHttpClient.java:534)[aws-java-sdk-1.8.9.1.jar:]
at com.amazonaws.http.AmazonHttpClient.execute(AmazonHttpClient.java:273)[aws-java-sdk-1.8.9.1.jar:]
at com.amazonaws.services.simpleworkflow.AmazonSimpleWorkflowClient.invoke(AmazonSimpleWorkflowClient.java:3264)[aws-java-sdk-1.8.9.1.jar:]
at com.amazonaws.services.simpleworkflow.AmazonSimpleWorkflowClient.registerActivityType(AmazonSimpleWorkflowClient.java:2396)[aws-java-sdk-1.8.9.1.jar:]
at com.amazonaws.services.simpleworkflow.flow.worker.GenericActivityWorker.registerActivityType(GenericActivityWorker.java:153)[aws-java-sdk-1.8.9.1.jar:]
at com.amazonaws.services.simpleworkflow.flow.worker.GenericActivityWorker.registerActivityTypes(GenericActivityWorker.java:118)[aws-java-sdk-1.8.9.1.jar:]
at com.amazonaws.services.simpleworkflow.flow.worker.GenericActivityWorker.registerTypesToPoll(GenericActivityWorker.java:105)[aws-java-sdk-1.8.9.1.jar:]
at com.amazonaws.services.simpleworkflow.flow.worker.GenericWorker.start(GenericWorker.java:367)[aws-java-sdk-1.8.9.1.jar:]
at org.apache.camel.component.aws.swf.SWFActivityConsumer.doStart(SWFActivityConsumer.java:55)[camel-aws-2.15.2.jar:2.15.2]
at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:61)[camel-core-2.15.2.jar:2.15.2]
at org.apache.camel.impl.DefaultCamelContext.startService(DefaultCamelContext.java:2869)[camel-core-2.15.2.jar:2.15.2]
at org.apache.camel.impl.DefaultCamelContext.doStartOrResumeRouteConsumers(DefaultCamelContext.java:3163)[camel-core-2.15.2.jar:2.15.2]
at org.apache.camel.impl.DefaultCamelContext.doStartRouteConsumers(DefaultCamelContext.java:3099)[camel-core-2.15.2.jar:2.15.2]
at org.apache.camel.impl.DefaultCamelContext.safelyStartRouteServices(DefaultCamelContext.java:3029)[camel-core-2.15.2.jar:2.15.2]
at org.apache.camel.impl.DefaultCamelContext.doStartOrResumeRoutes(DefaultCamelContext.java:2797)[camel-core-2.15.2.jar:2.15.2]
at org.apache.camel.impl.DefaultCamelContext.doStartCamel(DefaultCamelContext.java:2653)[camel-core-2.15.2.jar:2.15.2]
at org.apache.camel.impl.DefaultCamelContext.access$000(DefaultCamelContext.java:167)[camel-core-2.15.2.jar:2.15.2]
at org.apache.camel.impl.DefaultCamelContext$2.call(DefaultCamelContext.java:2467)[camel-core-2.15.2.jar:2.15.2]
at org.apache.camel.impl.DefaultCamelContext$2.call(DefaultCamelContext.java:2463)[camel-core-2.15.2.jar:2.15.2]
at org.apache.camel.impl.DefaultCamelContext.doWithDefinedClassLoader(DefaultCamelContext.java:2486)[camel-core-2.15.2.jar:2.15.2]
at org.apache.camel.impl.DefaultCamelContext.doStart(DefaultCamelContext.java:2463)[camel-core-2.15.2.jar:2.15.2]
at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:61)[camel-core-2.15.2.jar:2.15.2]
at org.apache.camel.impl.DefaultCamelContext.start(DefaultCamelContext.java:2432)[camel-core-2.15.2.jar:2.15.2]
at org.apache.camel.main.Main.doStart(Main.java:124)[camel-core-2.15.2.jar:2.15.2]
at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:61)[camel-core-2.15.2.jar:2.15.2]
at org.apache.camel.main.MainSupport.run(MainSupport.java:150)[camel-core-2.15.2.jar:2.15.2]
at ActivityConsumer.main(ActivityConsumer.java:13)[file:///target/classes/:]
2015-07-09 15:34:45,271 [main ] INFO GenericWorker - shutdownNow
2015-07-09 15:34:45,271 [main ] INFO DefaultCamelContext - Apache Camel 2.15.2 (CamelContext: camel-1) is shutting down
2015-07-09 15:34:45,278 [main ] INFO DefaultCamelContext - Apache Camel 2.15.2 (CamelContext: camel-1) uptime 4.707 seconds
2015-07-09 15:34:45,278 [main ] INFO DefaultCamelContext - Apache Camel 2.15.2 (CamelContext: camel-1) is shutdown in 0.005 seconds
2015-07-09 15:34:45,279 [main ] INFO MainSupport - Apache Camel 2.15.2 stopping
Exception in thread "main" com.amazonaws.AmazonServiceException: The request signature we calculated does not match the signature you provided. Check your AWS Secret Access Key and signing method. Consult the service documentation for details.

The Canonical String for this request should have been
'POST
/

content-length:236
content-type:application/x-amz-json-1.0
host:swf.us-east-1.amazonaws.com
user-agent:aws-sdk-java/1.8.9.1 Windows_Server_2008_R2/6.1 Java_HotSpot(TM)_64-Bit_Server_VM/25.31-b07/1.8.0_31
x-amz-date:20150709T193444Z
x-amz-target:SimpleWorkflowService.RegisterActivityType

content-length;content-type;host;user-agent;x-amz-date;x-amz-target
f259fe07eb71db96af5db2869254ff4072c403a17529199e300a62e0239ac2d5'

The String-to-Sign should have been
'AWS4-HMAC-SHA256
20150709T193444Z
20150709/us-east-1/swf/aws4_request
f1843ff091a25b53ccebdc4e32a3966cba525f68372cee8ca7944126abb542e6'
(Service: AmazonSimpleWorkflow; Status Code: 400; Error Code: InvalidSignatureException; Request ID: 98cf4b3d-2671-11e5-9e75-9d6c75cae329)
at com.amazonaws.http.AmazonHttpClient.handleErrorResponse(AmazonHttpClient.java:937)
at com.amazonaws.http.AmazonHttpClient.executeHelper(AmazonHttpClient.java:506)
at com.amazonaws.http.AmazonHttpClient.execute(AmazonHttpClient.java:273)
at com.amazonaws.services.simpleworkflow.AmazonSimpleWorkflowClient.invoke(AmazonSimpleWorkflowClient.java:3264)
at com.amazonaws.services.simpleworkflow.AmazonSimpleWorkflowClient.registerActivityType(AmazonSimpleWorkflowClient.java:2396)
at com.amazonaws.services.simpleworkflow.flow.worker.GenericActivityWorker.registerActivityType(GenericActivityWorker.java:153)
at com.amazonaws.services.simpleworkflow.flow.worker.GenericActivityWorker.registerActivityTypes(GenericActivityWorker.java:118)
at com.amazonaws.services.simpleworkflow.flow.worker.GenericActivityWorker.registerTypesToPoll(GenericActivityWorker.java:105)
at com.amazonaws.services.simpleworkflow.flow.worker.GenericWorker.start(GenericWorker.java:367)
at org.apache.camel.component.aws.swf.SWFActivityConsumer.doStart(SWFActivityConsumer.java:55)
at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:61)
at org.apache.camel.impl.DefaultCamelContext.startService(DefaultCamelContext.java:2869)
at org.apache.camel.impl.DefaultCamelContext.doStartOrResumeRouteConsumers(DefaultCamelContext.java:3163)
at org.apache.camel.impl.DefaultCamelContext.doStartRouteConsumers(DefaultCamelContext.java:3099)
at org.apache.camel.impl.DefaultCamelContext.safelyStartRouteServices(DefaultCamelContext.java:3029)
at org.apache.camel.impl.DefaultCamelContext.doStartOrResumeRoutes(DefaultCamelContext.java:2797)
at org.apache.camel.impl.DefaultCamelContext.doStartCamel(DefaultCamelContext.java:2653)
at org.apache.camel.impl.DefaultCamelContext.access$000(DefaultCamelContext.java:167)
at org.apache.camel.impl.DefaultCamelContext$2.call(DefaultCamelContext.java:2467)
at org.apache.camel.impl.DefaultCamelContext$2.call(DefaultCamelContext.java:2463)
at org.apache.camel.impl.DefaultCamelContext.doWithDefinedClassLoader(DefaultCamelContext.java:2486)
at org.apache.camel.impl.DefaultCamelContext.doStart(DefaultCamelContext.java:2463)
at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:61)
at org.apache.camel.impl.DefaultCamelContext.start(DefaultCamelContext.java:2432)
at org.apache.camel.main.Main.doStart(Main.java:124)
at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:61)
at org.apache.camel.main.MainSupport.run(MainSupport.java:150)
at ActivityConsumer.main(ActivityConsumer.java:13)
2015-07-09 15:34:45,282 [Thread-0 ] INFO MainSupport$HangupInterceptor - Received hang up - stopping the main instance.