This is an automated email from the ASF dual-hosted git repository.
mdedetrich pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/incubator-pekko.git
The following commit(s) were added to refs/heads/main by this push:
new 2df2e0294f Remove fqcn
2df2e0294f is described below
commit 2df2e0294f763a8f7c41d31830b3f28059e0bf01
Author: Matthew de Detrich <[email protected]>
AuthorDate: Sat Jun 17 12:05:52 2023 +0200
Remove fqcn
---
.../src/test/scala/docs/org/apache/pekko/typed/RouterSpec.scala | 2 +-
.../org/apache/pekko/actor/typed/ActorRefResolverSpec.scala | 2 +-
.../pekko/cluster/ddata/typed/scaladsl/DistributedData.scala | 2 +-
.../main/scala/org/apache/pekko/persistence/query/Offset.scala | 2 +-
.../org/apache/pekko/remote/testconductor/ControllerSpec.scala | 9 +++++----
.../apache/pekko/remote/artery/compress/CompressionTable.scala | 2 +-
.../apache/pekko/remote/serialization/ProtobufSerializer.scala | 2 +-
.../scala/org/apache/pekko/remote/transport/PekkoPduCodec.scala | 2 +-
.../apache/pekko/remote/transport/PekkoProtocolTransport.scala | 2 +-
.../main/scala/org/apache/pekko/remote/transport/Transport.scala | 2 +-
.../test/scala/org/apache/pekko/remote/RemoteFeaturesSpec.scala | 2 +-
11 files changed, 15 insertions(+), 14 deletions(-)
diff --git
a/actor-typed-tests/src/test/scala/docs/org/apache/pekko/typed/RouterSpec.scala
b/actor-typed-tests/src/test/scala/docs/org/apache/pekko/typed/RouterSpec.scala
index 9fc9c331a0..de2ac07290 100644
---
a/actor-typed-tests/src/test/scala/docs/org/apache/pekko/typed/RouterSpec.scala
+++
b/actor-typed-tests/src/test/scala/docs/org/apache/pekko/typed/RouterSpec.scala
@@ -13,7 +13,6 @@
package docs.org.apache.pekko.typed
-import org.apache.pekko.actor.typed.DispatcherSelector
// #pool
import org.apache.pekko
import pekko.actor.testkit.typed.scaladsl.{ LogCapturing,
ScalaTestWithActorTestKit }
@@ -22,6 +21,7 @@ import pekko.actor.typed.receptionist.{ Receptionist,
ServiceKey }
import pekko.actor.typed.scaladsl.{ Behaviors, Routers }
// #pool
+import pekko.actor.typed.DispatcherSelector
import org.scalatest.wordspec.AnyWordSpecLike
object RouterSpec {
diff --git
a/actor-typed-tests/src/test/scala/org/apache/pekko/actor/typed/ActorRefResolverSpec.scala
b/actor-typed-tests/src/test/scala/org/apache/pekko/actor/typed/ActorRefResolverSpec.scala
index e53e04a717..6c067a509d 100644
---
a/actor-typed-tests/src/test/scala/org/apache/pekko/actor/typed/ActorRefResolverSpec.scala
+++
b/actor-typed-tests/src/test/scala/org/apache/pekko/actor/typed/ActorRefResolverSpec.scala
@@ -41,7 +41,7 @@ class ActorRefResolverSpec extends AnyWordSpec with
ScalaFutures with Matchers {
}
// we can't detect that for MinimalActorRef
- import org.apache.pekko.actor.typed.scaladsl.adapter._
+ import pekko.actor.typed.scaladsl.adapter._
val minRef1: pekko.actor.ActorRef = new MinimalActorRef {
override def provider: ActorRefProvider =
system1.toClassic.asInstanceOf[ActorSystemImpl].provider
diff --git
a/cluster-typed/src/main/scala/org/apache/pekko/cluster/ddata/typed/scaladsl/DistributedData.scala
b/cluster-typed/src/main/scala/org/apache/pekko/cluster/ddata/typed/scaladsl/DistributedData.scala
index d35bba669b..ef111083a0 100644
---
a/cluster-typed/src/main/scala/org/apache/pekko/cluster/ddata/typed/scaladsl/DistributedData.scala
+++
b/cluster-typed/src/main/scala/org/apache/pekko/cluster/ddata/typed/scaladsl/DistributedData.scala
@@ -77,7 +77,7 @@ object DistributedData extends ExtensionId[DistributedData] {
* and classic actors can share the same data.
*/
class DistributedData(system: ActorSystem[_]) extends Extension {
- import org.apache.pekko.actor.typed.scaladsl.adapter._
+ import pekko.actor.typed.scaladsl.adapter._
private val settings: ReplicatorSettings = ReplicatorSettings(system)
diff --git
a/persistence-query/src/main/scala/org/apache/pekko/persistence/query/Offset.scala
b/persistence-query/src/main/scala/org/apache/pekko/persistence/query/Offset.scala
index 1b6447e0d1..6c5241c849 100644
---
a/persistence-query/src/main/scala/org/apache/pekko/persistence/query/Offset.scala
+++
b/persistence-query/src/main/scala/org/apache/pekko/persistence/query/Offset.scala
@@ -106,7 +106,7 @@ final case class TimestampOffset(timestamp: Instant,
readTimestamp: Instant, see
/** Java API */
def getSeen(): java.util.Map[String, java.lang.Long] = {
- import org.apache.pekko.util.ccompat.JavaConverters._
+ import pekko.util.ccompat.JavaConverters._
seen.map { case (pid, seqNr) => pid -> java.lang.Long.valueOf(seqNr)
}.asJava
}
diff --git
a/remote-tests/src/test/scala/org/apache/pekko/remote/testconductor/ControllerSpec.scala
b/remote-tests/src/test/scala/org/apache/pekko/remote/testconductor/ControllerSpec.scala
index de83d67681..45ebff180f 100644
---
a/remote-tests/src/test/scala/org/apache/pekko/remote/testconductor/ControllerSpec.scala
+++
b/remote-tests/src/test/scala/org/apache/pekko/remote/testconductor/ControllerSpec.scala
@@ -16,10 +16,11 @@ package org.apache.pekko.remote.testconductor
import java.net.InetAddress
import java.net.InetSocketAddress
-import org.apache.pekko.actor.{ AddressFromURIString, PoisonPill, Props }
-import org.apache.pekko.remote.testconductor.Controller.NodeInfo
-import org.apache.pekko.testkit.PekkoSpec
-import org.apache.pekko.testkit.ImplicitSender
+import org.apache.pekko
+import pekko.actor.{ AddressFromURIString, PoisonPill, Props }
+import pekko.remote.testconductor.Controller.NodeInfo
+import pekko.testkit.PekkoSpec
+import pekko.testkit.ImplicitSender
object ControllerSpec {
val config = """
diff --git
a/remote/src/main/scala/org/apache/pekko/remote/artery/compress/CompressionTable.scala
b/remote/src/main/scala/org/apache/pekko/remote/artery/compress/CompressionTable.scala
index e985b4da6e..c8abf8d53d 100644
---
a/remote/src/main/scala/org/apache/pekko/remote/artery/compress/CompressionTable.scala
+++
b/remote/src/main/scala/org/apache/pekko/remote/artery/compress/CompressionTable.scala
@@ -20,7 +20,7 @@ import org.agrona.collections.Hashing
import org.agrona.collections.Object2IntHashMap
import org.apache.pekko
-import org.apache.pekko.util.HashCode
+import pekko.util.HashCode
/**
* INTERNAL API: Versioned compression table to be advertised between systems
diff --git
a/remote/src/main/scala/org/apache/pekko/remote/serialization/ProtobufSerializer.scala
b/remote/src/main/scala/org/apache/pekko/remote/serialization/ProtobufSerializer.scala
index 9753b3131b..37cce2011a 100644
---
a/remote/src/main/scala/org/apache/pekko/remote/serialization/ProtobufSerializer.scala
+++
b/remote/src/main/scala/org/apache/pekko/remote/serialization/ProtobufSerializer.scala
@@ -58,7 +58,7 @@ class ProtobufSerializer(val system: ExtendedActorSystem)
extends BaseSerializer
private val toByteArrayMethodBindingRef = new AtomicReference[Map[Class[_],
Method]](Map.empty)
private val allowedClassNames: Set[String] = {
- import org.apache.pekko.util.ccompat.JavaConverters._
+ import pekko.util.ccompat.JavaConverters._
system.settings.config.getStringList("pekko.serialization.protobuf.allowed-classes").asScala.toSet
}
diff --git
a/remote/src/main/scala/org/apache/pekko/remote/transport/PekkoPduCodec.scala
b/remote/src/main/scala/org/apache/pekko/remote/transport/PekkoPduCodec.scala
index 581ebc1c42..2717aa13b1 100644
---
a/remote/src/main/scala/org/apache/pekko/remote/transport/PekkoPduCodec.scala
+++
b/remote/src/main/scala/org/apache/pekko/remote/transport/PekkoPduCodec.scala
@@ -217,7 +217,7 @@ private[remote] object PekkoPduProtobufCodec$ extends
PekkoPduCodec {
val ackAndEnvelope = AckAndEnvelopeContainer.parseFrom(raw.toArrayUnsafe())
val ackOption = if (ackAndEnvelope.hasAck) {
- import org.apache.pekko.util.ccompat.JavaConverters._
+ import pekko.util.ccompat.JavaConverters._
Some(
Ack(
SeqNo(ackAndEnvelope.getAck.getCumulativeAck),
diff --git
a/remote/src/main/scala/org/apache/pekko/remote/transport/PekkoProtocolTransport.scala
b/remote/src/main/scala/org/apache/pekko/remote/transport/PekkoProtocolTransport.scala
index 5aadc4e28a..cad53b837b 100644
---
a/remote/src/main/scala/org/apache/pekko/remote/transport/PekkoProtocolTransport.scala
+++
b/remote/src/main/scala/org/apache/pekko/remote/transport/PekkoProtocolTransport.scala
@@ -49,7 +49,7 @@ private[remote] class PekkoProtocolSettings(config: Config) {
import config._
- import org.apache.pekko.util.Helpers.ConfigOps
+ import pekko.util.Helpers.ConfigOps
val TransportFailureDetectorConfig: Config =
getConfig("pekko.remote.classic.transport-failure-detector")
val TransportFailureDetectorImplementationClass: String =
diff --git
a/remote/src/main/scala/org/apache/pekko/remote/transport/Transport.scala
b/remote/src/main/scala/org/apache/pekko/remote/transport/Transport.scala
index cd5de55e67..3753529acd 100644
--- a/remote/src/main/scala/org/apache/pekko/remote/transport/Transport.scala
+++ b/remote/src/main/scala/org/apache/pekko/remote/transport/Transport.scala
@@ -81,7 +81,7 @@ object Transport {
*/
@deprecated("Classic remoting is deprecated, use Artery", "Akka 2.6.0")
trait Transport {
- import org.apache.pekko.remote.transport.Transport._
+ import pekko.remote.transport.Transport._
/**
* Returns a string that will be used as the scheme part of the URLs
corresponding to this transport
diff --git
a/remote/src/test/scala/org/apache/pekko/remote/RemoteFeaturesSpec.scala
b/remote/src/test/scala/org/apache/pekko/remote/RemoteFeaturesSpec.scala
index 2fc94e1154..029feb4ef7 100644
--- a/remote/src/test/scala/org/apache/pekko/remote/RemoteFeaturesSpec.scala
+++ b/remote/src/test/scala/org/apache/pekko/remote/RemoteFeaturesSpec.scala
@@ -76,7 +76,7 @@ abstract class RemoteFeaturesSpec(c: Config) extends
ArteryMultiNodeSpec(c) with
}
mute()
- import org.apache.pekko.remote.artery.RemoteWatcherSpec.TestRemoteWatcher
+ import pekko.remote.artery.RemoteWatcherSpec.TestRemoteWatcher
protected val monitor = system.actorOf(Props(new TestRemoteWatcher),
"monitor1")
protected val watcher = system.actorOf(Props(new EmptyActor),
"a1").asInstanceOf[InternalActorRef]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
