Fix Cache Removal listener

- Removal lister will be called even if the entry was manually
  invalidated. Timeout handler should check for the cause.

Note: In both of the cases fixed in this patch, Future should silently ignore
  setException, external behavior-wise no change by this patch.

Change-Id: Id46f23c9ff8dfa607874cfd94807000f03a95b31

@@ -312,9 +312,11 @@ public class SimpleFlowRuleStore
         @Override
         @Override
         public void onRemoval(RemovalNotification<Integer, SettableFuture<CompletedBatchOperation>> notification) {
         public void onRemoval(RemovalNotification<Integer, SettableFuture<CompletedBatchOperation>> notification) {
             // wrapping in ExecutionException to support Future.get
             // wrapping in ExecutionException to support Future.get
+            if (notification.wasEvicted()) {
                 notification.getValue()
                 notification.getValue()
                     .setException(new ExecutionException("Timed out",
                     .setException(new ExecutionException("Timed out",
                                                      new TimeoutException()));
                                                      new TimeoutException()));
             }
             }
         }
         }
+    }
 }
 }

@@ -72,8 +72,10 @@ public class NettyMessagingService implements MessagingService {
             .removalListener(new RemovalListener<Long, SettableFuture<byte[]>>() {
             .removalListener(new RemovalListener<Long, SettableFuture<byte[]>>() {
                 @Override
                 @Override
                 public void onRemoval(RemovalNotification<Long, SettableFuture<byte[]>> entry) {
                 public void onRemoval(RemovalNotification<Long, SettableFuture<byte[]>> entry) {
+                    if (entry.wasEvicted()) {
                         entry.getValue().setException(new TimeoutException("Timedout waiting for reply"));
                         entry.getValue().setException(new TimeoutException("Timedout waiting for reply"));
                     }
                     }
+                }
             })
             })
             .build();
             .build();
     private final GenericKeyedObjectPool<Endpoint, Channel> channels
     private final GenericKeyedObjectPool<Endpoint, Channel> channels