Hi, cheers for your response. We had a play about with the tests and all seems well.
It appears after inspecting our jms queues that the reason it was blocking was because the file was still present in the body of the message and this was causing it to hang and not shutdown correctly. JMS Storage % was +100% full. We found that if we purged the response queue it worked fine which led us to this conclusion. As it happens as part of real implementation we simple clear down/overwrite the mesage body with a simple response and the issue went away. We are now successfully sending and retrieving S3 files without a restart :) Thanks for the help. On 23 February 2012 22:57, Christian Müller <[email protected]>wrote: > I updated the AWS S3 integration test to send two requests [1]. > Could you execute the test and tell us how it works for you? You have to > provide your own accessKey and secretKey to execute it... > > [1] > > https://svn.apache.org/repos/asf/camel/trunk/components/camel-aws/src/test/java/org/apache/camel/component/aws/s3/integration/S3ComponentIntegrationTest.java > > Best, > Christian > > On Thu, Feb 23, 2012 at 6:43 PM, James Morgan <[email protected] > >wrote: > > > To follow this up, I am also having trouble shutting down the application > > once it is started, usually resorting to killing the java process. > > > > Windows 7 x64, Jetty 7 > > > > On 23 February 2012 17:40, James Morgan <[email protected]> > wrote: > > > > > Hi I've been using camel S3 component and a few problems have arisen > but > > > not sure where about they stem from. > > > > > > My issue is that once I have sent 1 file to S3 (which works fine, I can > > > see the file in the correct bucket) I cannot send any more without > > > restarting the application. > > > > > > I was wondering if I have missed something and I am not correctly > closing > > > the route/connection but am completely stumped, any help would be > > > appreciated? > > > > > > The file is already set as the body on the route. > > > > > > Basic route set-up is as follows: > > > > > > public class DocumentStorageEngineRouting extends RouteBuilder { > > > > > > public static final String DOCUMENT_UPLOAD_QUEUE = > > > "direct:document-upload-request"; > > > > > > @AutowiredProperty("aws.bucketName") > > > private String bucketName = "###MY_BUCKET###"; > > > > > > @AutowiredProperty("aws.region") > > > private String region = "eu-west-1"; > > > > > > @Override > > > public void configure() throws Exception { > > > > > > final String awsEndpoint = > > > > > > > > > String.format("aws-s3://%s?storageClass=REDUCED_REDUNDANCY®ion=%s&amazonS3Client=#amazonS3", > > > this.bucketName, > > > this.region); > > > > > > // @formatter:off > > > from(DOCUMENT_UPLOAD_QUEUE) > > > .setHeader(S3Constants.KEY, "my_file_name") > > > .setHeader(S3Constants.CONTENT_TYPE, > > simple("application/pdf")) > > > .to(awsEndpoint) > > > .end(); > > > // @formatter:on > > > } > > > } > > > > > > Camel 2.8.4, Spring 3.0.4, Java 6 > > > > > > Thanks James > > > > > >
