public CephObjectMetadata put()

in src/main/java/com/epam/digital/data/platform/integration/ceph/service/impl/CephServiceS3Impl.java [108:121]


  public CephObjectMetadata put(String cephBucketName, String key, String contentType,
      Map<String, String> userMetadata, InputStream content) {
    log.info("Putting file with key {} to ceph bucket {}", key, cephBucketName);
    assertBucketExists(cephAmazonS3, cephBucketName);
    var result = execute(() -> {
      var objectMetadata = new ObjectMetadata();
      objectMetadata.setContentType(contentType);
      objectMetadata.setUserMetadata(userMetadata);
      cephAmazonS3.putObject(cephBucketName, key, content, objectMetadata);
      return cephAmazonS3.getObjectMetadata(cephBucketName, key);
    });
    log.info("File {} was put to ceph bucket {}", key, cephBucketName);
    return toCephObjectMetadata(result);
  }