This is an automated email from the ASF dual-hosted git repository.
fanningpj pushed a commit to branch main
in repository
https://gitbox.apache.org/repos/asf/incubator-pekko-connectors-samples.git
The following commit(s) were added to refs/heads/main by this push:
new fd806ed [jms] Migrate akka dependencies to pekko (#14)
fd806ed is described below
commit fd806edfa0304e07c417646cb63594f52f80a299
Author: Laglangyue <[email protected]>
AuthorDate: Sun Dec 17 04:54:59 2023 +0800
[jms] Migrate akka dependencies to pekko (#14)
* [jms] Migrate akka dependencies to pekko
* use pekko version 1.1.0
* update refs
---------
Co-authored-by: laglang <[email protected]>
Co-authored-by: PJ Fanning <[email protected]>
---
.github/workflows/compile.yml | 4 +-
docs/build.sbt | 32 ++++-----
docs/project/Dependencies.scala | 6 +-
jms.conf | 6 +-
pekko-connectors-sample-jms/README.md | 8 +--
pekko-connectors-sample-jms/build.sbt | 4 +-
.../docs/src/main/paradox/append-to-file.md | 2 +-
.../docs/src/main/paradox/index.md | 4 +-
.../docs/src/main/paradox/to-http-get.md | 2 +-
.../src/main/paradox/to-one-file-per-message.md | 2 +-
.../docs/src/main/paradox/to-websocket.md | 2 +-
.../project/Dependencies.scala | 24 +++----
.../src/main/java/samples/javadsl/JmsToFile.java | 39 +++++------
.../main/java/samples/javadsl/JmsToHttpGet.java | 35 +++++-----
.../samples/javadsl/JmsToOneFilePerMessage.java | 34 +++++-----
.../main/java/samples/javadsl/JmsToWebSocket.java | 71 ++++++++++----------
.../src/main/resources/application.conf | 6 +-
.../src/main/resources/logback.xml | 3 +-
.../src/main/scala/playground/ActiveMqBroker.scala | 20 +++---
.../src/main/scala/playground/WebServer.scala | 76 +++++++++++-----------
.../scala/samples/scaladsl/JmsSampleBase.scala | 19 +++---
.../main/scala/samples/scaladsl/JmsToFile.scala | 11 ++--
.../main/scala/samples/scaladsl/JmsToHttpGet.scala | 17 +++--
.../samples/scaladsl/JmsToOneFilePerMessage.scala | 11 ++--
.../scala/samples/scaladsl/JmsToWebSocket.scala | 18 ++---
25 files changed, 231 insertions(+), 225 deletions(-)
diff --git a/.github/workflows/compile.yml b/.github/workflows/compile.yml
index 20e218c..ca0a0fe 100644
--- a/.github/workflows/compile.yml
+++ b/.github/workflows/compile.yml
@@ -18,7 +18,7 @@ jobs:
uses: actions/checkout@v4
- name: Setup Java 11
- uses: actions/setup-java@v3
+ uses: actions/setup-java@v4
with:
distribution: temurin
java-version: 11
@@ -59,7 +59,7 @@ jobs:
uses: actions/checkout@v4
- name: Setup Java 11
- uses: actions/setup-java@v3
+ uses: actions/setup-java@v4
with:
distribution: temurin
java-version: 11
diff --git a/docs/build.sbt b/docs/build.sbt
index abea44f..aad702c 100644
--- a/docs/build.sbt
+++ b/docs/build.sbt
@@ -6,7 +6,7 @@ enablePlugins(AkkaParadoxPlugin, ParadoxSitePlugin,
PublishRsyncPlugin)
name := "Pekko Connectors Samples"
previewFixedPort := Some(8085)
scmInfo :=
Some(ScmInfo(url("https://github.com/apache/incubator-pekko-connectors-samples";),
"[email protected]:apache/incubator-pekko-connectors-samples.git"))
-homepage := Some(url("https://akka.io/alpakka-samples";))
+homepage :=
Some(url("https://github.com/apache/incubator-pekko-connectors-samples";))
description := "Example solutions for Enterprise Integrations using Pekko
Connectors and Reactive Streams."
version := {
val time = java.time.LocalDateTime.now().withSecond(0).withNano(0)
@@ -26,7 +26,7 @@ FtpToFile / paradoxProperties ++= Map(
"snip.build.base_dir" ->
s"${baseDirectory.value}/../pekko-connectors-sample-${FtpToFile.name}",
"github.root.base_dir" -> s"${baseDirectory.value}/..",
// Alpakka
- "scaladoc.akka.stream.alpakka.base_url" ->
s"https://doc.akka.io/api/alpakka/${Dependencies.Jms.AlpakkaVersion}";,
+ "scaladoc.akka.stream.alpakka.base_url" ->
s"https://doc.akka.io/api/alpakka/${Dependencies.FtpToFile.AlpakkaVersion}";,
"javadoc.akka.base_url" -> "",
"extref.alpakka.base_url" ->
s"https://doc.akka.io/docs/alpakka/${Dependencies.FtpToFile.AlpakkaVersion}/%s";,
// Akka
@@ -77,10 +77,10 @@ JdbcToElasticsearch / paradoxProperties ++= Map(
"canonical.base_url" -> s"${homepage.value.get}/${JdbcToElasticsearch.name}",
"snip.build.base_dir" ->
s"${baseDirectory.value}/../pekko-connectors-sample-${JdbcToElasticsearch.name}",
"github.root.base_dir" -> s"${baseDirectory.value}/..",
- "scaladoc.akka.stream.alpakka.base_url" ->
s"https://pekko.apache.org/api/pekko-connectors/${Dependencies.JdbcToElasticsearch.PekkoConnectorsVersion}";,
+ "scaladoc.pekko.stream.pekko-connectors.base_url" ->
s"https://pekko.apache.org/api/pekko-connectors/${Dependencies.JdbcToElasticsearch.PekkoConnectorsVersion}";,
"javadoc.pekko.base_url" -> "",
"extref.pekko-connectors.base_url" ->
s"https://pekko.apache.org/docs/pekko-connectors/${Dependencies.JdbcToElasticsearch.PekkoConnectorsVersion}/%s";,
- // Akka
+ // Pekko
"scaladoc.pekko.base_url" ->
s"https://pekko.apache.org/api/pekko/${Dependencies.JdbcToElasticsearch.PekkoVersion}";,
"javadoc.pekko.base_url" ->
s"https://pekko.apache.org/japi/pekko/${Dependencies.JdbcToElasticsearch.PekkoVersion}";,
"extref.pekko.base_url" ->
s"https://pekko.apache.org/docs/pekko/${Dependencies.JdbcToElasticsearch.PekkoVersion}/%s";,
@@ -98,18 +98,18 @@ Jms / paradoxProperties ++= Map(
"canonical.base_url" -> s"${homepage.value.get}/${Jms.name}",
"snip.build.base_dir" ->
s"${baseDirectory.value}/../pekko-connectors-sample-${Jms.name}",
"github.root.base_dir" -> s"${baseDirectory.value}/..",
- // Alpakka
- "scaladoc.akka.stream.alpakka.base_url" ->
s"https://doc.akka.io/api/alpakka/${Dependencies.Jms.AlpakkaVersion}";,
- "javadoc.akka.base_url" -> "",
- "extref.alpakka.base_url" ->
s"https://doc.akka.io/docs/alpakka/${Dependencies.Jms.AlpakkaVersion}/%s";,
- // Akka
- "scaladoc.akka.base_url" ->
s"https://doc.akka.io/api/akka/${Dependencies.Jms.AkkaVersion}";,
- "javadoc.akka.base_url" ->
s"https://doc.akka.io/japi/akka/${Dependencies.Jms.AkkaVersion}";,
- "extref.akka.base_url" ->
s"https://doc.akka.io/docs/akka/${Dependencies.Jms.AkkaVersion}/%s";,
- // Akka HTTP
- "scaladoc.akka.http.base_url" ->
s"https://doc.akka.io/api/akka-http/${Dependencies.Jms.AkkaHttpVersion}";,
- "javadoc.akka.http.base_url" ->
s"https://doc.akka.io/japi/akka-http/${Dependencies.Jms.AkkaHttpVersion}";,
- "extref.akka-http.base_url" ->
s"https://doc.akka.io/docs/akka-http/${Dependencies.Jms.AkkaHttpVersion}/%s";,
+ // Pekko Connectors
+ "scaladoc.pekko.stream.pekko-connectors.base_url" ->
s"https://pekko.apache.org/api/pekko-connectors/${Dependencies.Jms.PekkoConnectorsVersion}";,
+ "javadoc.pekko.base_url" -> "",
+ "extref.pekko-connectors.base_url" ->
s"https://pekko.apache.org/docs/pekko-connectors/${Dependencies.Jms.PekkoConnectorsVersion}/%s";,
+ // Pekko
+ "scaladoc.pekko.base_url" ->
s"https://pekko.apache.org/api/pekko/${Dependencies.Jms.PekkoVersion}";,
+ "javadoc.pekko.base_url" ->
s"https://pekko.apache.org/japi/pekko/${Dependencies.Jms.PekkoVersion}";,
+ "extref.pekko.base_url" ->
s"https://pekko.apache.org/docs/pekko/${Dependencies.Jms.PekkoVersion}/%s";,
+ // Pekko HTTP
+ "scaladoc.org.apache.pekko.http.base_url" ->
s"https://pekko.apache.org/api/pekko-http/${Dependencies.Jms.PekkoHttpVersion}";,
+ "javadoc.org.apache.pekko.http.base_url" ->
s"https://pekko.apache.org/japi/pekko-http/${Dependencies.Jms.PekkoHttpVersion}";,
+ "extref.org.apache.pekko-http.base_url" ->
s"https://pekko.apache.org/docs/pekko-http/${Dependencies.Jms.PekkoHttpVersion}/%s";,
)
Jms / paradoxGroups := Map("Language" -> Seq("Java", "Scala"))
diff --git a/docs/project/Dependencies.scala b/docs/project/Dependencies.scala
index 546c783..05b2b4e 100644
--- a/docs/project/Dependencies.scala
+++ b/docs/project/Dependencies.scala
@@ -58,9 +58,9 @@ object Dependencies {
}
val ScalaVersion = versions("scalaVer")
- val AkkaVersion = versions("AkkaVersion")
- val AkkaHttpVersion = versions("AkkaHttpVersion")
- val AlpakkaVersion = versions("AlpakkaVersion")
+ val PekkoVersion = versions("PekkoVersion")
+ val PekkoHttpVersion = versions("PekkoHttpVersion")
+ val PekkoConnectorsVersion = versions("PekkoConnectorsVersion")
}
object KafkaToElasticsearch {
diff --git a/jms.conf b/jms.conf
index 8266805..53b6132 100644
--- a/jms.conf
+++ b/jms.conf
@@ -12,11 +12,11 @@ studentify {
exercise-project-prefix = "step"
- master-base-project-name = "alpakka-sample-jms"
+ master-base-project-name = "pekko-connectors-sample-jms"
- studentified-project-name = "alpakka-sample-jms_sample"
+ studentified-project-name = "pekko-connectors-sample-jms_sample"
- relative-source-folder = "alpakka-sample-jms"
+ relative-source-folder = "pekko-connectors-sample-jms"
readme-in-test-resources = false
diff --git a/pekko-connectors-sample-jms/README.md
b/pekko-connectors-sample-jms/README.md
index 894dd74..fb07b16 100644
--- a/pekko-connectors-sample-jms/README.md
+++ b/pekko-connectors-sample-jms/README.md
@@ -1,9 +1,9 @@
-# Alpakka sample
+# Apeche Pekko Connectors sample
## Receive JMS messages
-These examples show small usages of @extref[Alpakka JMS](alpakka:jms).
+These examples show small usages of @extref[Pekko-Connector
JMS](pekko-connectors:jms).
-Browse the sources at
@link:[Github](https://github.com/akka/alpakka-samples/tree/master/alpakka-sample-jms)
{ open=new }.
+Browse the sources at
@link:[Github](https://github.com/apache/incubator-pekko-connectors-samples/tree/main/pekko-connectors-sample-jms)
{ open=new }.
-To try out this project clone @link:[the Alpakka Samples
repository](https://github.com/akka/alpakka-samples) { open=new } and find it
in the `alpakka-samples-jms` directory.
+To try out this project clone @link:[the Pekko-Connector Samples
repository](https://github.com/apache/incubator-pekko-connectors-samples) {
open=new } and find it in the `pekko-connectors-sample-jms` directory.
diff --git a/pekko-connectors-sample-jms/build.sbt
b/pekko-connectors-sample-jms/build.sbt
index 22eb85b..be69f1a 100644
--- a/pekko-connectors-sample-jms/build.sbt
+++ b/pekko-connectors-sample-jms/build.sbt
@@ -1,5 +1,5 @@
-organization := "com.lightbend.akka.samples"
-version := "1.3.0"
+organization := "org.apache.pekko"
+version := "1.0.1"
scalaVersion := Dependencies.scalaVer
libraryDependencies ++= Dependencies.dependencies
// Having JBoss as a first resolver is a workaround for
https://github.com/coursier/coursier/issues/200
diff --git
a/pekko-connectors-sample-jms/docs/src/main/paradox/append-to-file.md
b/pekko-connectors-sample-jms/docs/src/main/paradox/append-to-file.md
index 6b46df7..7085815 100644
--- a/pekko-connectors-sample-jms/docs/src/main/paradox/append-to-file.md
+++ b/pekko-connectors-sample-jms/docs/src/main/paradox/append-to-file.md
@@ -1,7 +1,7 @@
### Read text messages from JMS queue and append to file
- listens to the JMS queue "test" receiving `String`s (1),
-- converts incoming data to `akka.util.ByteString` (3),
+- converts incoming data to `org.apache.pekko.util.ByteString` (3),
- and appends the data to the file `target/out` (2).
Scala
diff --git a/pekko-connectors-sample-jms/docs/src/main/paradox/index.md
b/pekko-connectors-sample-jms/docs/src/main/paradox/index.md
index 2714cd2..ed359db 100644
--- a/pekko-connectors-sample-jms/docs/src/main/paradox/index.md
+++ b/pekko-connectors-sample-jms/docs/src/main/paradox/index.md
@@ -17,9 +17,9 @@ Scala
> run
```
-### All Alpakka samples
+### All Pekko-Connectors samples
-Show [Alpakka samples listing](../index.html).
+Show [Pekko-Connectors samples listing](../index.html).
@@toc
diff --git a/pekko-connectors-sample-jms/docs/src/main/paradox/to-http-get.md
b/pekko-connectors-sample-jms/docs/src/main/paradox/to-http-get.md
index e207f65..8800b16 100644
--- a/pekko-connectors-sample-jms/docs/src/main/paradox/to-http-get.md
+++ b/pekko-connectors-sample-jms/docs/src/main/paradox/to-http-get.md
@@ -1,7 +1,7 @@
### Read text messages from JMS queue and send to web server
- listens to the JMS queue "test" receiving `String`s (1),
-- converts incoming data to `akka.util.ByteString` (2),
+- converts incoming data to `org.apache.pekko.util.ByteString` (2),
- puts the received text into an `HttpRequest` (3),
- sends the created request via Akka Http (4),
- prints the `HttpResponse` to standard out (5).
diff --git
a/pekko-connectors-sample-jms/docs/src/main/paradox/to-one-file-per-message.md
b/pekko-connectors-sample-jms/docs/src/main/paradox/to-one-file-per-message.md
index 70eafb6..cf833d1 100644
---
a/pekko-connectors-sample-jms/docs/src/main/paradox/to-one-file-per-message.md
+++
b/pekko-connectors-sample-jms/docs/src/main/paradox/to-one-file-per-message.md
@@ -1,7 +1,7 @@
### Read text messages from JMS queue and create one file per message
- listens to the JMS queue "test" receiving `String`s (1),
-- converts incoming data to `akka.util.ByteString` (2),
+- converts incoming data to `org.apache.pekko.util.ByteString` (2),
- combines the incoming data with a counter (3),
- creates an intermediary stream writing the incoming data to a file using the
counter
value to create unique file names (4).
diff --git a/pekko-connectors-sample-jms/docs/src/main/paradox/to-websocket.md
b/pekko-connectors-sample-jms/docs/src/main/paradox/to-websocket.md
index 740c3f6..39d82cb 100644
--- a/pekko-connectors-sample-jms/docs/src/main/paradox/to-websocket.md
+++ b/pekko-connectors-sample-jms/docs/src/main/paradox/to-websocket.md
@@ -2,7 +2,7 @@
- listens to the JMS queue "test" receiving `String`s (1),
- configures a web socket flow to localhost (2),
-- converts incoming data to a
@scala[@scaladoc[ws.TextMessage](akka.http.scaladsl.model.ws.TextMessage)]@java[@scaladoc[akka.http.javadsl.model.ws.TextMessage](akka.http.javadsl.model.ws.TextMessage)]
(3),
+- converts incoming data to a
@scala[@scaladoc[ws.TextMessage](org.apache.pekko.http.scaladsl.model.ws.TextMessage)]@java[@scaladoc[org.apache.pekko.http.javadsl.model.ws.TextMessage](org.apache.pekko.http.javadsl.model.ws.TextMessage)]
(3),
- pass the message via the web socket flow (4),
- convert the (potentially chunked) web socket reply to a `String` (5),
- prefix the `String` (6),
diff --git a/pekko-connectors-sample-jms/project/Dependencies.scala
b/pekko-connectors-sample-jms/project/Dependencies.scala
index 7bc1f45..0b0ed80 100644
--- a/pekko-connectors-sample-jms/project/Dependencies.scala
+++ b/pekko-connectors-sample-jms/project/Dependencies.scala
@@ -1,28 +1,28 @@
import sbt._
object Dependencies {
- val scalaVer = "2.13.7"
+ val scalaVer = "2.13.12"
// #deps
- val AkkaVersion = "2.6.19"
- val AkkaHttpVersion = "10.1.12"
- val AlpakkaVersion = "4.0.0"
+ val PekkoVersion = "1.0.2"
+ val PekkoHttpVersion = "1.0.0"
+ val PekkoConnectorsVersion = "1.0.1"
// #deps
val dependencies = List(
// #deps
- "com.lightbend.akka" %% "akka-stream-alpakka-jms" % AlpakkaVersion,
- "com.typesafe.akka" %% "akka-http" % AkkaHttpVersion,
- "com.typesafe.akka" %% "akka-stream" % AkkaVersion,
- "com.typesafe.akka" %% "akka-actor-typed" % AkkaVersion,
- "com.typesafe.akka" %% "akka-actor" % AkkaVersion,
+ "org.apache.pekko" %% "pekko-connectors-jms" % PekkoConnectorsVersion,
+ "org.apache.pekko" %% "pekko-http" % PekkoHttpVersion,
+ "org.apache.pekko" %% "pekko-stream" % PekkoVersion,
+ "org.apache.pekko" %% "pekko-actor-typed" % PekkoVersion,
+ "org.apache.pekko" %% "pekko-actor" % PekkoVersion,
// https://github.com/javaee/javax.jms
"javax.jms" % "jms" % "1.1", // CDDL Version 1.1
// Logging
- "com.typesafe.akka" %% "akka-slf4j" % AkkaVersion,
- "ch.qos.logback" % "logback-classic" % "1.2.3",
+ "org.apache.pekko" %% "pekko-slf4j" % PekkoVersion,
+ "ch.qos.logback" % "logback-classic" % "1.2.13",
// #deps
// http://activemq.apache.org/download.html
- "org.apache.activemq" % "activemq-all" % "5.16.0" exclude("log4j",
"log4j") exclude("org.slf4j", "slf4j-log4j12") // ApacheV2
+ "org.apache.activemq" % "activemq-all" % "5.16.7" exclude("log4j",
"log4j") exclude("org.slf4j", "slf4j-log4j12") // ApacheV2
)
}
diff --git
a/pekko-connectors-sample-jms/src/main/java/samples/javadsl/JmsToFile.java
b/pekko-connectors-sample-jms/src/main/java/samples/javadsl/JmsToFile.java
index a6c4e01..9316531 100644
--- a/pekko-connectors-sample-jms/src/main/java/samples/javadsl/JmsToFile.java
+++ b/pekko-connectors-sample-jms/src/main/java/samples/javadsl/JmsToFile.java
@@ -6,31 +6,32 @@ package samples.javadsl;
// #sample
-import akka.actor.typed.ActorSystem;
-import akka.actor.typed.javadsl.Behaviors;
-import akka.japi.Pair;
-import akka.stream.IOResult;
-import akka.stream.alpakka.jms.JmsConsumerSettings;
-import akka.stream.alpakka.jms.JmsProducerSettings;
-import akka.stream.alpakka.jms.javadsl.JmsConsumer;
-import akka.stream.alpakka.jms.javadsl.JmsConsumerControl;
-import akka.stream.alpakka.jms.javadsl.JmsProducer;
-import akka.stream.javadsl.FileIO;
-import akka.stream.javadsl.Keep;
-import akka.stream.javadsl.Sink;
-import akka.stream.javadsl.Source;
-import akka.util.ByteString;
-import scala.concurrent.ExecutionContext;
+import org.apache.pekko.actor.typed.ActorSystem;
+import org.apache.pekko.actor.typed.javadsl.Behaviors;
+import org.apache.pekko.japi.Pair;
+import org.apache.pekko.stream.IOResult;
+import org.apache.pekko.stream.connectors.jms.JmsConsumerSettings;
+import org.apache.pekko.stream.connectors.jms.JmsProducerSettings;
+import org.apache.pekko.stream.connectors.jms.javadsl.JmsConsumer;
+import org.apache.pekko.stream.connectors.jms.javadsl.JmsConsumerControl;
+import org.apache.pekko.stream.connectors.jms.javadsl.JmsProducer;
+import org.apache.pekko.stream.javadsl.FileIO;
+import org.apache.pekko.stream.javadsl.Keep;
+import org.apache.pekko.stream.javadsl.Sink;
+import org.apache.pekko.stream.javadsl.Source;
+import org.apache.pekko.util.ByteString;
+import playground.ActiveMqBroker;
-import javax.jms.ConnectionFactory;
import java.nio.file.Paths;
import java.util.Arrays;
import java.util.concurrent.CompletionStage;
import java.util.concurrent.TimeUnit;
-// #sample
+import javax.jms.ConnectionFactory;
-import playground.ActiveMqBroker;
+import scala.concurrent.ExecutionContext;
+
+// #sample
public class JmsToFile {
@@ -39,7 +40,7 @@ public class JmsToFile {
me.run();
}
- private final ActorSystem<Void> system =
ActorSystem.create(Behaviors.empty(), "JmsToFile");
+ private final ActorSystem<Object> system =
ActorSystem.create(Behaviors.empty(), "JmsToFile");
private final ExecutionContext ec = system.executionContext();
private void enqueue(ConnectionFactory connectionFactory, String... msgs) {
diff --git
a/pekko-connectors-sample-jms/src/main/java/samples/javadsl/JmsToHttpGet.java
b/pekko-connectors-sample-jms/src/main/java/samples/javadsl/JmsToHttpGet.java
index 126c4af..23ac317 100644
---
a/pekko-connectors-sample-jms/src/main/java/samples/javadsl/JmsToHttpGet.java
+++
b/pekko-connectors-sample-jms/src/main/java/samples/javadsl/JmsToHttpGet.java
@@ -6,27 +6,30 @@ package samples.javadsl;
// #sample
-import akka.Done;
-import akka.actor.typed.ActorSystem;
-import akka.actor.typed.javadsl.Behaviors;
-import static akka.actor.typed.javadsl.Adapter.*;
-import akka.http.javadsl.Http;
-import akka.http.javadsl.model.HttpRequest;
-import akka.japi.Pair;
-import akka.stream.alpakka.jms.JmsConsumerSettings;
-import akka.stream.alpakka.jms.JmsProducerSettings;
-import akka.stream.alpakka.jms.javadsl.JmsConsumer;
-import akka.stream.alpakka.jms.javadsl.JmsConsumerControl;
-import akka.stream.alpakka.jms.javadsl.JmsProducer;
-import akka.stream.javadsl.Keep;
-import akka.stream.javadsl.Sink;
-import akka.stream.javadsl.Source;
-import akka.util.ByteString;
+import static org.apache.pekko.actor.typed.javadsl.Adapter.*;
+
+import org.apache.pekko.Done;
+import org.apache.pekko.actor.typed.ActorSystem;
+import org.apache.pekko.actor.typed.javadsl.Behaviors;
+import org.apache.pekko.http.javadsl.Http;
+import org.apache.pekko.http.javadsl.model.HttpRequest;
+import org.apache.pekko.japi.Pair;
+import org.apache.pekko.stream.connectors.jms.JmsConsumerSettings;
+import org.apache.pekko.stream.connectors.jms.JmsProducerSettings;
+import org.apache.pekko.stream.connectors.jms.javadsl.JmsConsumer;
+import org.apache.pekko.stream.connectors.jms.javadsl.JmsConsumerControl;
+import org.apache.pekko.stream.connectors.jms.javadsl.JmsProducer;
+import org.apache.pekko.stream.javadsl.Keep;
+import org.apache.pekko.stream.javadsl.Sink;
+import org.apache.pekko.stream.javadsl.Source;
+import org.apache.pekko.util.ByteString;
import playground.ActiveMqBroker;
import playground.WebServer;
+
import scala.concurrent.ExecutionContext;
import javax.jms.ConnectionFactory;
+
import java.util.Arrays;
import java.util.concurrent.CompletionStage;
import java.util.concurrent.TimeUnit;
diff --git
a/pekko-connectors-sample-jms/src/main/java/samples/javadsl/JmsToOneFilePerMessage.java
b/pekko-connectors-sample-jms/src/main/java/samples/javadsl/JmsToOneFilePerMessage.java
index de5de2e..0147d5c 100644
---
a/pekko-connectors-sample-jms/src/main/java/samples/javadsl/JmsToOneFilePerMessage.java
+++
b/pekko-connectors-sample-jms/src/main/java/samples/javadsl/JmsToOneFilePerMessage.java
@@ -6,30 +6,32 @@ package samples.javadsl;
// #sample
-import akka.Done;
-import akka.actor.typed.ActorSystem;
-import akka.actor.typed.javadsl.Behaviors;
-import akka.japi.Pair;
-import akka.stream.KillSwitch;
-import akka.stream.alpakka.jms.JmsConsumerSettings;
-import akka.stream.alpakka.jms.JmsProducerSettings;
-import akka.stream.alpakka.jms.javadsl.JmsConsumer;
-import akka.stream.alpakka.jms.javadsl.JmsConsumerControl;
-import akka.stream.alpakka.jms.javadsl.JmsProducer;
-import akka.stream.javadsl.FileIO;
-import akka.stream.javadsl.Keep;
-import akka.stream.javadsl.Sink;
-import akka.stream.javadsl.Source;
-import akka.util.ByteString;
+import org.apache.pekko.Done;
+import org.apache.pekko.actor.typed.ActorSystem;
+import org.apache.pekko.actor.typed.javadsl.Behaviors;
+import org.apache.pekko.japi.Pair;
+import org.apache.pekko.stream.KillSwitch;
+import org.apache.pekko.stream.connectors.jms.JmsConsumerSettings;
+import org.apache.pekko.stream.connectors.jms.JmsProducerSettings;
+import org.apache.pekko.stream.connectors.jms.javadsl.JmsConsumer;
+import org.apache.pekko.stream.connectors.jms.javadsl.JmsConsumerControl;
+import org.apache.pekko.stream.connectors.jms.javadsl.JmsProducer;
+import org.apache.pekko.stream.javadsl.FileIO;
+import org.apache.pekko.stream.javadsl.Keep;
+import org.apache.pekko.stream.javadsl.Sink;
+import org.apache.pekko.stream.javadsl.Source;
+import org.apache.pekko.util.ByteString;
import playground.ActiveMqBroker;
-import scala.concurrent.ExecutionContext;
import javax.jms.ConnectionFactory;
+
import java.nio.file.Paths;
import java.util.Arrays;
import java.util.concurrent.CompletionStage;
import java.util.concurrent.TimeUnit;
+import scala.concurrent.ExecutionContext;
+
// #sample
public class JmsToOneFilePerMessage {
diff --git
a/pekko-connectors-sample-jms/src/main/java/samples/javadsl/JmsToWebSocket.java
b/pekko-connectors-sample-jms/src/main/java/samples/javadsl/JmsToWebSocket.java
index 2eb1849..3819d2a 100644
---
a/pekko-connectors-sample-jms/src/main/java/samples/javadsl/JmsToWebSocket.java
+++
b/pekko-connectors-sample-jms/src/main/java/samples/javadsl/JmsToWebSocket.java
@@ -6,37 +6,40 @@ package samples.javadsl;
// #sample
-import akka.Done;
-import akka.actor.typed.ActorSystem;
-import akka.actor.typed.javadsl.Behaviors;
-import static akka.actor.typed.javadsl.Adapter.*;
-import akka.http.javadsl.Http;
-import akka.http.javadsl.model.StatusCodes;
-import akka.http.javadsl.model.ws.Message;
-import akka.http.javadsl.model.ws.TextMessage;
-import akka.http.javadsl.model.ws.WebSocketRequest;
-import akka.http.javadsl.model.ws.WebSocketUpgradeResponse;
-import akka.japi.Pair;
-import akka.stream.alpakka.jms.JmsConsumerSettings;
-import akka.stream.alpakka.jms.JmsProducerSettings;
-import akka.stream.alpakka.jms.javadsl.JmsConsumer;
-import akka.stream.alpakka.jms.javadsl.JmsConsumerControl;
-import akka.stream.alpakka.jms.javadsl.JmsProducer;
-import akka.stream.javadsl.Flow;
-import akka.stream.javadsl.Keep;
-import akka.stream.javadsl.Sink;
-import akka.stream.javadsl.Source;
+import static org.apache.pekko.actor.typed.javadsl.Adapter.toClassic;
+
+import org.apache.pekko.Done;
+import org.apache.pekko.actor.typed.ActorSystem;
+import org.apache.pekko.actor.typed.javadsl.Behaviors;
+import org.apache.pekko.http.javadsl.Http;
+import org.apache.pekko.http.javadsl.model.StatusCodes;
+import org.apache.pekko.http.javadsl.model.ws.Message;
+import org.apache.pekko.http.javadsl.model.ws.TextMessage;
+import org.apache.pekko.http.javadsl.model.ws.WebSocketRequest;
+import org.apache.pekko.http.javadsl.model.ws.WebSocketUpgradeResponse;
+import org.apache.pekko.japi.Pair;
+import org.apache.pekko.stream.connectors.jms.JmsConsumerSettings;
+import org.apache.pekko.stream.connectors.jms.JmsProducerSettings;
+import org.apache.pekko.stream.connectors.jms.javadsl.JmsConsumer;
+import org.apache.pekko.stream.connectors.jms.javadsl.JmsConsumerControl;
+import org.apache.pekko.stream.connectors.jms.javadsl.JmsProducer;
+import org.apache.pekko.stream.javadsl.Flow;
+import org.apache.pekko.stream.javadsl.Keep;
+import org.apache.pekko.stream.javadsl.Sink;
+import org.apache.pekko.stream.javadsl.Source;
import playground.ActiveMqBroker;
import playground.WebServer;
-import scala.concurrent.ExecutionContext;
import javax.jms.ConnectionFactory;
+
import java.util.Arrays;
import java.util.List;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.CompletionStage;
import java.util.concurrent.TimeUnit;
+import scala.concurrent.ExecutionContext;
+
// #sample
public class JmsToWebSocket {
@@ -81,17 +84,17 @@ public class JmsToWebSocket {
int parallelism = 4;
Pair<Pair<JmsConsumerControl, CompletionStage<WebSocketUpgradeResponse>>,
CompletionStage<Done>>
pair =
- jmsSource // : String
- .map(
- s -> {
- Message msg = TextMessage.create(s);
- return msg;
- }) // : Message (3)
- .viaMat(webSocketFlow, Keep.both()) // : Message (4)
- .mapAsync(parallelism, this::wsMessageToString) // : String
(5)
- .map(s -> "client received: " + s) // : String (6)
- .toMat(Sink.foreach(System.out::println), Keep.both()) //
(7)
- .run(system);
+ jmsSource // : String
+ .map(
+ s -> {
+ Message msg = TextMessage.create(s);
+ return msg;
+ }) // : Message (3)
+ .viaMat(webSocketFlow, Keep.both()) // : Message (4)
+ .mapAsync(parallelism, this::wsMessageToString) // : String
(5)
+ .map(s -> "client received: " + s) // : String (6)
+ .toMat(Sink.foreach(System.out::println), Keep.both()) //
(7)
+ .run(system);
// #sample
JmsConsumerControl runningSource = pair.first().first();
CompletionStage<WebSocketUpgradeResponse> wsUpgradeResponse =
pair.first().second();
@@ -122,7 +125,9 @@ public class JmsToWebSocket {
// #sample
- /** Convert potentially chunked WebSocket Message to a string. */
+ /**
+ * Convert potentially chunked WebSocket Message to a string.
+ */
private CompletionStage<String> wsMessageToString(Message msg) {
if (msg.isText()) {
TextMessage tMsg = msg.asTextMessage();
diff --git a/pekko-connectors-sample-jms/src/main/resources/application.conf
b/pekko-connectors-sample-jms/src/main/resources/application.conf
index 7bdde8d..77117b1 100644
--- a/pekko-connectors-sample-jms/src/main/resources/application.conf
+++ b/pekko-connectors-sample-jms/src/main/resources/application.conf
@@ -1,5 +1,5 @@
-akka {
- loggers = ["akka.event.slf4j.Slf4jLogger"]
- logging-filter = "akka.event.slf4j.Slf4jLoggingFilter"
+pekko {
+ loggers = ["org.apache.pekko.event.slf4j.Slf4jLogger"]
+ logging-filter = "org.apache.pekko.event.slf4j.Slf4jLoggingFilter"
loglevel = "DEBUG"
}
diff --git a/pekko-connectors-sample-jms/src/main/resources/logback.xml
b/pekko-connectors-sample-jms/src/main/resources/logback.xml
index b6242b4..d3a972d 100644
--- a/pekko-connectors-sample-jms/src/main/resources/logback.xml
+++ b/pekko-connectors-sample-jms/src/main/resources/logback.xml
@@ -7,8 +7,7 @@
</encoder>
</appender>
- <logger name="org.apache" level="WARN"/>
- <logger name="akka" level="WARN"/>
+ <logger name="org.apache.pekko" level="WARN"/>
<root level="debug">
<appender-ref ref="console"/>
diff --git
a/pekko-connectors-sample-jms/src/main/scala/playground/ActiveMqBroker.scala
b/pekko-connectors-sample-jms/src/main/scala/playground/ActiveMqBroker.scala
index 397763f..14c64a4 100644
--- a/pekko-connectors-sample-jms/src/main/scala/playground/ActiveMqBroker.scala
+++ b/pekko-connectors-sample-jms/src/main/scala/playground/ActiveMqBroker.scala
@@ -5,21 +5,21 @@
package playground
import java.util.concurrent.CompletionStage
-
-import akka.Done
import javax.jms.ConnectionFactory
+
+import org.apache.pekko.Done
import org.apache.activemq.ActiveMQConnectionFactory
import org.apache.activemq.broker.BrokerService
-import scala.concurrent.{ExecutionContext, Future}
-import scala.compat.java8.FutureConverters._
+import scala.concurrent.{ ExecutionContext, Future }
+import scala.jdk.FutureConverters._
/**
- * To start an ActiveMQ broker be sure to include these dependencies:
- *
- * "javax.jms" % "jms" % "1.1",
- * "org.apache.activemq" % "activemq-all" % "5.14.4"
- */
+ * To start an ActiveMQ broker be sure to include these dependencies:
+ *
+ * "javax.jms" % "jms" % "1.1",
+ * "org.apache.activemq" % "activemq-all" % "5.16.7"
+ */
class ActiveMqBroker {
var brokerService: Option[BrokerService] = None
@@ -33,7 +33,7 @@ class ActiveMqBroker {
broker
}
- def stopCs(ec: ExecutionContext): CompletionStage[Done] = stop()(ec).toJava
+ def stopCs(ec: ExecutionContext): CompletionStage[Done] = stop()(ec).asJava
def stop()(implicit ec: ExecutionContext): Future[Done] =
brokerService.fold(Future.successful(Done)) { broker =>
diff --git
a/pekko-connectors-sample-jms/src/main/scala/playground/WebServer.scala
b/pekko-connectors-sample-jms/src/main/scala/playground/WebServer.scala
index 29cc3a0..021455f 100644
--- a/pekko-connectors-sample-jms/src/main/scala/playground/WebServer.scala
+++ b/pekko-connectors-sample-jms/src/main/scala/playground/WebServer.scala
@@ -4,29 +4,30 @@
package playground
-import akka.actor.{ActorSystem, Terminated}
-import akka.event.Logging
-import akka.http.scaladsl.model.ws.{BinaryMessage, Message, TextMessage}
-import akka.http.scaladsl.model.{ContentTypes, HttpEntity}
-import akka.http.scaladsl.server.{HttpApp, Route}
-import akka.http.scaladsl.settings.ServerSettings
-import akka.stream.scaladsl.{Flow, GraphDSL, Sink, Source}
-import akka.stream.FlowShape
-import akka.{Done, NotUsed}
+import org.apache.pekko.actor.{ ActorSystem, Terminated }
+import org.apache.pekko.event.Logging
+import org.apache.pekko.http.scaladsl.model.ws.{ BinaryMessage, Message,
TextMessage }
+import org.apache.pekko.http.scaladsl.model.{ ContentTypes, HttpEntity }
+import org.apache.pekko.http.scaladsl.server.{ HttpApp, Route }
+import org.apache.pekko.http.scaladsl.settings.ServerSettings
+import org.apache.pekko.stream.scaladsl.{ Flow, GraphDSL, Sink, Source }
+import org.apache.pekko.stream.FlowShape
+import org.apache.pekko.{ Done, NotUsed }
import scala.concurrent.duration.DurationInt
-import scala.concurrent.{ExecutionContext, Future, Promise}
+import scala.concurrent.{ ExecutionContext, Future, Promise }
import scala.util.Success
class WebServer extends HttpApp {
- implicit val theSystem =
ActorSystem(Logging.simpleName(this).replaceAll("\\$", ""))
- implicit val executionContext = theSystem.dispatcher
+ implicit val theSystem: ActorSystem =
ActorSystem(Logging.simpleName(this).replaceAll("\\$", ""))
+ implicit val executionContext: ExecutionContext = theSystem.dispatcher
private val shutdownPromise = Promise[Done]
- /** Override to do something more interesting on Web socket messages
- *
http://doc.akka.io/docs/akka-http/current/scala/http/websocket-support.html#routing-support
- */
+ /**
+ * Override to do something more interesting on Web socket messages
+ *
https://pekko.apache.org/docs/pekko-http/current/scala/http/websocket-support.html#routing-support
+ */
def websocket: Flow[Message, Message, Any] =
Flow[Message].mapConcat {
case tm: TextMessage =>
@@ -35,8 +36,7 @@ class WebServer extends HttpApp {
Source
.single("Hello ")
.concat(tm.textStream)
- .concat(Source.single("!"))
- ) :: Nil
+ .concat(Source.single("!"))) :: Nil
case bm: BinaryMessage =>
// ignore binary messages but drain content to avoid the stream being
clogged
bm.dataStream.runWith(Sink.ignore)
@@ -44,8 +44,8 @@ class WebServer extends HttpApp {
}
/**
- * Sends out messages on the websocket.
- */
+ * Sends out messages on the websocket.
+ */
def outgoing: Flow[Message, Message, NotUsed] = {
val routingGraph: Flow[Message, Message, NotUsed] =
Flow.fromGraph(GraphDSL.create() { implicit b =>
val in = b.add(Sink.ignore)
@@ -56,9 +56,9 @@ class WebServer extends HttpApp {
}
/**
- * @see
http://doc.akka.io/docs/akka-http/current/scala/http/routing-dsl/overview.html
- *
http://doc.akka.io/docs/akka-http/current/scala/http/routing-dsl/directives/alphabetically.html
- */
+ * @see
https://pekko.apache.org/docs/pekko-http/current/scala/http/routing-dsl/overview.html
+ *
https://pekko.apache.org/docs/pekko-http/current/scala/http/routing-dsl/directives/alphabetically.html
+ */
override def routes: Route =
pathSingleSlash {
complete {
@@ -66,24 +66,24 @@ class WebServer extends HttpApp {
HttpEntity(ContentTypes.`text/html(UTF-8)`, "<html><body>Welcome to
the playground!</body></html>")
}
} ~
- path("hello") {
- get { ctx =>
- ctx.complete {
- println(s"Web server received ${ctx.request}")
- HttpEntity(ContentTypes.`application/json`, """{ msg: "Hi!" }""")
- }
+ path("hello") {
+ get { ctx =>
+ ctx.complete {
+ println(s"Web server received ${ctx.request}")
+ HttpEntity(ContentTypes.`application/json`, """{ msg: "Hi!" }""")
}
- } ~
- pathPrefix("webSocket") {
- path("ping") {
- // connect e.g. with
Http().webSocketClientFlow(WebSocketRequest("ws://localhost:8080/webSocket/ping"))
- println("Web server received webSocket/ping connect")
- handleWebSocketMessages(websocket)
- } // ~
- // path("outgoing") {
- // handleWebSocketMessages(outgoing)
- // }
}
+ } ~
+ pathPrefix("webSocket") {
+ path("ping") {
+ // connect e.g. with
Http().webSocketClientFlow(WebSocketRequest("ws://localhost:8080/webSocket/ping"))
+ println("Web server received webSocket/ping connect")
+ handleWebSocketMessages(websocket)
+ } // ~
+ // path("outgoing") {
+ // handleWebSocketMessages(outgoing)
+ // }
+ }
override protected def postHttpBindingFailure(cause: Throwable): Unit =
println(s"The server could not be started due to $cause")
diff --git
a/pekko-connectors-sample-jms/src/main/scala/samples/scaladsl/JmsSampleBase.scala
b/pekko-connectors-sample-jms/src/main/scala/samples/scaladsl/JmsSampleBase.scala
index 819fae0..9e2a5cf 100644
---
a/pekko-connectors-sample-jms/src/main/scala/samples/scaladsl/JmsSampleBase.scala
+++
b/pekko-connectors-sample-jms/src/main/scala/samples/scaladsl/JmsSampleBase.scala
@@ -4,15 +4,15 @@
package samples.scaladsl
-import akka.Done
-import akka.actor.typed.ActorSystem
-import akka.actor.typed.scaladsl.Behaviors
-import akka.stream.alpakka.jms.JmsProducerSettings
-import akka.stream.alpakka.jms.scaladsl.JmsProducer
-import akka.stream.scaladsl.{Sink, Source}
-import javax.jms.ConnectionFactory
+import org.apache.pekko.Done
+import org.apache.pekko.actor.typed.ActorSystem
+import org.apache.pekko.actor.typed.scaladsl.Behaviors
+import org.apache.pekko.stream.connectors.jms.scaladsl.JmsProducer
+import org.apache.pekko.stream.connectors.jms.JmsProducerSettings
+import org.apache.pekko.stream.scaladsl.{ Sink, Source }
-import scala.concurrent.{Await, ExecutionContext, Future}
+import javax.jms.ConnectionFactory
+import scala.concurrent.{ Await, ExecutionContext, Future }
import scala.concurrent.duration._
class JmsSampleBase {
@@ -30,8 +30,7 @@ class JmsSampleBase {
def enqueue(connectionFactory: ConnectionFactory)(msgs: String*): Unit = {
val jmsSink: Sink[String, Future[Done]] =
JmsProducer.textSink(
- JmsProducerSettings(system, connectionFactory).withQueue("test")
- )
+ JmsProducerSettings(system, connectionFactory).withQueue("test"))
Source(msgs.toList).runWith(jmsSink)
}
}
diff --git
a/pekko-connectors-sample-jms/src/main/scala/samples/scaladsl/JmsToFile.scala
b/pekko-connectors-sample-jms/src/main/scala/samples/scaladsl/JmsToFile.scala
index 4521edc..2a813c0 100644
---
a/pekko-connectors-sample-jms/src/main/scala/samples/scaladsl/JmsToFile.scala
+++
b/pekko-connectors-sample-jms/src/main/scala/samples/scaladsl/JmsToFile.scala
@@ -6,12 +6,11 @@ package samples.scaladsl
// #sample
import java.nio.file.Paths
-
-import akka.stream.IOResult
-import akka.stream.alpakka.jms.JmsConsumerSettings
-import akka.stream.alpakka.jms.scaladsl.{JmsConsumer, JmsConsumerControl}
-import akka.stream.scaladsl.{FileIO, Keep, Sink, Source}
-import akka.util.ByteString
+import org.apache.pekko.stream.IOResult
+import org.apache.pekko.stream.connectors.jms.scaladsl.{ JmsConsumer,
JmsConsumerControl }
+import org.apache.pekko.stream.connectors.jms.JmsConsumerSettings
+import org.apache.pekko.stream.scaladsl.{ FileIO, Keep, Sink, Source }
+import org.apache.pekko.util.ByteString
import scala.concurrent.Future
import scala.concurrent.duration.DurationInt
diff --git
a/pekko-connectors-sample-jms/src/main/scala/samples/scaladsl/JmsToHttpGet.scala
b/pekko-connectors-sample-jms/src/main/scala/samples/scaladsl/JmsToHttpGet.scala
index 99eb75d..002a4e5 100644
---
a/pekko-connectors-sample-jms/src/main/scala/samples/scaladsl/JmsToHttpGet.scala
+++
b/pekko-connectors-sample-jms/src/main/scala/samples/scaladsl/JmsToHttpGet.scala
@@ -5,20 +5,19 @@
package samples.scaladsl
// #sample
-import akka.Done
-import akka.actor.typed.scaladsl.adapter._
-import akka.http.scaladsl.Http
-import akka.http.scaladsl.model._
-import akka.stream.alpakka.jms.JmsConsumerSettings
-import akka.stream.alpakka.jms.scaladsl.{JmsConsumer, JmsConsumerControl}
-import akka.stream.scaladsl.{Keep, Sink, Source}
-import akka.util.ByteString
+import org.apache.pekko.Done
+import org.apache.pekko.http.scaladsl.Http
+import org.apache.pekko.http.scaladsl.model._
+import org.apache.pekko.stream.connectors.jms.scaladsl.{ JmsConsumer,
JmsConsumerControl }
+import org.apache.pekko.stream.connectors.jms.JmsConsumerSettings
+import org.apache.pekko.stream.scaladsl.{ Keep, Sink, Source }
+import org.apache.pekko.util.ByteString
import scala.concurrent.Future
import scala.concurrent.duration.DurationInt
// #sample
-import playground.{ActiveMqBroker, WebServer}
+import playground.{ ActiveMqBroker, WebServer }
object JmsToHttpGet extends JmsSampleBase with App {
diff --git
a/pekko-connectors-sample-jms/src/main/scala/samples/scaladsl/JmsToOneFilePerMessage.scala
b/pekko-connectors-sample-jms/src/main/scala/samples/scaladsl/JmsToOneFilePerMessage.scala
index 0256ad8..fe2798a 100644
---
a/pekko-connectors-sample-jms/src/main/scala/samples/scaladsl/JmsToOneFilePerMessage.scala
+++
b/pekko-connectors-sample-jms/src/main/scala/samples/scaladsl/JmsToOneFilePerMessage.scala
@@ -5,13 +5,12 @@
package samples.scaladsl
// #sample
-import java.nio.file.Paths
-
-import akka.stream.alpakka.jms.JmsConsumerSettings
-import akka.stream.alpakka.jms.scaladsl.{JmsConsumer, JmsConsumerControl}
-import akka.stream.scaladsl.{FileIO, Keep, Sink, Source}
-import akka.util.ByteString
+import org.apache.pekko.stream.connectors.jms.JmsConsumerSettings
+import org.apache.pekko.stream.connectors.jms.scaladsl.{JmsConsumer,
JmsConsumerControl}
+import org.apache.pekko.stream.scaladsl.{FileIO, Keep, Sink, Source}
+import org.apache.pekko.util.ByteString
+import java.nio.file.Paths
import scala.concurrent.duration.DurationInt
// #sample
import playground.ActiveMqBroker
diff --git
a/pekko-connectors-sample-jms/src/main/scala/samples/scaladsl/JmsToWebSocket.scala
b/pekko-connectors-sample-jms/src/main/scala/samples/scaladsl/JmsToWebSocket.scala
index a5e6fdc..61a48df 100644
---
a/pekko-connectors-sample-jms/src/main/scala/samples/scaladsl/JmsToWebSocket.scala
+++
b/pekko-connectors-sample-jms/src/main/scala/samples/scaladsl/JmsToWebSocket.scala
@@ -5,18 +5,18 @@
package samples.scaladsl
// #sample
-import akka.Done
-import akka.http.scaladsl.Http
-import akka.http.scaladsl.model._
-import akka.actor.typed.scaladsl.adapter._
-import akka.http.scaladsl.model.ws.{WebSocketRequest, WebSocketUpgradeResponse}
-import akka.stream.alpakka.jms.JmsConsumerSettings
-import akka.stream.alpakka.jms.scaladsl.{JmsConsumer, JmsConsumerControl}
-import akka.stream.scaladsl.{Flow, Keep, Sink, Source}
+import org.apache.pekko.Done
+import org.apache.pekko.http.scaladsl.Http
+import org.apache.pekko.http.scaladsl.model._
+import org.apache.pekko.actor.typed.scaladsl.adapter._
+import org.apache.pekko.http.scaladsl.model.ws.{ WebSocketRequest,
WebSocketUpgradeResponse }
+import org.apache.pekko.stream.connectors.jms.scaladsl.{ JmsConsumer,
JmsConsumerControl }
+import org.apache.pekko.stream.connectors.jms.JmsConsumerSettings
+import org.apache.pekko.stream.scaladsl.{ Flow, Keep, Sink, Source }
import scala.concurrent.Future
// #sample
-import playground.{ActiveMqBroker, WebServer}
+import playground.{ ActiveMqBroker, WebServer }
import scala.concurrent.duration.DurationInt
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
