package org.jboss.resteasy.core;

import org.jboss.resteasy.resteasy_jaxrs.i18n.Messages;
import org.jboss.resteasy.spi.AsynchronousResponse;
import org.jboss.resteasy.spi.HttpRequest;
import org.jboss.resteasy.spi.HttpResponse;
import org.jboss.resteasy.spi.ResteasyAsynchronousContext;
import org.jboss.resteasy.spi.ResteasyAsynchronousResponse;

import javax.ws.rs.core.Response;

Author:Bill Burke
See Also:
Version:$Revision: 1 $
Deprecated:Replaced by org.jboss.resteasy.core.AsynchronousResponseInjector
/** * @author <a href="mailto:bill@burkecentral.com">Bill Burke</a> * @version $Revision: 1 $ * * @deprecated Replaced by org.jboss.resteasy.core.AsynchronousResponseInjector * * @see org.jboss.resteasy.core.AsynchronousResponseInjector */
@Deprecated public class SuspendInjector implements ValueInjector { private long suspend; public SuspendInjector(final long suspend, final Class type) { if (!type.equals(AsynchronousResponse.class)) throw new IllegalArgumentException(Messages.MESSAGES.notValidInjectableType(type.getName())); this.suspend = suspend; } public Object inject() { throw new IllegalStateException(Messages.MESSAGES.cannotInjectIntoForm()); } public Object inject(HttpRequest request, HttpResponse response) { final ResteasyAsynchronousContext asynchronousContext = request.getAsyncContext(); final ResteasyAsynchronousResponse asynchronousResponse = asynchronousContext.suspend(suspend); ResourceMethodInvoker invoker = (ResourceMethodInvoker)request.getAttribute(ResourceMethodInvoker.class.getName()); invoker.initializeAsync(asynchronousResponse); return new AsynchronousResponse() { @Override public void setResponse(Response response) { asynchronousResponse.resume(response); } }; } }