Apache/olingo-odata4
1
0
Fork 0
mirror of https://github.com/apache/olingo-odata4.git synced 2025-02-11 04:26:16 +00:00
Code Issues Packages Projects Releases Wiki Activity

[OLINGO-708] Support for async create

Browse Source
This commit is contained in:
Michael Bolz 2015-06-30 08:31:05 +02:00
parent a30fb16f25
commit 2080f23bfa
1 changed files with 43 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

52
lib/server-tecsvc/src/main/java/org/apache/olingo/server/tecsvc/async/AsyncProcessor.java
View File

@ -18,21 +18,31 @@
*/ */
package org.apache.olingo.server.tecsvc.async; package org.apache.olingo.server.tecsvc.async;
import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.lang.reflect.InvocationHandler;
import java.lang.reflect.InvocationTargetException;
import java.lang.reflect.Method;
import java.lang.reflect.Proxy;
import java.nio.ByteBuffer;
import java.nio.channels.Channels;
import java.nio.channels.ReadableByteChannel;
import java.nio.channels.WritableByteChannel;
import java.util.ArrayList;
import java.util.List;
import java.util.Locale;
import java.util.Map;
import org.apache.olingo.commons.api.http.HttpHeader; import org.apache.olingo.commons.api.http.HttpHeader;
import org.apache.olingo.commons.api.http.HttpStatusCode;
import org.apache.olingo.server.api.ODataApplicationException; import org.apache.olingo.server.api.ODataApplicationException;
import org.apache.olingo.server.api.ODataLibraryException; import org.apache.olingo.server.api.ODataLibraryException;
import org.apache.olingo.server.api.ODataRequest; import org.apache.olingo.server.api.ODataRequest;
import org.apache.olingo.server.api.ODataResponse; import org.apache.olingo.server.api.ODataResponse;
import org.apache.olingo.server.api.processor.Processor; import org.apache.olingo.server.api.processor.Processor;
import java.lang.reflect.InvocationHandler;
import java.lang.reflect.InvocationTargetException;
import java.lang.reflect.Method;
import java.lang.reflect.Proxy;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
public class AsyncProcessor<T extends Processor> { public class AsyncProcessor<T extends Processor> {
private final MyInvocationHandler handler; private final MyInvocationHandler handler;
private final TechnicalAsyncService service; private final TechnicalAsyncService service;
@ -140,9 +150,9 @@ public class AsyncProcessor<T extends Processor> {
return handler.process(); return handler.process();
} }
private ODataRequest copyRequest(ODataRequest request) { private ODataRequest copyRequest(ODataRequest request) throws ODataApplicationException {
ODataRequest req = new ODataRequest(); ODataRequest req = new ODataRequest();
req.setBody(request.getBody()); req.setBody(copyRequestBody(request));
req.setMethod(request.getMethod()); req.setMethod(request.getMethod());
req.setRawBaseUri(request.getRawBaseUri()); req.setRawBaseUri(request.getRawBaseUri());
req.setRawODataPath(request.getRawODataPath()); req.setRawODataPath(request.getRawODataPath());
@ -162,6 +172,28 @@ public class AsyncProcessor<T extends Processor> {
return req; return req;
} }
private InputStream copyRequestBody(ODataRequest request) throws ODataApplicationException {
ByteArrayOutputStream buffer = new ByteArrayOutputStream();
InputStream input = request.getBody();
if (input != null) {
try {
ByteBuffer inBuffer = ByteBuffer.allocate(8192);
ReadableByteChannel ic = Channels.newChannel(input);
WritableByteChannel oc = Channels.newChannel(buffer);
while (ic.read(inBuffer) > 0) {
inBuffer.flip();
oc.write(inBuffer);
inBuffer.rewind();
}
return new ByteArrayInputStream(buffer.toByteArray());
} catch (IOException e) {
throw new ODataApplicationException("Error on reading request content",
HttpStatusCode.INTERNAL_SERVER_ERROR.getStatusCode(), Locale.ROOT);
}
}
return null;
}
public String getPreferHeader() { public String getPreferHeader() {
return preferHeader; return preferHeader;
} }