[REEF-1661] RejectedExecutionException thrown when closing the acceptor in NettyMessageTransport
diff --git a/lang/java/reef-io/src/test/java/org/apache/reef/io/network/util/NetworkMessagingTestService.java b/lang/java/reef-io/src/test/java/org/apache/reef/io/network/util/NetworkMessagingTestService.java
index 92e4980..59fd0c8 100644
--- a/lang/java/reef-io/src/test/java/org/apache/reef/io/network/util/NetworkMessagingTestService.java
+++ b/lang/java/reef-io/src/test/java/org/apache/reef/io/network/util/NetworkMessagingTestService.java
@@ -23,7 +23,6 @@
import org.apache.reef.io.network.Message;
import org.apache.reef.io.network.NetworkConnectionService;
import org.apache.reef.io.network.impl.config.NetworkConnectionServiceIdFactory;
-import org.apache.reef.io.network.naming.NameResolver;
import org.apache.reef.io.network.naming.NameResolverConfiguration;
import org.apache.reef.io.network.naming.NameServer;
import org.apache.reef.tang.Configuration;
@@ -51,8 +50,6 @@
private final NetworkConnectionService receiverNetworkConnService;
private final NetworkConnectionService senderNetworkConnService;
private final NameServer nameServer;
- private final NameResolver receiverResolver;
- private final NameResolver senderResolver;
public NetworkMessagingTestService(final String localAddress) throws InjectionException {
// name server
@@ -67,14 +64,12 @@
// network service for receiver
final Injector injectorReceiver = injector.forkInjector(netConf);
this.receiverNetworkConnService = injectorReceiver.getInstance(NetworkConnectionService.class);
- this.receiverResolver = injectorReceiver.getInstance(NameResolver.class);
this.factory = injectorReceiver.getNamedInstance(NetworkConnectionServiceIdFactory.class);
// network service for sender
LOG.log(Level.FINEST, "=== Test network connection service sender start");
final Injector injectorSender = injector.forkInjector(netConf);
senderNetworkConnService = injectorSender.getInstance(NetworkConnectionService.class);
- this.senderResolver = injectorSender.getInstance(NameResolver.class);
}
public <T> void registerTestConnectionFactory(final Identifier connFactoryId,
@@ -101,8 +96,6 @@
senderNetworkConnService.close();
receiverNetworkConnService.close();
nameServer.close();
- receiverResolver.close();
- senderResolver.close();
}
public static final class MessageHandler<T> implements EventHandler<Message<T>> {
