-
Notifications
You must be signed in to change notification settings - Fork 558
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
JMS Reactive Messaging connector #2282
Conversation
9e85205
to
efe7dc3
Compare
78131db
to
68d64bb
Compare
examples/messaging/jms-websocket-mp/src/main/java/io/helidon/messaging/mp/example/Main.java
Outdated
Show resolved
Hide resolved
...saging/jms-websocket-mp/src/main/java/io/helidon/messaging/mp/example/MsgProcessingBean.java
Outdated
Show resolved
Hide resolved
...saging/jms-websocket-mp/src/main/java/io/helidon/messaging/mp/example/WebSocketEndpoint.java
Outdated
Show resolved
Hide resolved
messaging/aq/src/main/java/io/helidon/messaging/connectors/aq/AqConnector.java
Outdated
Show resolved
Hide resolved
messaging/aq/src/main/java/io/helidon/messaging/connectors/aq/AqMessage.java
Outdated
Show resolved
Hide resolved
messaging/jms/src/main/java/io/helidon/messaging/connectors/jms/SessionMetadata.java
Outdated
Show resolved
Hide resolved
messaging/messaging/src/main/java/io/helidon/messaging/MessagingException.java
Outdated
Show resolved
Hide resolved
messaging/jms/src/main/java/io/helidon/messaging/connectors/jms/JmsMessage.java
Outdated
Show resolved
Hide resolved
messaging/jms/src/main/java/io/helidon/messaging/connectors/jms/JmsMessage.java
Outdated
Show resolved
Hide resolved
Awesome work. I think we need a full processor example where incoming and outgoing are both AQ connector channels. I'm still hitting the issues we've discussed offline. |
...oracle-aq-websocket-mp/src/main/java/io/helidon/examples/messaging/mp/MsgProcessingBean.java
Show resolved
Hide resolved
a7cf277
to
ff8f60e
Compare
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Looks good and I will do additional testing with it once it's in as well. Great work.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM
c41dba9
to
077f745
Compare
Signed-off-by: Daniel Kec <daniel.kec@oracle.com> Checkstyle Signed-off-by: Daniel Kec <daniel.kec@oracle.com> Checkstyle 2 Signed-off-by: Daniel Kec <daniel.kec@oracle.com> Copyright Signed-off-by: Daniel Kec <daniel.kec@oracle.com>
Custom mapper support for outgoing messages Checkstyle fix Signed-off-by: Daniel Kec <daniel.kec@oracle.com> Copyright fix Signed-off-by: Daniel Kec <daniel.kec@oracle.com> Remove final params Signed-off-by: Daniel Kec <daniel.kec@oracle.com> Review issues Signed-off-by: Daniel Kec <daniel.kec@oracle.com> Fix examples readme Signed-off-by: Daniel Kec <daniel.kec@oracle.com> Fix examples readme 2 Signed-off-by: Daniel Kec <daniel.kec@oracle.com>
Signed-off-by: Daniel Kec <daniel.kec@oracle.com>
Signed-off-by: Daniel Kec <daniel.kec@oracle.com>
Signed-off-by: Daniel Kec <daniel.kec@oracle.com>
Signed-off-by: Daniel Kec <daniel.kec@oracle.com>
Signed-off-by: Daniel Kec <daniel.kec@oracle.com>
Signed-off-by: Daniel Kec <daniel.kec@oracle.com>
Signed-off-by: Daniel Kec <daniel.kec@oracle.com>
<dependency> | ||
<groupId>io.helidon.messaging.aq</groupId> | ||
<artifactId>helidon-messaging-aq</artifactId> | ||
<version>${helidon.version}</version> | ||
</dependency> |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Hello, I couldn't see this being resolved. May I know if its available for public?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Hi, helidon-messaging-aq is part of this PR, it needs to be accepted, merged and then released with new version of Helidon
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Got it, thanks for the update.
Signed-off-by: Daniel Kec <daniel.kec@oracle.com>
Signed-off-by: Daniel Kec <daniel.kec@oracle.com>
Signed-off-by: Daniel Kec <daniel.kec@oracle.com>
Signed-off-by: Daniel Kec <daniel.kec@oracle.com>
Signed-off-by: Daniel Kec <daniel.kec@oracle.com>
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM
And Oracle AQ connector based on JMS connector.
Messaging example connecting to OCI autonomous database: https://github.com/danielkec/helidon-messaging-oracle-aq
Signed-off-by: Daniel Kec daniel.kec@oracle.com
Config description in the issue #2098