org.jboss.resteasy.spi.HttpResponse类的使用及代码示例

x33g5p2x  于2022-01-20 转载在 其他  
字(7.5k)|赞(0)|评价(0)|浏览(103)

本文整理了Java中org.jboss.resteasy.spi.HttpResponse类的一些代码示例,展示了HttpResponse类的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。HttpResponse类的具体详情如下:
包路径:org.jboss.resteasy.spi.HttpResponse
类名称: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();
}

相关文章

微信公众号

最新文章

更多