More scala3 work (cassandra / azure) (#130)

* scala3 support for cassandra connector * try azure connector
apache · Jun 10, 2023 · 8ebafac · 8ebafac
1 parent 16c2202
commit 8ebafac
Show file tree

Hide file tree

Showing 4 changed files with 3 additions and 5 deletions.
diff --git a/...la/org/apache/pekko/stream/connectors/azure/storagequeue/impl/AzureQueueSourceStage.scala b/...la/org/apache/pekko/stream/connectors/azure/storagequeue/impl/AzureQueueSourceStage.scala
@@ -68,7 +68,7 @@ import scala.collection.mutable.Queue
     setHandler(
       out,
       new OutHandler {
-        override def onPull: Unit =
+        override def onPull(): Unit =
           if (!buffer.isEmpty) {
             push(out, buffer.dequeue())
           } else {

diff --git a/...est/scala/org/apache/pekko/stream/connectors/cassandra/javadsl/CassandraSessionSpec.scala b/...est/scala/org/apache/pekko/stream/connectors/cassandra/javadsl/CassandraSessionSpec.scala
@@ -38,7 +38,7 @@ import scala.concurrent.duration._
 
 final class CassandraSessionSpec extends CassandraSpecBase(ActorSystem("CassandraSessionSpec")) {
 
-  val log = Logging(system, this.getClass)
+  val log = Logging(system, classOf[CassandraSessionSpec])
   val javadslSessionRegistry = javadsl.CassandraSessionRegistry.get(system)
 
   val data = 1 until 103

diff --git a/...g/apache/pekko/stream/connectors/cassandra/scaladsl/CassandraSessionPerformanceSpec.scala b/...g/apache/pekko/stream/connectors/cassandra/scaladsl/CassandraSessionPerformanceSpec.scala
@@ -25,7 +25,7 @@ import scala.concurrent.duration._
 
 final class CassandraSessionPerformanceSpec extends CassandraSpecBase(ActorSystem("CassandraSessionPerformanceSpec")) {
 
-  val log = Logging(system, this.getClass)
+  val log = Logging(system, classOf[CassandraSessionPerformanceSpec])
 
   val data = 1 to 5 * 1000 * 1000
 

diff --git a/project/Dependencies.scala b/project/Dependencies.scala
@@ -106,7 +106,6 @@ object Dependencies {
         ExclusionRule("software.amazon.awssdk", "netty-nio-client"))) ++ Mockito)
 
   val AzureStorageQueue = Seq(
-    crossScalaVersions -= Scala3,
     libraryDependencies ++= Seq(
       "com.microsoft.azure" % "azure-storage" % "8.0.0" // ApacheV2
     ))
@@ -116,7 +115,6 @@ object Dependencies {
   val CassandraDriverVersionInDocs = "4.15"
 
   val Cassandra = Seq(
-    crossScalaVersions -= Scala3,
     libraryDependencies ++= Seq(
       ("com.datastax.oss" % "java-driver-core" % CassandraDriverVersion)
         .exclude("com.github.spotbugs", "spotbugs-annotations")