<%@ jet imports=" org.talend.core.model.process.INode org.talend.core.model.process.ElementParameterParser org.talend.core.model.metadata.IMetadataTable org.talend.designer.codegen.config.CodeGeneratorArgument java.util.List java.util.Map java.util.ArrayList " %> <% CodeGeneratorArgument codeGenArgument = (CodeGeneratorArgument) argument; INode node = (INode)codeGenArgument.getArgument(); String accessKey = ElementParameterParser.getValue(node, "__ACCESSKEY__"); String secretKey = ElementParameterParser.getValue(node, "__SECRETKEY__"); String bucket = ElementParameterParser.getValue(node, "__BUCKET__"); String raiseErrorIfBucketExist = ElementParameterParser.getValue(node, "__ERROR_IF_BUCKET_EXIST__"); String cid = node.getUniqueName(); %> com.amazon.s3.AWSAuthConnection AWSAuthConnection<%=cid %> =null; <% String useExistingConn = ElementParameterParser.getValue(node, "__USE_EXISTING_CONNECTION__"); if(useExistingConn.equals("true")){ String connection = ElementParameterParser.getValue(node, "__CONNECTION__"); String conn= "conn_" + connection; %> AWSAuthConnection<%=cid %> = (com.amazon.s3.AWSAuthConnection)globalMap.get("<%=conn %>"); <%}else{%> AWSAuthConnection<%=cid %> = new com.amazon.s3.AWSAuthConnection(<%=accessKey%>,<%=secretKey%>); <%} %> java.util.Map> lHeaders = new java.util.TreeMap>(); lHeaders.put("Content-Type", java.util.Arrays.asList(new String[] { "text/plain" })); try { java.util.List lListBucket = AWSAuthConnection<%=cid %>.listAllMyBuckets(lHeaders).entries; boolean raiseError = <%=raiseErrorIfBucketExist%>; if (raiseError && com.ysance.s3.UtilsS3.listContainsBucket(lListBucket, <%=bucket%>)) throw new com.ysance.s3.exception.S3BucketAlreadyExistException("The Bucket " + <%=bucket%> + " already exist"); if (!com.ysance.s3.UtilsS3.listContainsBucket(lListBucket, <%=bucket%>)) AWSAuthConnection<%=cid %>.createBucket(<%=bucket%>, null, lHeaders).connection.getResponseMessage(); } catch (java.io.IOException ioe) { if ("Connection refused: connect".equals(ioe.getMessage())) throw new com.ysance.s3.exception.S3ConnectionException(ioe.getMessage()); else throw new com.ysance.s3.exception.S3BucketCreateException(ioe.getMessage()); }