Examples of CompleteMultipartUploadResult

com.amazonaws.services.glacier.model.CompleteMultipartUploadResult
amazonwebservices.com/amazonglacier/latest/dev/api-archive-post.html"> Upload Archive . For conceptual information, go to Working with Archives in Amazon Glacier .
com.amazonaws.services.s3.model.CompleteMultipartUploadResult
The CompleteMultipartUploadResult contains all the information about the CompleteMultipartUpload method.

Examples of com.amazonaws.services.glacier.model.CompleteMultipartUploadResult

            }


            String checksum = TreeHashGenerator.calculateTreeHash(binaryChecksums);


            String archiveSize = Long.toString(file.length());
            CompleteMultipartUploadResult completeMultipartUploadResult =
                glacier.completeMultipartUpload(new CompleteMultipartUploadRequest()
                    .withAccountId(accountId)
                    .withArchiveSize(archiveSize)
                    .withVaultName(vaultName)
                    .withChecksum(checksum)
                    .withUploadId(uploadId));


            String artifactId = completeMultipartUploadResult.getArchiveId();
            publishProgress(progressListener, ProgressEventType.TRANSFER_COMPLETED_EVENT);
            return new UploadResult(artifactId);
        } catch (Exception e) {
            publishProgress(progressListener, ProgressEventType.TRANSFER_FAILED_EVENT);
            glacier.abortMultipartUpload(new AbortMultipartUploadRequest(accountId, vaultName, uploadId));

View Full Code Here

Examples of com.amazonaws.services.glacier.model.CompleteMultipartUploadResult

          }


          String checksum = TreeHashGenerator.calculateTreeHash(binaryChecksums);


          String archiveSize = Long.toString(file.length());
          CompleteMultipartUploadResult completeMultipartUploadResult =
              glacier.completeMultipartUpload(new CompleteMultipartUploadRequest()
                  .withAccountId(accountId)
                  .withArchiveSize(archiveSize)
                  .withVaultName(vaultName)
                  .withChecksum(checksum)
                  .withUploadId(uploadId));


          String artifactId = completeMultipartUploadResult.getArchiveId();
          return new UploadResult(artifactId);
        } catch (AmazonClientException e) {
          glacier.abortMultipartUpload(new AbortMultipartUploadRequest(accountId, vaultName, uploadId));
          throw e;
        }

View Full Code Here

Examples of com.amazonaws.services.glacier.model.CompleteMultipartUploadResult

          }


          String checksum = TreeHashGenerator.calculateTreeHash(binaryChecksums);


          String archiveSize = Long.toString(file.length());
          CompleteMultipartUploadResult completeMultipartUploadResult =
              glacier.completeMultipartUpload(new CompleteMultipartUploadRequest()
                  .withAccountId(accountId)
                  .withArchiveSize(archiveSize)
                  .withVaultName(vaultName)
                  .withChecksum(checksum)
                  .withUploadId(uploadId));


          String artifactId = completeMultipartUploadResult.getArchiveId();
          return new UploadResult(artifactId);
    } catch (Exception e) {
      glacier.abortMultipartUpload(new AbortMultipartUploadRequest(accountId, vaultName, uploadId));
      throw new AmazonClientException("Unable to finish the upload", e);
    }

View Full Code Here

Examples of com.amazonaws.services.glacier.model.CompleteMultipartUploadResult

          }


          String checksum = TreeHashGenerator.calculateTreeHash(binaryChecksums);


          String archiveSize = Long.toString(file.length());
          CompleteMultipartUploadResult completeMultipartUploadResult =
              glacier.completeMultipartUpload(new CompleteMultipartUploadRequest()
                  .withAccountId(accountId)
                  .withArchiveSize(archiveSize)
                  .withVaultName(vaultName)
                  .withChecksum(checksum)
                  .withUploadId(uploadId));


          String artifactId = completeMultipartUploadResult.getArchiveId();
          return new UploadResult(artifactId);
        } catch (AmazonClientException e) {
          glacier.abortMultipartUpload(new AbortMultipartUploadRequest(accountId, vaultName, uploadId));
          throw e;
        }

View Full Code Here

Examples of com.amazonaws.services.glacier.model.CompleteMultipartUploadResult

            }


            String checksum = TreeHashGenerator.calculateTreeHash(binaryChecksums);


            String archiveSize = Long.toString(file.length());
            CompleteMultipartUploadResult completeMultipartUploadResult =
                glacier.completeMultipartUpload(new CompleteMultipartUploadRequest()
                    .withAccountId(accountId)
                    .withArchiveSize(archiveSize)
                    .withVaultName(vaultName)
                    .withChecksum(checksum)
                    .withUploadId(uploadId));


            String artifactId = completeMultipartUploadResult.getArchiveId();
            return new UploadResult(artifactId);
        } catch (Exception e) {
            glacier.abortMultipartUpload(new AbortMultipartUploadRequest(accountId, vaultName, uploadId));
            throw new AmazonClientException("Unable to finish the upload", e);
        }

View Full Code Here

Examples of com.amazonaws.services.glacier.model.CompleteMultipartUploadResult

            }


            String checksum = TreeHashGenerator.calculateTreeHash(binaryChecksums);


            String archiveSize = Long.toString(file.length());
            CompleteMultipartUploadResult completeMultipartUploadResult =
                glacier.completeMultipartUpload(new CompleteMultipartUploadRequest()
                    .withAccountId(accountId)
                    .withArchiveSize(archiveSize)
                    .withVaultName(vaultName)
                    .withChecksum(checksum)
                    .withUploadId(uploadId));


            String artifactId = completeMultipartUploadResult.getArchiveId();
            return new UploadResult(artifactId);
        } catch (Exception e) {
            glacier.abortMultipartUpload(new AbortMultipartUploadRequest(accountId, vaultName, uploadId));
            throw new AmazonClientException("Unable to finish the upload", e);
        }

View Full Code Here

Examples of com.amazonaws.services.glacier.model.CompleteMultipartUploadResult

            } // end outer while


            String checksum = TreeHashGenerator.calculateTreeHash(binaryChecksums);


            String archiveSize = Long.toString(file.length());
            CompleteMultipartUploadResult completeMultipartUploadResult =
                glacier.completeMultipartUpload(new CompleteMultipartUploadRequest()
                    .withAccountId(accountId)
                    .withArchiveSize(archiveSize)
                    .withVaultName(vaultName)
                    .withChecksum(checksum)
                    .withUploadId(uploadId));


            String artifactId = completeMultipartUploadResult.getArchiveId();
            publishProgress(progressListener, ProgressEventType.TRANSFER_COMPLETED_EVENT);
            return new UploadResult(artifactId);
        } catch (Throwable t) {
            publishProgress(progressListener, ProgressEventType.TRANSFER_FAILED_EVENT);
            glacier.abortMultipartUpload(new AbortMultipartUploadRequest(accountId, vaultName, uploadId));

View Full Code Here

Examples of com.amazonaws.services.glacier.model.CompleteMultipartUploadResult

            }


            String checksum = TreeHashGenerator.calculateTreeHash(binaryChecksums);


            String archiveSize = Long.toString(file.length());
            CompleteMultipartUploadResult completeMultipartUploadResult =
                glacier.completeMultipartUpload(new CompleteMultipartUploadRequest()
                    .withAccountId(accountId)
                    .withArchiveSize(archiveSize)
                    .withVaultName(vaultName)
                    .withChecksum(checksum)
                    .withUploadId(uploadId));


            String artifactId = completeMultipartUploadResult.getArchiveId();
            publishProgress(progressListener, ProgressEventType.TRANSFER_COMPLETED_EVENT);
            return new UploadResult(artifactId);
        } catch (Throwable t) {
            publishProgress(progressListener, ProgressEventType.TRANSFER_FAILED_EVENT);
            glacier.abortMultipartUpload(new AbortMultipartUploadRequest(accountId, vaultName, uploadId));

View Full Code Here

Examples of com.amazonaws.services.glacier.model.CompleteMultipartUploadResult

          }


          String checksum = TreeHashGenerator.calculateTreeHash(binaryChecksums);


          String archiveSize = Long.toString(file.length());
          CompleteMultipartUploadResult completeMultipartUploadResult =
              glacier.completeMultipartUpload(new CompleteMultipartUploadRequest()
                  .withAccountId(accountId)
                  .withArchiveSize(archiveSize)
                  .withVaultName(vaultName)
                  .withChecksum(checksum)
                  .withUploadId(uploadId));


          String artifactId = completeMultipartUploadResult.getArchiveId();
          return new UploadResult(artifactId);
        } catch (AmazonClientException e) {
          glacier.abortMultipartUpload(new AbortMultipartUploadRequest(accountId, vaultName, uploadId));
          throw e;
        }

View Full Code Here

Examples of com.amazonaws.services.s3.model.CompleteMultipartUploadResult


        final InitiateMultipartUploadResult initResponse = getEndpoint().getS3Client().initiateMultipartUpload(initRequest);
        final long contentLength = objectMetadata.getContentLength();
        final List<PartETag> partETags = new ArrayList<PartETag>();
        long partSize = getConfiguration().getPartSize();
        CompleteMultipartUploadResult uploadResult = null;


        long filePosition = 0;




        try {
            for (int part = 1; filePosition < contentLength; part++) {
                partSize = Math.min(partSize, contentLength - filePosition);


                UploadPartRequest uploadRequest = new UploadPartRequest()
                        .withBucketName(getConfiguration().getBucketName()).withKey(keyName)
                        .withUploadId(initResponse.getUploadId()).withPartNumber(part)
                        .withFileOffset(filePosition)
                        .withFile(filePayload)
                        .withPartSize(partSize);


                LOG.trace("Uploading part [{}] for {}", part, keyName);
                partETags.add(getEndpoint().getS3Client().uploadPart(uploadRequest).getPartETag());


                filePosition += partSize;
            }
            CompleteMultipartUploadRequest compRequest = new
                    CompleteMultipartUploadRequest(getConfiguration().getBucketName(),
                    keyName,
                    initResponse.getUploadId(),
                    partETags);


            uploadResult = getEndpoint().getS3Client().completeMultipartUpload(compRequest);


        } catch (Exception e) {
            getEndpoint().getS3Client().abortMultipartUpload(new AbortMultipartUploadRequest(
                    getConfiguration().getBucketName(), keyName, initResponse.getUploadId()));
            throw e;
        }


        Message message = getMessageForResponse(exchange);
        message.setHeader(S3Constants.E_TAG, uploadResult.getETag());
        if (uploadResult.getVersionId() != null) {
            message.setHeader(S3Constants.VERSION_ID, uploadResult.getVersionId());
        }


        if (getConfiguration().isDeleteAfterWrite() && filePayload != null) {
            FileUtil.deleteFile(filePayload);
        }

View Full Code Here

0 1 2 3 4 5

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.