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 d5cc65632 jms: move java source to src/main/java (#720)
d5cc65632 is described below
commit d5cc65632a6039cbc9cd61a0e34c65f3ffe8eeed
Author: PJ Fanning <[email protected]>
AuthorDate: Wed Jul 3 21:06:36 2024 +0100
jms: move java source to src/main/java (#720)
* jms: move java source to src/main/java
* javafmt
---
.../pekko/stream/connectors/jms/javadsl/JmsConnectorState.java | 10 +++++++---
.../stream/connectors/jms/javadsl/JmsConsumerControl.java | 10 +++++-----
.../pekko/stream/connectors/jms/javadsl/JmsProducerStatus.java | 10 +++++-----
3 files changed, 17 insertions(+), 13 deletions(-)
diff --git
a/jms/src/main/scala/org/apache/pekko/stream/connectors/jms/javadsl/JmsConnectorState.java
b/jms/src/main/java/org/apache/pekko/stream/connectors/jms/javadsl/JmsConnectorState.java
similarity index 83%
rename from
jms/src/main/scala/org/apache/pekko/stream/connectors/jms/javadsl/JmsConnectorState.java
rename to
jms/src/main/java/org/apache/pekko/stream/connectors/jms/javadsl/JmsConnectorState.java
index 703cd0e6c..33fa23cf6 100644
---
a/jms/src/main/scala/org/apache/pekko/stream/connectors/jms/javadsl/JmsConnectorState.java
+++
b/jms/src/main/java/org/apache/pekko/stream/connectors/jms/javadsl/JmsConnectorState.java
@@ -14,7 +14,11 @@
package org.apache.pekko.stream.connectors.jms.javadsl;
public enum JmsConnectorState {
-
- Disconnected, Connecting, Connected, Completing, Completed, Failing, Failed
-
+ Disconnected,
+ Connecting,
+ Connected,
+ Completing,
+ Completed,
+ Failing,
+ Failed
}
diff --git
a/jms/src/main/scala/org/apache/pekko/stream/connectors/jms/javadsl/JmsConsumerControl.java
b/jms/src/main/java/org/apache/pekko/stream/connectors/jms/javadsl/JmsConsumerControl.java
similarity index 72%
rename from
jms/src/main/scala/org/apache/pekko/stream/connectors/jms/javadsl/JmsConsumerControl.java
rename to
jms/src/main/java/org/apache/pekko/stream/connectors/jms/javadsl/JmsConsumerControl.java
index f89dc1d27..d7a64a6e6 100644
---
a/jms/src/main/scala/org/apache/pekko/stream/connectors/jms/javadsl/JmsConsumerControl.java
+++
b/jms/src/main/java/org/apache/pekko/stream/connectors/jms/javadsl/JmsConsumerControl.java
@@ -19,9 +19,9 @@ import org.apache.pekko.stream.javadsl.Source;
public interface JmsConsumerControl extends KillSwitch {
- /**
- * source that provides connector status change information.
- * Only the most recent connector state is buffered if the source is not
consumed.
- */
- Source<JmsConnectorState, NotUsed> connectorState();
+ /**
+ * source that provides connector status change information. Only the most
recent connector state
+ * is buffered if the source is not consumed.
+ */
+ Source<JmsConnectorState, NotUsed> connectorState();
}
diff --git
a/jms/src/main/scala/org/apache/pekko/stream/connectors/jms/javadsl/JmsProducerStatus.java
b/jms/src/main/java/org/apache/pekko/stream/connectors/jms/javadsl/JmsProducerStatus.java
similarity index 70%
rename from
jms/src/main/scala/org/apache/pekko/stream/connectors/jms/javadsl/JmsProducerStatus.java
rename to
jms/src/main/java/org/apache/pekko/stream/connectors/jms/javadsl/JmsProducerStatus.java
index 25a9cd967..7fcf0215a 100644
---
a/jms/src/main/scala/org/apache/pekko/stream/connectors/jms/javadsl/JmsProducerStatus.java
+++
b/jms/src/main/java/org/apache/pekko/stream/connectors/jms/javadsl/JmsProducerStatus.java
@@ -18,9 +18,9 @@ import org.apache.pekko.stream.javadsl.Source;
public interface JmsProducerStatus {
- /**
- * source that provides connector status change information.
- * Only the most recent connector state is buffered if the source is not
consumed.
- */
- Source<JmsConnectorState, NotUsed> connectorState();
+ /**
+ * source that provides connector status change information. Only the most
recent connector state
+ * is buffered if the source is not consumed.
+ */
+ Source<JmsConnectorState, NotUsed> connectorState();
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
