diff --git a/java/com.sap.sse.replication/src/com/sap/sse/replication/impl/ReplicationReceiver.java b/java/com.sap.sse.replication/src/com/sap/sse/replication/impl/ReplicationReceiver.java
index 7bb7352a7fa..f391ea47be2 100755
--- a/java/com.sap.sse.replication/src/com/sap/sse/replication/impl/ReplicationReceiver.java
+++ b/java/com.sap.sse.replication/src/com/sap/sse/replication/impl/ReplicationReceiver.java
@@ -298,12 +298,7 @@ public class ReplicationReceiver implements Runnable {
     }
     
     private synchronized <S, O extends OperationWithResult<S, ?>> void apply(final OperationWithResult<S, ?> operation, Replicable<S, O> replicable) {
-        Runnable runnable = new Runnable() {
-            @Override
-            public void run() {
-                replicable.applyReceivedReplicated(operation);
-            }
-        };
+        Runnable runnable = () -> replicable.applyReceivedReplicated(operation);
         if (operation.requiresSynchronousExecution()) {
             runnable.run();
         } else {