Akka cleanup! ( +rabbitmq)

.github/workflows/deploy.yml

@@ -23,7 +23,6 @@ jobs:
           sbt 'project pubsub' assembly
           sbt 'project sqs' assembly
           sbt 'project stdout' assembly
-          sbt 'project rabbitmq' assembly
       - name: Get current version
         id: ver
         run: |
@@ -43,7 +42,6 @@ jobs:
             pubsub/target/scala-2.12/snowplow-stream-collector-google-pubsub-${{ steps.ver.outputs.project_version }}.jar
             sqs/target/scala-2.12/snowplow-stream-collector-sqs-${{ steps.ver.outputs.project_version }}.jar
             stdout/target/scala-2.12/snowplow-stream-collector-stdout-${{ steps.ver.outputs.project_version }}.jar
-            rabbitmq/target/scala-2.12/snowplow-stream-collector-stdout-${{ steps.ver.outputs.project_version }}.jar
         env:
           GITHUB_TOKEN: ${{ secrets.GITHUB_TOKEN }}
 
@@ -58,11 +56,8 @@ jobs:
           - kafka
           - nsq
           - stdout
-          - rabbitmq
         include:
           - suffix: ""
-          - suffix: -experimental
-            platform: rabbitmq
           - platform: kinesis
             run_snyk: ${{ !contains(github.ref, 'rc') }}
           - platform: pubsub

build.sbt

@@ -9,37 +9,6 @@
 import com.typesafe.sbt.packager.docker._
 import sbtbuildinfo.BuildInfoPlugin.autoImport._
 
-lazy val commonDependencies = Seq(
-  // Java
-  Dependencies.Libraries.thrift,
-  Dependencies.Libraries.jodaTime,
-  Dependencies.Libraries.slf4j,
-  Dependencies.Libraries.log4jOverSlf4j,
-  Dependencies.Libraries.config,
-  // Scala
-  Dependencies.Libraries.scopt,
-  Dependencies.Libraries.akkaStream,
-  Dependencies.Libraries.akkaHttp,
-  Dependencies.Libraries.akkaStream,
-  Dependencies.Libraries.akkaSlf4j,
-  Dependencies.Libraries.akkaHttpMetrics,
-  Dependencies.Libraries.jnrUnixsocket,
-  Dependencies.Libraries.badRows,
-  Dependencies.Libraries.collectorPayload,
-  Dependencies.Libraries.pureconfig,
-  Dependencies.Libraries.Legacy.trackerCore,
-  Dependencies.Libraries.Legacy.trackerEmitterId,
-  // Unit tests
-  Dependencies.Libraries.akkaTestkit,
-  Dependencies.Libraries.akkaHttpTestkit,
-  Dependencies.Libraries.akkaStreamTestkit,
-  Dependencies.Libraries.specs2,
-  // Integration tests
-  Dependencies.Libraries.Legacy.testcontainers,
-  Dependencies.Libraries.Legacy.http4sClient,
-  Dependencies.Libraries.Legacy.catsRetry
-)
-
 lazy val commonExclusions = Seq(
   "org.apache.tomcat.embed" % "tomcat-embed-core", // exclude for security vulnerabilities introduced by libthrift
   // Avoid duplicate .proto files brought in by akka and google-cloud-pubsub.
@@ -109,15 +78,7 @@ lazy val allSettings = buildSettings ++
 lazy val root = project
   .in(file("."))
   .settings(buildSettings ++ dynVerSettings)
-  .aggregate(core, kinesis, pubsub, kafka, nsq, stdout, sqs, rabbitmq, http4s)
-
-lazy val core = project
-  .settings(moduleName := "snowplow-stream-collector-core")
-  .settings(buildSettings ++ BuildSettings.sbtAssemblySettings)
-  .settings(libraryDependencies ++= commonDependencies)
-  .settings(excludeDependencies ++= commonExclusions)
-  .settings(Defaults.itSettings)
-  .configs(IntegrationTest)
+  .aggregate(kinesis, pubsub, kafka, nsq, stdout, sqs, http4s)
 
 lazy val http4s = project
   .settings(moduleName := "snowplow-stream-collector-http4s-core")
@@ -320,16 +281,4 @@ lazy val rabbitmqSettings =
     moduleName := "snowplow-stream-collector-rabbitmq",
     Docker / packageName := "scala-stream-collector-rabbitmq-experimental",
     libraryDependencies ++= Seq(Dependencies.Libraries.rabbitMQ)
-  )
-
-lazy val rabbitmq = project
-  .settings(rabbitmqSettings)
-  .enablePlugins(JavaAppPackaging, SnowplowDockerPlugin, BuildInfoPlugin)
-  .dependsOn(core % "test->test;compile->compile")
-
-lazy val rabbitmqDistroless = project
-  .in(file("distroless/rabbitmq"))
-  .settings(sourceDirectory := (rabbitmq / sourceDirectory).value)
-  .settings(rabbitmqSettings)
-  .enablePlugins(JavaAppPackaging, SnowplowDistrolessDockerPlugin, BuildInfoPlugin)
-  .dependsOn(core % "test->test;compile->compile")
+  )