[CXF-6389] set initialSuspend=true incorrectly when resume the asyncresponse

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 3.0, 3.0.3, 2.7.15
• Fix Version/s: 3.1.1, 3.0.6
• Component/s: JAX-RS
• Estimated Complexity: Unknown
• Flags: Patch
• Assignee: Sergey Beryozkin
• Reporter: Iris Ding
• Created: 05/May/15 06:15
• Updated: 14/Oct/16 14:25
• Resolved: 07/May/15 11:54

Description

My Resource class:
@Path("resource")
public class Resource
{

public static final String RESUMED = "Response resumed";
public static final String FALSE = "A method returned false";
public static final String TRUE = "A method return true";

//
private static final AsyncResponseBlockingQueue[] stage =

{ new AsyncResponseBlockingQueue(1), new AsyncResponseBlockingQueue(1), new AsyncResponseBlockingQueue(1)}

;

@GET
@Path("suspend")
public void suspend(@Suspended AsyncResponse asyncResponse)

{ stage[0].add(asyncResponse); }

@GET
@Path("cancelvoid")
public String cancel(@QueryParam("stage") String stage)

{ AsyncResponse response = takeAsyncResponse(stage); boolean ret = response.cancel(); System.out.println("*** response.cancel() 1 " + ret); ret &= response.cancel(); System.out.println("*** response.cancel() 2 " + ret); addResponse(response, stage); return ret ? TRUE : FALSE; }

@POST
@Path("resume")
public String resume(@QueryParam("stage") String stage, String response)

{ AsyncResponse async = takeAsyncResponse(stage); boolean b = resume(async, response); addResponse(async, stage); return b ? TRUE : FALSE; }

protected static AsyncResponse takeAsyncResponse(String stageId)

{ return takeAsyncResponse(Integer.parseInt(stageId)); }

protected static AsyncResponse takeAsyncResponse(int stageId)
{
final ResponseBuilder error = createErrorResponseBuilder();
AsyncResponse asyncResponse = null;
try

{ asyncResponse = stage[stageId].take(); }

catch (InterruptedException e)

{ throw new WebApplicationException(error.entity( "ArrayBlockingQueue#take").build()); }

return asyncResponse;
}

protected static final void addResponse(AsyncResponse response, String stageId)

{ int id = Integer.parseInt(stageId) + 1; if (id != stage.length) stage[id].add(response); }

protected static boolean resume(AsyncResponse takenResponse, Object response)

{ return takenResponse.resume(response); }

protected static ResponseBuilder createErrorResponseBuilder()

{ return Response.status(Status.EXPECTATION_FAILED); }

}