|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object | +--uk.org.ogsadai.activity.Activity | +--uk.org.ogsadai.activity.delivery.AbstractDeliverFromAddressActivity
This abstract class contains methods to connect to a
java.io.InputStream
and pull all the information on
that stream into OGSA-DAI, either in one byte array block, or via
multiple set sized byte array blocks.
The output can then be connected to the input of another activity,
Field Summary | |
private static java.lang.String |
COPYRIGHT_NOTICE
Copyright statement |
private static DAILogger |
LOG
Logger object for logging in this class |
protected boolean |
mBlockMode
Size of blocks placed onto the stream |
protected byte[] |
mBuffer
Buffer to hold data |
protected java.io.ByteArrayOutputStream |
mByteBuffer
ByteArrayOutputStream to hold output data |
protected java.lang.String |
mFromAddress
Address to read data from |
protected java.io.InputStream |
mFromInputStream
Input stream configured to read data from the address |
protected BlockWriter |
mOutput
Activity output - data read from address |
Fields inherited from class uk.org.ogsadai.activity.Activity |
mContext, mExternalInputs, mExternalOutputs, mInternalInputs, mInternalOutputs |
Constructor Summary | |
AbstractDeliverFromAddressActivity(org.w3c.dom.Element element)
|
Method Summary | |
void |
initialise()
This method should be overridden by subclasses to perform any initialisation they require before the process
method invocations begin. |
void |
processBlock()
Performs an iteration of the processing of an activity. |
abstract void |
processFirst()
This method is called during the first iteration of processing an activity. |
protected void |
setupBlocking(org.w3c.dom.Element fromElement)
Gets the block size, in bytes, from a blockSizeInBytes attribute of the given element
and saves this in an instance variable. |
protected void |
setupOutput(org.w3c.dom.Element toElement)
Gets the name of the activity output stream from a name attribute of the given element
and saves this in the activity's list of internal outputs. |
Methods inherited from class uk.org.ogsadai.activity.Activity |
cleanUp, connectsTo, createOutputPipe, getActivityConfiguration, getActivityName, getCause, getName, getObservableStatus, getProperties, getSession, getStatus, hasActivityConfiguration, hasProperties, process, setActivityName, setCompleted, setError |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
private static final java.lang.String COPYRIGHT_NOTICE
private static final DAILogger LOG
protected java.lang.String mFromAddress
protected java.io.InputStream mFromInputStream
protected boolean mBlockMode
protected byte[] mBuffer
protected final java.io.ByteArrayOutputStream mByteBuffer
protected BlockWriter mOutput
Constructor Detail |
public AbstractDeliverFromAddressActivity(org.w3c.dom.Element element) throws ActivityCreationException, ActivitySpecificationException
Method Detail |
protected void setupBlocking(org.w3c.dom.Element fromElement) throws ActivitySpecificationException, ActivityExecutionException
blockSizeInBytes
attribute of the given element
and saves this in an instance variable.
fromElement
- Element from the request.
ActivitySpecificationException
- If the block size is not an integer > 0.
ActivityExecutionException
- If there is not enough memory.protected void setupOutput(org.w3c.dom.Element toElement)
name
attribute of the given element
and saves this in the activity's list of internal outputs.
toElement
- Element from the request.public void initialise() throws ActivitySpecificationException, ActivityExecutionException
Activity
process
method invocations begin. This might be used for setting up
convenient fields to reference objects contained in the
context. It shouldn't be used for opening resources.
That should be done in processFirst
.
initialise
in class Activity
ActivityExecutionException
- If some system problem prevents the activity from
initialising.
ActivitySpecificationException
- If a problem with settings provided by a client prevents
the activity from initialising.public abstract void processFirst()
Activity
processFirst
in class Activity
public void processBlock()
Activity
setCompleted
method to indicate that
processing is complete, or the setError
method if
an error occurs that will prevent the processing from
completing.
processBlock
in class Activity
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |