client ordered event execution minor fix

hazelcast · Sep 1, 2014 · 12aeeca · 12aeeca
1 parent 1a95801
commit 12aeeca
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/hazelcast-client/src/main/java/com/hazelcast/client/spi/impl/ClientListenerServiceImpl.java b/hazelcast-client/src/main/java/com/hazelcast/client/spi/impl/ClientListenerServiceImpl.java
@@ -16,6 +16,7 @@
 import com.hazelcast.nio.serialization.SerializationService;
 import com.hazelcast.util.ExceptionUtil;
 import com.hazelcast.util.executor.StripedExecutor;
+import com.hazelcast.util.executor.StripedRunnable;
 
 import java.util.Collections;
 import java.util.Iterator;
@@ -127,7 +128,7 @@ public void shutdown() {
         eventExecutor.shutdown();
     }
 
-    private final class ClientEventProcessor implements Runnable {
+    private final class ClientEventProcessor implements StripedRunnable {
         final Packet packet;
 
         private ClientEventProcessor(Packet packet) {
@@ -152,5 +153,10 @@ private void handleEvent(Data event, int callId, ClientConnection conn) {
             }
             eventHandler.handle(eventObject);
         }
+
+        @Override
+        public int getKey() {
+            return packet.getPartitionId();
+        }
     }
 }