public FilePullOperation(ClusterFileTransfer.FileContentChunk fileChunk) 
{
         mFileChunk = fileChunk;
}

 public  void cancel() 
{
         logMessage("Canceling send of file " + mFileChunk.getDestinationFile() + " as remote server "+mFileChunk.getOriginatingNodeName()+" left the cluster.");
         try
         {
            mInput.close();
         }
         catch(IOException e) { logException(e); }
}

Cancel the file pull operation. To be called locally on the machine that is supplying the file.

 public ClusterFileTransfer.FileContentChunk getFileChunk() 
{
         return mFileChunk;
}

 public InputStream getInputStream() 
{
         return mInput;
}

 public  void openInputFile() throws FileNotFoundException 
{
         mInput = mFileChunk.openInputFile();
}