本文整理了Java中org.jboss.resteasy.spi.HttpResponse
类的一些代码示例,展示了HttpResponse
类的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。HttpResponse
类的具体详情如下:
包路径:org.jboss.resteasy.spi.HttpResponse
类名称:HttpResponse
[英]Bridge interface between the base Resteasy JAX-RS implementation and the actual HTTP transport (i.e. a servlet container)
[中]基本Resteasy JAX-RS实现与实际HTTP传输(即servlet容器)之间的桥接接口
代码示例来源:origin: resteasy/Resteasy
public void unhandledAsynchronousException(HttpResponse response, Throwable ex) {
LogMessages.LOGGER.unhandledAsynchronousException(ex);
// unhandled exceptions need to be processed as they can't be thrown back to the servlet container
if (!response.isCommitted()) {
try
{
response.reset();
response.sendError(500);
}
catch (IOException e)
{
}
}
}
代码示例来源:origin: resteasy/Resteasy
ResteasyProviderFactory.getInstance(), t -> {
}, true);
response.getOutputStream().write(SseConstants.EOL);
response.getOutputStream().write(SseConstants.EOL);
response.flushBuffer();
responseFlushed = true;
代码示例来源:origin: resteasy/Resteasy
public void doWrite(Object toOutput, Class type, Type genericType,
MediaType mediaType, Annotation[] annotations,
MultivaluedMap<String, Object> requestHeaders,
OutputStream outputStream) throws IOException
{
final Map<String, Object> attributes = new HashMap<String, Object>();
AbstractWriterInterceptorContext messageBodyWriterContext = new ClientWriterInterceptorContext(interceptors, factory, toOutput, type,
genericType, annotations, mediaType, requestHeaders, outputStream, attributes);
messageBodyWriterContext
.proceed();
}
代码示例来源:origin: resteasy/Resteasy
String id = "" + System.currentTimeMillis() + "-" + counter.nextInt();
jobs.put(id, future);
response.setStatus(HttpResponseCodes.SC_ACCEPTED);
URI uri = request.getUri().getBaseUriBuilder().path(basePath).path(id).build();
response.getOutputHeaders().add(HttpHeaderNames.LOCATION, uri);
代码示例来源:origin: resteasy/Resteasy
} catch (SecurityException e)
response.sendError(HttpResponseCodes.SC_UNAUTHORIZED);
return null;
response.sendError(HttpResponseCodes.SC_UNAUTHORIZED);
return null;
代码示例来源:origin: resteasy/Resteasy
if (entity == null || response.getOutputStream() == null)
response.setStatus(jaxrsResponse.getStatus());
commitHeaders(jaxrsResponse, response);
return;
response.setStatus(jaxrsResponse.getStatus());
final BuiltResponse built = jaxrsResponse;
CommitHeaderOutputStream.CommitCallback callback = new CommitHeaderOutputStream.CommitCallback()
OutputStream os = sendHeaders ? new CommitHeaderOutputStream(response.getOutputStream(), callback) : response.getOutputStream();
response.setOutputStream(writerContext.getOutputStream()); //propagate interceptor changes on the outputstream to the response
代码示例来源:origin: resteasy/Resteasy
if (mediaType == null || !mediaTypeSet)
Object o = response.getOutputHeaders().getFirst("Content-Type");
if (o != null)
response.getOutputStream().write(bout.toByteArray());
response.flushBuffer();
代码示例来源:origin: resteasy/Resteasy
@Override
public OutputStream getEntityStream()
{
try
{
return httpResponse.getOutputStream();
}
catch (IOException e)
{
throw new RuntimeException(e);
}
}
代码示例来源:origin: resteasy/Resteasy
response.addNewCookie(cookie);
it.remove();
response.getOutputHeaders().add(javax.ws.rs.core.HttpHeaders.SET_COOKIE, next);
it.remove();
&& jaxrsResponse.getMetadata().size() > 0)
response.getOutputHeaders().putAll(jaxrsResponse.getMetadata());
代码示例来源:origin: weibocom/motan
@Override
public Object invoke(HttpRequest request, HttpResponse httpResponse, Object resource)
throws Failure, ApplicationException {
if (!Provider.class.isInstance(resource)) {
return super.invoke(request, httpResponse, resource);
}
Object[] args = injectArguments(request, httpResponse);
RestfulContainerRequest req = new RestfulContainerRequest();
req.setInterfaceName(method.getResourceClass().getClazz().getName());
req.setMethodName(method.getMethod().getName());
req.setParamtersDesc(ReflectUtil.getMethodParamDesc(method.getMethod()));
req.setArguments(args);
req.setHttpRequest(request);
req.setAttachments(RestfulUtil.decodeAttachments(request.getMutableHeaders()));
try {
Response resp = Provider.class.cast(resource).call(req);
RestfulUtil.encodeAttachments(httpResponse.getOutputHeaders(), resp.getAttachments());
return resp.getValue();
} catch (Exception e) {
if (e != null && e instanceof RuntimeException) {
throw (RuntimeException) e;
}
throw new InternalServerErrorException("provider call process error:" + e.getMessage(), e);
}
}
代码示例来源:origin: resteasy/Resteasy
if (response.isCommitted())
if (!bufferExceptionEntity)
response.getOutputHeaders().add("resteasy.buffer.exception.entity", "false");
} finally {
RESTEasyTracingLogger tracingLogger = RESTEasyTracingLogger.getInstance(request);
tracingLogger.log("FINISHED", response.getStatus());
tracingLogger.flush(response.getOutputHeaders());
代码示例来源:origin: stackoverflow.com
@RequestMapping...
public void getFile(HttpResponse resp) throws IOException {
InputStream is = ... // get InputStream from your file
resp.setContentType("text/html"); // or whatever is appropriate for your file
OutputStream os = resp.getOutputStream();
// now read from one stream and write to the other
byte[] buffer = new byte[1024];
int len = in.read(buffer);
while (len != -1) {
out.write(buffer, 0, len);
len = in.read(buffer);
}
}
代码示例来源:origin: resteasy/Resteasy
protected void writeResponse(HttpRequest request, HttpResponse response, Response jaxrsResponse)
{
try
{
ServerResponseWriter.writeNomapResponse((BuiltResponse) jaxrsResponse, request, response, providerFactory,
t -> {
if(t != null)
writeException(request, response, t, t2 -> {});
});
}
catch (Exception e)
{
//logger.error("writeResponse() failed mapping exception", e);
writeException(request, response, e, t -> {});
}
finally {
RESTEasyTracingLogger tracingLogger = RESTEasyTracingLogger.getInstance(request);
tracingLogger.log("FINISHED", response.getStatus());
tracingLogger.flush(response.getOutputHeaders());
}
}
代码示例来源:origin: resteasy/Resteasy
@Override
public void onTimeout(AsyncEvent asyncEvent) throws IOException
{
LogMessages.LOGGER.debug(Messages.MESSAGES.onTimeout());
synchronized (responseLock)
{
if (done || cancelled) return;
response.reset();
handleTimeout();
}
}
代码示例来源:origin: org.jboss.resteasy/resteasy-jaxrs-20
if (response.isCommitted())
if (!bufferExceptionEntity)
response.getOutputHeaders().add("resteasy.buffer.exception.entity", "false");
代码示例来源:origin: resteasy/Resteasy
@Override
public void setEntityStream(OutputStream entityStream)
{
httpResponse.setOutputStream(entityStream);
}
代码示例来源:origin: resteasy/Resteasy
response.sendError(HttpResponseCodes.SC_UNAUTHORIZED);
return null;
response.sendError(HttpResponseCodes.SC_UNAUTHORIZED);
return null;
代码示例来源:origin: org.jboss.resteasy/resteasy-jaxrs-20
if (jaxrsResponse.getEntity() == null || response.getOutputStream() == null)
response.setStatus(jaxrsResponse.getStatus());
commitHeaders(jaxrsResponse, response);
return;
response.setStatus(jaxrsResponse.getStatus());
final BuiltResponse built = jaxrsResponse;
CommitHeaderOutputStream.CommitCallback callback = new CommitHeaderOutputStream.CommitCallback()
OutputStream os = sendHeaders ? new CommitHeaderOutputStream(response.getOutputStream(), callback) : response.getOutputStream();
writerContext.proceed();
if(sendHeaders) {
response.setOutputStream(writerContext.getOutputStream()); //propagate interceptor changes on the outputstream to the response
代码示例来源:origin: org.jboss.resteasy/resteasy-core
if (mediaType == null || !mediaTypeSet)
Object o = response.getOutputHeaders().getFirst("Content-Type");
if (o != null)
response.getOutputStream().write(bout.toByteArray());
response.flushBuffer();
代码示例来源:origin: resteasy/Resteasy
default void close() throws IOException {
// RESTEASY-1650
getOutputStream().close();
}
内容来源于网络,如有侵权,请联系作者删除!