[jira] Commented: (CXF-2589) Allow CXF Bean endpoint to work in asynchronous mode

["Sergey Beryozkin (JIRA)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/CXF-2589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=12795045#action_12795045 ] 

Sergey Beryozkin commented on CXF-2589:
---------------------------------------

Hi Charles,

please see 

http://svn.apache.org/repos/asf/cxf/trunk/systests/jaxrs/src/test/java/org/apache/cxf/systest/jaxrs/BookContinuationStore.java

I'm wondering, can you try to use Continuations explicitly given that getIncidentsAsync() is quite explicit already in the way it uses Futures/etc ?

So you might have a code like this :

private ConcurrentHashMap<Continuation, List<Incident>> incidents = ...

@GET
@Path("/incidents2/")
public Incidents getIncidentsAsync() {

 Continuation c = getContinuation(); 
 synchronized (c) {
    if (c.isNew()) {
        // Call the distant service to get result (ASYNCHR WAY )
        Future future = producer.asyncRequestBody("jms:queue:inout", "GET");
        // this will throw a RuntimeException (SuspendedInvocationException)
        extractFutureBody(c, future);
    }  else if (incidents.containsKey(c))
        // here we also have a choice if suspending the invocation again if some other related information is not ready yet
        return incidents.remove(c);
    } else {
         // here we also have a choice if suspending the invocation again if some other related information is not ready yet, for example, extractFutureBody suspends the invocation for 10001 so in theory the invocation might've come back just a fraction of millisec before the producer has finisehd extracting the body, so here we might give it another try and suspend it again for say another few secs
         return null;
    }
    
 }
 
}

private void doAsyncCall(final Continuation c, final Future f) {

// you might want to have a private executor instead

new Thread(new Runnable() {
 public void run() {
  List<ReportIncident> incidentsList = null;
  try { 
     incidentsList = producer.extractFutureBody(future, 10000,TimeUnit.MILLISECONDS, List.class); 
  } catch (TimeoutException e) { 
     // null
  }
  incidents.put(c, incidentsList);
  // this one will ensure an original suspended invocation will return into getIncidents2()
  c.resume();
 }
}).start();

// this one will throw  a SuspendedInvocationException and ensure it will get back in 10 secs + 1 milli sec
c.suspend(10001);

}

If no cxfcamel (which intercepts a getIncidendtsAsync) were involved then this code would most likely work really well. But cxfcamel might need to be updated a bit to deal with SuspendedInvocationExceptions, probably very similarly to the way ServiceMix CXF BC component has been updated (would be a copy and paste probably), and it would need to be done even when we introduce later on @SuspendedInvocation later on...

Give it a try please and let me know how it goes on - I'm quite sure you will end up opening a Camel CXF JIRA :-) but I'll be excited if it just will work as is in Camel too :-)

cheers, Sergey

> Allow CXF Bean endpoint to work in asynchronous mode
> ----------------------------------------------------
>
>                 Key: CXF-2589
>                 URL: https://issues.apache.org/jira/browse/CXF-2589
>             Project: CXF
>          Issue Type: New Feature
>    Affects Versions: 2.2.5
>            Reporter: Charles Moulliard
>
> The following code does not work :
> 	@GET
> 	@Path("/incidents2/")
> 	public Incidents getIncidentsAsync() {
> 		Incidents l = new Incidents();
> 		// Call the distant service to get result (ASYNCHR WAY )
> 		Future future = producer.asyncRequestBody("jms:queue:inout", "GET");
> 		// Check if we receive a feedback within 10 seconds
> 		List<ReportIncident> i;
> 		try {
> 			i = producer.extractFutureBody(future, 10000,TimeUnit.MILLISECONDS, List.class);
> 		} catch (TimeoutException e) {
> 			return null;
> 		}
> 		l.setIncidents(i);
> 		return l;
> 	}
> because CXF bean endpoint does not allow to work with async process

-- 
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.