Revision 6611
Added by ben leinfelder over 12 years ago
ReplicationService.java | ||
---|---|---|
838 | 838 |
String datafilePath = PropertyService |
839 | 839 |
.getProperty("application.datafilepath"); |
840 | 840 |
|
841 |
InputStream inputStream = getURLStream(url); |
|
842 |
|
|
841 | 843 |
Exception writeException = null; |
842 | 844 |
//register data file into xml_documents table and wite data file |
843 | 845 |
//into file system |
844 | 846 |
try { |
845 |
DocumentImpl.writeDataFileInReplication(url.openStream(),
|
|
847 |
DocumentImpl.writeDataFileInReplication(inputStream,
|
|
846 | 848 |
datafilePath, docName, docType, docid, null, docHomeServer, |
847 | 849 |
server, DocumentImpl.DOCUMENTTABLE, false, createdDate, |
848 | 850 |
updatedDate); |
... | ... | |
2040 | 2042 |
* @throws java.io.IOException |
2041 | 2043 |
*/ |
2042 | 2044 |
public static String getURLContent(URL u) throws java.io.IOException { |
2043 |
logReplication.info("Getting url content from " + u.toString()); |
|
2044 | 2045 |
char istreamChar; |
2045 | 2046 |
int istreamInt; |
2046 |
logReplication.info("ReplicationService.getURLContent - Before sending request to: " + u.toString()); |
|
2047 |
// use httpclient to set up SSL |
|
2048 |
RestClient client = getSSLClient(); |
|
2049 |
HttpResponse response = client.doGetRequest(u.toString()); |
|
2050 | 2047 |
// get the response content |
2051 |
InputStream input = response.getEntity().getContent();
|
|
2048 |
InputStream input = getURLStream(u);
|
|
2052 | 2049 |
logReplication.info("ReplicationService.getURLContent - After getting response from: " + u.toString()); |
2053 | 2050 |
InputStreamReader istream = new InputStreamReader(input); |
2054 | 2051 |
StringBuffer serverResponse = new StringBuffer(); |
... | ... | |
2063 | 2060 |
} |
2064 | 2061 |
|
2065 | 2062 |
/** |
2063 |
* This method returns the InputStream after opening a url |
|
2064 |
* @param u the url to return the content from |
|
2065 |
* @return a InputStream representing the content of the url |
|
2066 |
* @throws java.io.IOException |
|
2067 |
*/ |
|
2068 |
public static InputStream getURLStream(URL u) throws java.io.IOException { |
|
2069 |
logReplication.info("Getting url stream from " + u.toString()); |
|
2070 |
logReplication.info("ReplicationService.getURLStream - Before sending request to: " + u.toString()); |
|
2071 |
// use httpclient to set up SSL |
|
2072 |
RestClient client = getSSLClient(); |
|
2073 |
HttpResponse response = client.doGetRequest(u.toString()); |
|
2074 |
// get the response content |
|
2075 |
InputStream input = response.getEntity().getContent(); |
|
2076 |
logReplication.info("ReplicationService.getURLStream - After getting response from: " + u.toString()); |
|
2077 |
|
|
2078 |
return input; |
|
2079 |
} |
|
2080 |
|
|
2081 |
/** |
|
2066 | 2082 |
* Sets up an HttpClient with SSL connection. |
2067 | 2083 |
* Sends client certificate to the server when doing the request. |
2068 | 2084 |
* @return |
Also available in: Unified diff
use SSL to get content from stream