Package org.wso2.carbon.relay
Class StreamingOnRequestDataSource
- java.lang.Object
-
- org.wso2.carbon.relay.StreamingOnRequestDataSource
-
- All Implemented Interfaces:
DataSource
public class StreamingOnRequestDataSource extends Object implements DataSource
This class has a special flag, which says this is it's last use and not to cache data if it did not have done so already.- Author:
- Srinath Perera (srinath@wso2.com)
-
-
Constructor Summary
Constructors Constructor Description StreamingOnRequestDataSource(InputStream in)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description String
getContentType()
InputStream
getInputStream()
String
getName()
OutputStream
getOutputStream()
boolean
isConsumed()
Indicates whether or not the InputStream of the message has been consumedvoid
setLastUse(boolean lastUse)
This flag says that this is the last use of the stream, hence do not need to cache it if it has not already cached.
-
-
-
Constructor Detail
-
StreamingOnRequestDataSource
public StreamingOnRequestDataSource(InputStream in)
-
-
Method Detail
-
getContentType
public String getContentType()
- Specified by:
getContentType
in interfaceDataSource
-
getInputStream
public InputStream getInputStream() throws IOException
- Specified by:
getInputStream
in interfaceDataSource
- Throws:
IOException
-
getName
public String getName()
- Specified by:
getName
in interfaceDataSource
-
getOutputStream
public OutputStream getOutputStream() throws IOException
- Specified by:
getOutputStream
in interfaceDataSource
- Throws:
IOException
-
setLastUse
public void setLastUse(boolean lastUse)
This flag says that this is the last use of the stream, hence do not need to cache it if it has not already cached.- Parameters:
lastUse
-
-
isConsumed
public boolean isConsumed()
Indicates whether or not the InputStream of the message has been consumed- Returns:
- true if the InputStream has already been consumed, false otherwise.
-
-