Package org.cdlib.mrt.core

Class StorageAddClient

java.lang.Object

org.cdlib.mrt.core.StorageAddClient

public class StorageAddClient
extends Object

AddClient for Storage

Author:

loy

Field Summary

Fields

Modifier and Type	Field	Description
protected static final String	FORMAT_NAME_MULTIPART
protected static final String	FORMAT_NAME_POST
protected LoggerInf	logger
protected static final String	NL

Constructor Summary

Constructors

Constructor	Description
StorageAddClient()
StorageAddClient(LoggerInf logger)

Method Summary

Modifier and Type	Method	Description
protected void	addNameValue(List<org.apache.http.NameValuePair> nvps, String key, String value)
Properties	addVersion(String link, int nodeID, Identifier objectID, String localContext, String localID, String manifestS, String urlS, Long size, String type, String value, String formatType, int timeout, int retry)
Properties	addVersion(String link, String nodeIDS, String objectIDS, String localContext, String localID, String manifestS, String urlS, String validate, String formatType)
void	log(String msg, int lvl)
protected Properties	processResponse(org.apache.http.HttpResponse response)
org.apache.http.HttpResponse	sendAddMultipart(String link, Integer nodeID, Identifier objectID, String localContext, String localID, File manifest, String url, Long size, String type, String value, String formatType)
org.apache.http.HttpResponse	sendAddMultipart(String link, Integer nodeID, Identifier objectID, String localContext, String localID, File manifest, String url, Long size, String type, String value, String formatType, int timeout)
org.apache.http.HttpResponse	sendAddMultipartRetry(String link, Integer nodeID, Identifier objectID, String localContext, String localID, File manifestFile, String urlS, Long size, String type, String value, String formatType, int timeout, int retry)	getObject with timeout and retry
Properties	sendAddMultipartRetryProperties(String link, Integer nodeID, Identifier objectID, String localContext, String localID, File manifestFile, String urlS, Long size, String type, String value, String formatType, int timeout, int retry)	Send a multipart storage add request
org.apache.http.HttpResponse	sendAddPost(String link, int nodeID, Identifier objectID, String context, String identifier, File manifest, String url, Long size, String type, String value, String formatType)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

NL

protected static final String NL

FORMAT_NAME_POST

protected static final String FORMAT_NAME_POST

See Also:

• Constant Field Values

FORMAT_NAME_MULTIPART

protected static final String FORMAT_NAME_MULTIPART

See Also:

• Constant Field Values

logger

protected LoggerInf logger

Constructor Details

StorageAddClient

public StorageAddClient(LoggerInf logger)

StorageAddClient

public StorageAddClient()

Method Details

addVersion

public Properties addVersion(String link,
 String nodeIDS,
 String objectIDS,
 String localContext,
 String localID,
 String manifestS,
 String urlS,
 String validate,
 String formatType)
                      throws TException

Throws:

TException

addVersion

public Properties addVersion(String link,
 int nodeID,
 Identifier objectID,
 String localContext,
 String localID,
 String manifestS,
 String urlS,
 Long size,
 String type,
 String value,
 String formatType,
 int timeout,
 int retry)
                      throws TException

Throws:

TException

sendAddMultipartRetry

public org.apache.http.HttpResponse sendAddMultipartRetry(String link,
 Integer nodeID,
 Identifier objectID,
 String localContext,
 String localID,
 File manifestFile,
 String urlS,
 Long size,
 String type,
 String value,
 String formatType,
 int timeout,
 int retry)
                                                   throws TException

getObject with timeout and retry

Parameters:

requestURL - build inputStream to this URL

timeout - milliseconds for timeout

retry - number of retry attemps

Returns:

InputStream to URL service

Throws:

TException

sendAddMultipartRetryProperties

public Properties sendAddMultipartRetryProperties(String link,
 Integer nodeID,
 Identifier objectID,
 String localContext,
 String localID,
 File manifestFile,
 String urlS,
 Long size,
 String type,
 String value,
 String formatType,
 int timeout,
 int retry)
                                           throws TException

Send a multipart storage add request

Parameters:

link - base storage URL

nodeID - node identifier

objectID - object identifier

localContext - authorization context for localID

localID - local identifier

manifestFile - manifest as file (exclusive of urlS)

urlS - link to manifest (exclusive of manifestFile)

size - size of manifest data

type - checksumType of manifest data

value - checksum of manifest data

formatType - output format type

timeout - milli-seconds for timeout

retry - number of retries

Returns:

response properties

Throws:

TException

processResponse

protected Properties processResponse(org.apache.http.HttpResponse response)
                              throws TException

Throws:

TException

sendAddMultipart

public org.apache.http.HttpResponse sendAddMultipart(String link,
 Integer nodeID,
 Identifier objectID,
 String localContext,
 String localID,
 File manifest,
 String url,
 Long size,
 String type,
 String value,
 String formatType)
                                              throws TException

Throws:

TException

sendAddMultipart

public org.apache.http.HttpResponse sendAddMultipart(String link,
 Integer nodeID,
 Identifier objectID,
 String localContext,
 String localID,
 File manifest,
 String url,
 Long size,
 String type,
 String value,
 String formatType,
 int timeout)
                                              throws TException

Throws:

TException

sendAddPost

public org.apache.http.HttpResponse sendAddPost(String link,
 int nodeID,
 Identifier objectID,
 String context,
 String identifier,
 File manifest,
 String url,
 Long size,
 String type,
 String value,
 String formatType)
                                         throws TException

Throws:

TException

log

public void log(String msg,
 int lvl)

addNameValue

protected void addNameValue(List<org.apache.http.NameValuePair> nvps,
 String key,
 String value)