public class S3Session extends java.lang.Object implements org.springframework.integration.file.remote.session.Session<S3ObjectSummary>
Session implementation.| Constructor and Description |
|---|
S3Session(AmazonS3 amazonS3) |
S3Session(AmazonS3 amazonS3,
io.awspring.cloud.core.env.ResourceIdResolver resourceIdResolver) |
| Modifier and Type | Method and Description |
|---|---|
void |
append(java.io.InputStream inputStream,
java.lang.String destination) |
void |
close() |
boolean |
exists(java.lang.String path) |
boolean |
finalizeRaw() |
java.lang.Object |
getClientInstance() |
java.lang.String |
getHostPort() |
boolean |
isOpen() |
S3ObjectSummary[] |
list(java.lang.String path) |
java.lang.String[] |
listNames(java.lang.String path) |
boolean |
mkdir(java.lang.String directory) |
java.lang.String |
normalizeBucketName(java.lang.String path) |
void |
read(java.lang.String source,
java.io.OutputStream outputStream) |
java.io.InputStream |
readRaw(java.lang.String source) |
boolean |
remove(java.lang.String path) |
void |
rename(java.lang.String pathFrom,
java.lang.String pathTo) |
boolean |
rmdir(java.lang.String directory) |
void |
setEndpoint(java.lang.String endpoint) |
void |
write(java.io.InputStream inputStream,
java.lang.String destination) |
public S3Session(AmazonS3 amazonS3)
public S3Session(AmazonS3 amazonS3, io.awspring.cloud.core.env.ResourceIdResolver resourceIdResolver)
public void setEndpoint(java.lang.String endpoint)
public S3ObjectSummary[] list(java.lang.String path)
list in interface org.springframework.integration.file.remote.session.Session<S3ObjectSummary>public java.lang.String[] listNames(java.lang.String path)
listNames in interface org.springframework.integration.file.remote.session.Session<S3ObjectSummary>public boolean remove(java.lang.String path)
remove in interface org.springframework.integration.file.remote.session.Session<S3ObjectSummary>public void rename(java.lang.String pathFrom,
java.lang.String pathTo)
rename in interface org.springframework.integration.file.remote.session.Session<S3ObjectSummary>public void read(java.lang.String source,
java.io.OutputStream outputStream)
throws java.io.IOException
read in interface org.springframework.integration.file.remote.session.Session<S3ObjectSummary>java.io.IOExceptionpublic void write(java.io.InputStream inputStream,
java.lang.String destination)
write in interface org.springframework.integration.file.remote.session.Session<S3ObjectSummary>public void append(java.io.InputStream inputStream,
java.lang.String destination)
append in interface org.springframework.integration.file.remote.session.Session<S3ObjectSummary>public boolean mkdir(java.lang.String directory)
mkdir in interface org.springframework.integration.file.remote.session.Session<S3ObjectSummary>public boolean rmdir(java.lang.String directory)
rmdir in interface org.springframework.integration.file.remote.session.Session<S3ObjectSummary>public boolean exists(java.lang.String path)
exists in interface org.springframework.integration.file.remote.session.Session<S3ObjectSummary>public java.io.InputStream readRaw(java.lang.String source)
readRaw in interface org.springframework.integration.file.remote.session.Session<S3ObjectSummary>public void close()
close in interface java.io.Closeableclose in interface java.lang.AutoCloseableclose in interface org.springframework.integration.file.remote.session.Session<S3ObjectSummary>public boolean isOpen()
isOpen in interface org.springframework.integration.file.remote.session.Session<S3ObjectSummary>public boolean finalizeRaw()
finalizeRaw in interface org.springframework.integration.file.remote.session.Session<S3ObjectSummary>public java.lang.Object getClientInstance()
getClientInstance in interface org.springframework.integration.file.remote.session.Session<S3ObjectSummary>public java.lang.String getHostPort()
getHostPort in interface org.springframework.integration.file.remote.session.Session<S3ObjectSummary>public java.lang.String normalizeBucketName(java.lang.String path)