This is an automated email from the ASF dual-hosted git repository.
fanningpj pushed a commit to branch scala3
in repository https://gitbox.apache.org/repos/asf/incubator-pekko-connectors.git
The following commit(s) were added to refs/heads/scala3 by this push:
new 3a272d483 More scala3 work (cassandra / azure) (#130)
3a272d483 is described below
commit 3a272d483c179cb97d0c54ff5fcc928ac16fe9dc
Author: PJ Fanning <[email protected]>
AuthorDate: Wed May 31 08:23:09 2023 +0100
More scala3 work (cassandra / azure) (#130)
* scala3 support for cassandra connector
* try azure connector
---
.../connectors/azure/storagequeue/impl/AzureQueueSourceStage.scala | 2 +-
.../stream/connectors/cassandra/javadsl/CassandraSessionSpec.scala | 2 +-
.../connectors/cassandra/scaladsl/CassandraSessionPerformanceSpec.scala | 2 +-
project/Dependencies.scala | 2 --
4 files changed, 3 insertions(+), 5 deletions(-)
diff --git
a/azure-storage-queue/src/main/scala/org/apache/pekko/stream/connectors/azure/storagequeue/impl/AzureQueueSourceStage.scala
b/azure-storage-queue/src/main/scala/org/apache/pekko/stream/connectors/azure/storagequeue/impl/AzureQueueSourceStage.scala
index 6bfcc9a8e..712d2baac 100644
---
a/azure-storage-queue/src/main/scala/org/apache/pekko/stream/connectors/azure/storagequeue/impl/AzureQueueSourceStage.scala
+++
b/azure-storage-queue/src/main/scala/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/cassandra/src/test/scala/org/apache/pekko/stream/connectors/cassandra/javadsl/CassandraSessionSpec.scala
b/cassandra/src/test/scala/org/apache/pekko/stream/connectors/cassandra/javadsl/CassandraSessionSpec.scala
index 6fa00ffa1..0c76ddb86 100644
---
a/cassandra/src/test/scala/org/apache/pekko/stream/connectors/cassandra/javadsl/CassandraSessionSpec.scala
+++
b/cassandra/src/test/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/cassandra/src/test/scala/org/apache/pekko/stream/connectors/cassandra/scaladsl/CassandraSessionPerformanceSpec.scala
b/cassandra/src/test/scala/org/apache/pekko/stream/connectors/cassandra/scaladsl/CassandraSessionPerformanceSpec.scala
index 843db7d2b..19ec7c6ac 100644
---
a/cassandra/src/test/scala/org/apache/pekko/stream/connectors/cassandra/scaladsl/CassandraSessionPerformanceSpec.scala
+++
b/cassandra/src/test/scala/org/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
index 94433ece5..8faaffc24 100644
--- 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")
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
