[CXF-6373] CompletionCallback can not get the Throwable if error occurs in other interceptor (no serviceinvokerInterceptor)

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 3.0.3, 3.0.4, 2.7.15
• Fix Version/s: 3.1, 3.0.5
• Component/s: JAX-RS
• Estimated Complexity: Unknown
• Assignee: Sergey Beryozkin
• Reporter: Iris Ding
• Created: 26/Apr/15 02:10
• Updated: 14/Oct/16 14:24
• Resolved: 27/Apr/15 09:35

Description

//Resource class
@Path("resource")
public class Resource {

private static final AsyncResponseBlockingQueue[] step =

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

;

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

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

@GET
@Path("register")
public String registerObject(@QueryParam("step") String step)

{ AsyncResponse async = takeAsyncResponse(step); boolean b = async.register(new MyCompletionCallback()).isEmpty(); addResponse(async, step); return b ? TRUE : FALSE; }

@GET
@Path("exception")
public String throwExceptionOnAsyncResponse(
@QueryParam("step") String step)

{ System.out.println("********throwExceptionOnAsyncResponse"); AsyncResponse async = takeAsyncResponse(step); System.out.println("*****async is not null: " + async); boolean b = async.resume(new ExceptionThrowingStringBean( "throw exception")); System.out.println("execuet finished for resume!!!"); addResponse(async, step); return b ? TRUE : FALSE; }

}

/////// StringBean
public class StringBean {
private String header;

public String get()

{ return header; }

public void set(String header)

{ this.header = header; }

@Override
public String toString()

{ return "StringBean. To get a value, use rather #get() method."; }

public StringBean(String header)

{ super(); this.header = header; }

}
/////// Throw Exception here
public class ExceptionThrowingStringBean extends StringBean {
public ExceptionThrowingStringBean(String header)

{ super(header); }

@Override
public String get()

{ throw new RuntimeException(new IOException(super.get())); }

}

////// Register a provider to deal with StringBean,
// This cause we have an exception thrown in JaxrsOutInterceptor

@Provider
public class StringBeanEntityProvider implements MessageBodyReader<StringBean>,
MessageBodyWriter<StringBean> {

@Override
public boolean isWriteable(Class<?> type, Type genericType,
Annotation[] annotations, MediaType mediaType)

{ return StringBean.class.isAssignableFrom(type); }

@Override
public long getSize(StringBean t, Class<?> type, Type genericType,
Annotation[] annotations, MediaType mediaType)

{ return t.get().length(); }

@Override
public void writeTo(StringBean t, Class<?> type, Type genericType,
Annotation[] annotations, MediaType mediaType,
MultivaluedMap<String, Object> httpHeaders,
OutputStream entityStream) throws IOException,
WebApplicationException

{ entityStream.write(t.get().getBytes()); }

@Override
public boolean isReadable(Class<?> type, Type genericType,
Annotation[] annotations, MediaType mediaType)

{ return isWriteable(type, genericType, annotations, mediaType); }

@Override
public StringBean readFrom(Class<StringBean> type, Type genericType,
Annotation[] annotations, MediaType mediaType,
MultivaluedMap<String, String> httpHeaders, InputStream entityStream)
throws IOException, WebApplicationException

{ String stream = JaxrsUtil.readFromStream(entityStream); StringBean bean = new StringBean(stream); return bean; }

}

////// Need to get the exception throwed from ExceptionThrowingStringBean.get() method in this callback

public class MyCompletionCallback implements CompletionCallback {

private static String throwableName;
public static final String NULL = "NULL";
public static final String NONAME = "No name has been set yet";

@Override
public void onComplete(Throwable throwable)

{ throwableName = throwable == null ? NULL : throwable.getClass() .getName(); }

public static final String getLastThrowableName()

{ return throwableName; }

public static final void resetLastThrowableName()

{ throwableName = NONAME; }

}