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/pekko-connectors.git
The following commit(s) were added to refs/heads/main by this push:
new b0a0bf240 some small jakarta ms branding changes (#719)
b0a0bf240 is described below
commit b0a0bf24031ce0eeb134a1c62b01715807562abc
Author: PJ Fanning <[email protected]>
AuthorDate: Thu Jul 4 00:21:37 2024 +0100
some small jakarta ms branding changes (#719)
---
jakartams/src/main/resources/reference.conf | 2 +-
.../pekko/stream/connectors/jakartams/impl/JmsAckSourceStage.scala | 2 +-
.../pekko/stream/connectors/jakartams/impl/JmsTxSourceStage.scala | 2 +-
3 files changed, 3 insertions(+), 3 deletions(-)
diff --git a/jakartams/src/main/resources/reference.conf
b/jakartams/src/main/resources/reference.conf
index 4243e1da4..c01904f56 100644
--- a/jakartams/src/main/resources/reference.conf
+++ b/jakartams/src/main/resources/reference.conf
@@ -1,6 +1,6 @@
# SPDX-License-Identifier: Apache-2.0
-# Settings for the Apache Pekko Connectors JMS connector
+# Settings for the Apache Pekko Connectors JakartaMS connector
#
pekko.connectors.jakartams {
#connection-retry
diff --git
a/jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl/JmsAckSourceStage.scala
b/jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl/JmsAckSourceStage.scala
index 28fbb32e2..e04b4fbca 100644
---
a/jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl/JmsAckSourceStage.scala
+++
b/jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl/JmsAckSourceStage.scala
@@ -28,7 +28,7 @@ import pekko.stream.{ Attributes, Outlet, SourceShape }
private[jakartams] final class JmsAckSourceStage(settings:
JmsConsumerSettings, destination: Destination)
extends GraphStageWithMaterializedValue[SourceShape[AckEnvelope],
JmsConsumerMatValue] {
- private val out = Outlet[AckEnvelope]("JmsSource.out")
+ private val out = Outlet[AckEnvelope]("JakartaMsSource.out")
override def shape: SourceShape[AckEnvelope] = SourceShape[AckEnvelope](out)
diff --git
a/jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl/JmsTxSourceStage.scala
b/jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl/JmsTxSourceStage.scala
index be8bc499e..cc18708aa 100644
---
a/jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl/JmsTxSourceStage.scala
+++
b/jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl/JmsTxSourceStage.scala
@@ -29,7 +29,7 @@ import scala.concurrent.{ Await, TimeoutException }
private[jakartams] final class JmsTxSourceStage(settings: JmsConsumerSettings,
destination: Destination)
extends GraphStageWithMaterializedValue[SourceShape[TxEnvelope],
JmsConsumerMatValue] {
- private val out = Outlet[TxEnvelope]("JmsSource.out")
+ private val out = Outlet[TxEnvelope]("JakartaMsSource.out")
override def shape: SourceShape[TxEnvelope] = SourceShape[TxEnvelope](out)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
