diff --git a/akka-remote/src/main/scala/akka/remote/AccrualFailureDetector.scala b/akka-remote/src/main/scala/akka/remote/AccrualFailureDetector.scala index 0e653819ee..af74c82040 100644 --- a/akka-remote/src/main/scala/akka/remote/AccrualFailureDetector.scala +++ b/akka-remote/src/main/scala/akka/remote/AccrualFailureDetector.scala @@ -11,8 +11,6 @@ import scala.annotation.tailrec import System.{ currentTimeMillis ⇒ newTimestamp } -import akka.actor.ActorSystem - /** * Implementation of 'The Phi Accrual Failure Detector' by Hayashibara et al. as defined in their paper: * [http://ddg.jaist.ac.jp/pub/HDY+04.pdf] diff --git a/akka-remote/src/main/scala/akka/remote/Gossiper.scala b/akka-remote/src/main/scala/akka/remote/Gossiper.scala index 2ff25df939..6cdea287d4 100644 --- a/akka-remote/src/main/scala/akka/remote/Gossiper.scala +++ b/akka-remote/src/main/scala/akka/remote/Gossiper.scala @@ -9,7 +9,6 @@ import akka.actor.Status._ import akka.event.Logging import akka.util.Duration import akka.config.ConfigurationException -import akka.serialization.SerializationExtension import java.util.concurrent.atomic.AtomicReference import java.util.concurrent.TimeUnit.SECONDS @@ -19,7 +18,6 @@ import System.{ currentTimeMillis ⇒ newTimestamp } import scala.collection.immutable.Map import scala.annotation.tailrec -import com.google.protobuf.ByteString import java.util.concurrent.TimeoutException import akka.dispatch.Await import akka.pattern.ask diff --git a/akka-remote/src/main/scala/akka/remote/NetworkEventStream.scala b/akka-remote/src/main/scala/akka/remote/NetworkEventStream.scala index c108b54ae7..4fb970262a 100644 --- a/akka-remote/src/main/scala/akka/remote/NetworkEventStream.scala +++ b/akka-remote/src/main/scala/akka/remote/NetworkEventStream.scala @@ -5,9 +5,7 @@ package akka.remote import scala.collection.mutable -import akka.actor.{ LocalActorRef, Actor, ActorRef, Props, newUuid } -import akka.actor.Actor._ -import akka.actor.ActorSystemImpl +import akka.actor.{ Actor, Props, ActorSystemImpl } /** * Stream of all kinds of network events, remote failure and connection events, cluster failure and connection events etc. diff --git a/akka-remote/src/main/scala/akka/remote/Remote.scala b/akka-remote/src/main/scala/akka/remote/Remote.scala index 923ccdc85d..03479e6ee4 100644 --- a/akka-remote/src/main/scala/akka/remote/Remote.scala +++ b/akka-remote/src/main/scala/akka/remote/Remote.scala @@ -7,9 +7,7 @@ package akka.remote import akka.actor._ import akka.event._ import akka.util._ -import akka.util.duration._ -import akka.util.Helpers._ -import akka.serialization.{ JavaSerializer, Serialization, SerializationExtension } +import akka.serialization.{ Serialization, SerializationExtension } import akka.dispatch.MessageDispatcher import akka.dispatch.SystemMessage import scala.annotation.tailrec diff --git a/akka-remote/src/main/scala/akka/remote/RemoteActorRefProvider.scala b/akka-remote/src/main/scala/akka/remote/RemoteActorRefProvider.scala index 378d82096b..d8cebe9c31 100644 --- a/akka-remote/src/main/scala/akka/remote/RemoteActorRefProvider.scala +++ b/akka-remote/src/main/scala/akka/remote/RemoteActorRefProvider.scala @@ -6,16 +6,9 @@ package akka.remote import akka.actor._ import akka.dispatch._ -import akka.util.duration._ -import akka.util.Timeout -import akka.config.ConfigurationException import akka.event.{ DeathWatch, Logging } -import akka.serialization.Compression.LZF -import com.google.protobuf.ByteString import akka.event.EventStream -import akka.dispatch.Promise import akka.config.ConfigurationException -import java.util.concurrent.{ TimeoutException } /** * Remote ActorRefProvider. Starts up actor on remote node and creates a RemoteActorRef representing it. diff --git a/akka-remote/src/main/scala/akka/remote/RemoteConnectionManager.scala b/akka-remote/src/main/scala/akka/remote/RemoteConnectionManager.scala index deed34521a..43c07e6968 100644 --- a/akka-remote/src/main/scala/akka/remote/RemoteConnectionManager.scala +++ b/akka-remote/src/main/scala/akka/remote/RemoteConnectionManager.scala @@ -6,7 +6,6 @@ package akka.remote import akka.actor._ import akka.routing._ -import akka.actor.ActorSystem import akka.event.Logging import scala.collection.immutable.Map diff --git a/akka-remote/src/main/scala/akka/remote/RemoteInterface.scala b/akka-remote/src/main/scala/akka/remote/RemoteInterface.scala index a5474ce427..3f212f51f5 100644 --- a/akka-remote/src/main/scala/akka/remote/RemoteInterface.scala +++ b/akka-remote/src/main/scala/akka/remote/RemoteInterface.scala @@ -7,13 +7,10 @@ package akka.remote import akka.actor._ import akka.AkkaException import scala.reflect.BeanProperty -import java.io.{ PrintWriter, PrintStream } -import java.net.InetSocketAddress import java.net.URI import java.net.URISyntaxException import java.net.InetAddress import java.net.UnknownHostException -import java.net.UnknownServiceException import akka.event.Logging /** diff --git a/akka-remote/src/main/scala/akka/remote/RemoteSettings.scala b/akka-remote/src/main/scala/akka/remote/RemoteSettings.scala index 8a9a55a679..a1227ff69c 100644 --- a/akka-remote/src/main/scala/akka/remote/RemoteSettings.scala +++ b/akka-remote/src/main/scala/akka/remote/RemoteSettings.scala @@ -8,7 +8,6 @@ import akka.util.Duration import java.util.concurrent.TimeUnit.MILLISECONDS import java.net.InetAddress import akka.config.ConfigurationException -import com.eaio.uuid.UUID import scala.collection.JavaConverters._ class RemoteSettings(val config: Config, val systemName: String) { diff --git a/akka-remote/src/main/scala/akka/remote/netty/NettyRemoteSupport.scala b/akka-remote/src/main/scala/akka/remote/netty/NettyRemoteSupport.scala index 4e80c84fb5..b962426577 100644 --- a/akka-remote/src/main/scala/akka/remote/netty/NettyRemoteSupport.scala +++ b/akka-remote/src/main/scala/akka/remote/netty/NettyRemoteSupport.scala @@ -4,7 +4,7 @@ package akka.remote.netty -import akka.actor.{ ActorRef, IllegalActorStateException, simpleName } +import akka.actor.{ ActorRef, simpleName } import akka.remote._ import RemoteProtocol._ import akka.util._ @@ -25,7 +25,6 @@ import akka.actor.ActorSystemImpl import org.jboss.netty.handler.execution.{ ExecutionHandler, OrderedMemoryAwareThreadPoolExecutor } import java.util.concurrent._ import locks.ReentrantReadWriteLock -import akka.dispatch.MonitorableThreadFactory class RemoteClientMessageBufferException(message: String, cause: Throwable = null) extends AkkaException(message, cause) { def this(msg: String) = this(msg, null) diff --git a/akka-remote/src/multi-jvm/scala/akka/remote/DirectRoutedRemoteActorMultiJvmSpec.scala b/akka-remote/src/multi-jvm/scala/akka/remote/DirectRoutedRemoteActorMultiJvmSpec.scala index bbf653a808..57c949a655 100644 --- a/akka-remote/src/multi-jvm/scala/akka/remote/DirectRoutedRemoteActorMultiJvmSpec.scala +++ b/akka-remote/src/multi-jvm/scala/akka/remote/DirectRoutedRemoteActorMultiJvmSpec.scala @@ -1,11 +1,8 @@ package akka.remote -import akka.remote._ -import akka.routing._ import akka.actor.{ Actor, Props } import akka.testkit._ import akka.dispatch.Await -import akka.pattern.ask object DirectRoutedRemoteActorMultiJvmSpec extends AbstractRemoteActorMultiJvmSpec { override def NrOfNodes = 2 diff --git a/akka-remote/src/multi-jvm/scala/akka/remote/NewRemoteActorMultiJvmSpec.scala b/akka-remote/src/multi-jvm/scala/akka/remote/NewRemoteActorMultiJvmSpec.scala index 985e8bf835..563fbc4049 100644 --- a/akka-remote/src/multi-jvm/scala/akka/remote/NewRemoteActorMultiJvmSpec.scala +++ b/akka-remote/src/multi-jvm/scala/akka/remote/NewRemoteActorMultiJvmSpec.scala @@ -1,12 +1,8 @@ package akka.remote import akka.actor.{ Actor, Props } -import akka.remote._ -import akka.routing._ import akka.testkit._ -import akka.util.duration._ import akka.dispatch.Await -import akka.pattern.ask object NewRemoteActorMultiJvmSpec extends AbstractRemoteActorMultiJvmSpec { override def NrOfNodes = 2 diff --git a/akka-remote/src/multi-jvm/scala/akka/remote/RandomRoutedRemoteActorMultiJvmSpec.scala b/akka-remote/src/multi-jvm/scala/akka/remote/RandomRoutedRemoteActorMultiJvmSpec.scala index 2c2f0c154f..3e1339b8d4 100644 --- a/akka-remote/src/multi-jvm/scala/akka/remote/RandomRoutedRemoteActorMultiJvmSpec.scala +++ b/akka-remote/src/multi-jvm/scala/akka/remote/RandomRoutedRemoteActorMultiJvmSpec.scala @@ -1,11 +1,9 @@ package akka.remote import akka.actor.{ Actor, Props } -import akka.remote._ import akka.routing._ import akka.testkit.DefaultTimeout import akka.dispatch.Await -import akka.pattern.ask object RandomRoutedRemoteActorMultiJvmSpec extends AbstractRemoteActorMultiJvmSpec { override def NrOfNodes = 4 diff --git a/akka-remote/src/multi-jvm/scala/akka/remote/RoundRobinRoutedRemoteActorMultiJvmSpec.scala b/akka-remote/src/multi-jvm/scala/akka/remote/RoundRobinRoutedRemoteActorMultiJvmSpec.scala index f8ae8f635c..7a7b6dce95 100644 --- a/akka-remote/src/multi-jvm/scala/akka/remote/RoundRobinRoutedRemoteActorMultiJvmSpec.scala +++ b/akka-remote/src/multi-jvm/scala/akka/remote/RoundRobinRoutedRemoteActorMultiJvmSpec.scala @@ -1,11 +1,9 @@ package akka.remote import akka.actor.{ Actor, Props } -import akka.remote._ import akka.routing._ import akka.testkit.DefaultTimeout import akka.dispatch.Await -import akka.pattern.ask object RoundRobinRoutedRemoteActorMultiJvmSpec extends AbstractRemoteActorMultiJvmSpec { override def NrOfNodes = 4 diff --git a/akka-remote/src/multi-jvm/scala/akka/remote/ScatterGatherRoutedRemoteActorMultiJvmSpec.scala b/akka-remote/src/multi-jvm/scala/akka/remote/ScatterGatherRoutedRemoteActorMultiJvmSpec.scala index 48ef5adcc9..ce9e483c07 100644 --- a/akka-remote/src/multi-jvm/scala/akka/remote/ScatterGatherRoutedRemoteActorMultiJvmSpec.scala +++ b/akka-remote/src/multi-jvm/scala/akka/remote/ScatterGatherRoutedRemoteActorMultiJvmSpec.scala @@ -1,7 +1,6 @@ package akka.remote import akka.actor.{ Actor, Props } -import akka.remote._ import akka.routing._ import akka.testkit._ import akka.util.duration._