Unnecessary AtomicReference

neo4j · Feb 1, 2018 · e3f6eb1 · e3f6eb1
1 parent e42b622
commit e3f6eb1
Showing 1 changed file with 3 additions and 4 deletions.
diff --git a/...e/causal-clustering/src/main/java/org/neo4j/causalclustering/messaging/SenderService.java b/...e/causal-clustering/src/main/java/org/neo4j/causalclustering/messaging/SenderService.java
@@ -21,7 +21,6 @@
 
 import java.util.Iterator;
 import java.util.concurrent.CompletableFuture;
-import java.util.concurrent.atomic.AtomicReference;
 import java.util.concurrent.locks.ReadWriteLock;
 import java.util.concurrent.locks.ReentrantReadWriteLock;
 
@@ -62,7 +61,7 @@ public SenderService( ChannelInitializer channelInitializer, LogProvider logProv
     @Override
     public void send( AdvertisedSocketAddress to, Message message, boolean block )
     {
-        AtomicReference<CompletableFuture<Void>> future = new AtomicReference<>( new CompletableFuture<>() );
+        CompletableFuture<Void> future;
         serviceLock.readLock().lock();
         try
         {
@@ -73,7 +72,7 @@ public void send( AdvertisedSocketAddress to, Message message, boolean block )
 
             Channel channel = channel( to );
 
-            future.set( channel.writeAndFlush( message ) );
+            future = channel.writeAndFlush( message );
         }
         finally
         {
@@ -82,7 +81,7 @@ public void send( AdvertisedSocketAddress to, Message message, boolean block )
 
         if ( block )
         {
-            future.get().join();
+            future.join();
         }
     }