[infinispan-issues] [JBoss JIRA] (ISPN-1541) NotifyingNotifiableFuture's FutureListener can not invoke Future API on FutureListener#futureDone callback

[Vladimir Blagojevic (Updated) (JIRA)]

     [ https://issues.jboss.org/browse/ISPN-1541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Vladimir Blagojevic updated ISPN-1541:
--------------------------------------

    Git Pull Request: https://github.com/infinispan/infinispan/pull/660  (was: https://github.com/infinispan/infinispan/pull/660)
         Description: 
Invoking Future#get from a FutureListener attached to a NotifyingNotifiableFuture passed as a parameter to RpcManager#invokeRemotelyInFuture throws InterruptedException! Sounds more complicated than it really is! In another words, the following code throws InterruptedException 

{code}NotifyingFutureImpl f = ...
      f.attachListener(new FutureListener<Object>() {
         
         @Override
         public void futureDone(Future<Object> future) {
            try {      
               future.get();
            } catch (Exception e) {   
               e.printStackTrace();
            }             
         }
      });
      CommandsFactory cf = cache1.getAdvancedCache().getComponentRegistry().getComponent(CommandsFactory.class);
      cache1.getAdvancedCache().getRpcManager().invokeRemotelyInFuture(null, cf.buildPutKeyValueCommand("k","v", -1, -1, null), f);
{code}

  was:
Invoking Future#get from a FutureListener attached to a NotifyingNotifiableFuture passed as a parameter to RpcManager#invokeRemotelyInFuture throws InterruptedException!

{code}NotifyingFutureImpl f = ...
      f.attachListener(new FutureListener<Object>() {
         
         @Override
         public void futureDone(Future<Object> future) {
            try {      
               future.get();
            } catch (Exception e) {   
               e.printStackTrace();
            }             
         }
      });
      CommandsFactory cf = cache1.getAdvancedCache().getComponentRegistry().getComponent(CommandsFactory.class);
      cache1.getAdvancedCache().getRpcManager().invokeRemotelyInFuture(null, cf.buildPutKeyValueCommand("k","v", -1, -1, null), f);
{code}


    
> NotifyingNotifiableFuture's FutureListener can not invoke Future API on FutureListener#futureDone callback
> ----------------------------------------------------------------------------------------------------------
>
>                 Key: ISPN-1541
>                 URL: https://issues.jboss.org/browse/ISPN-1541
>             Project: Infinispan
>          Issue Type: Bug
>          Components: RPC
>    Affects Versions: 5.0.1.FINAL, 5.1.0.BETA4
>            Reporter: Vladimir Blagojevic
>            Assignee: Vladimir Blagojevic
>             Fix For: 5.1.0.FINAL
>
>
> Invoking Future#get from a FutureListener attached to a NotifyingNotifiableFuture passed as a parameter to RpcManager#invokeRemotelyInFuture throws InterruptedException! Sounds more complicated than it really is! In another words, the following code throws InterruptedException 
> {code}NotifyingFutureImpl f = ...
>       f.attachListener(new FutureListener<Object>() {
>          
>          @Override
>          public void futureDone(Future<Object> future) {
>             try {      
>                future.get();
>             } catch (Exception e) {   
>                e.printStackTrace();
>             }             
>          }
>       });
>       CommandsFactory cf = cache1.getAdvancedCache().getComponentRegistry().getComponent(CommandsFactory.class);
>       cache1.getAdvancedCache().getRpcManager().invokeRemotelyInFuture(null, cf.buildPutKeyValueCommand("k","v", -1, -1, null), f);
> {code}

--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.jboss.org/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira