quarkus-reactive-jms-tx

Quarkus reactive JMS transaction stream extension

License

License

Categories

Categories

Quarkus Container Microservices React User Interface Web Frameworks
GroupId

GroupId

org.lorislab.quarkus
ArtifactId

ArtifactId

quarkus-reactive-jms-tx
Last Version

Last Version

0.1.1
Release Date

Release Date

Type

Type

jar
Description

Description

quarkus-reactive-jms-tx
Quarkus reactive JMS transaction stream extension
Project Organization

Project Organization

p6

Download quarkus-reactive-jms-tx

How to add to project

<!-- https://jarcasting.com/artifacts/org.lorislab.quarkus/quarkus-reactive-jms-tx/ -->
<dependency>
    <groupId>org.lorislab.quarkus</groupId>
    <artifactId>quarkus-reactive-jms-tx</artifactId>
    <version>0.1.1</version>
</dependency>
// https://jarcasting.com/artifacts/org.lorislab.quarkus/quarkus-reactive-jms-tx/
implementation 'org.lorislab.quarkus:quarkus-reactive-jms-tx:0.1.1'
// https://jarcasting.com/artifacts/org.lorislab.quarkus/quarkus-reactive-jms-tx/
implementation ("org.lorislab.quarkus:quarkus-reactive-jms-tx:0.1.1")
'org.lorislab.quarkus:quarkus-reactive-jms-tx:jar:0.1.1'
<dependency org="org.lorislab.quarkus" name="quarkus-reactive-jms-tx" rev="0.1.1">
  <artifact name="quarkus-reactive-jms-tx" type="jar" />
</dependency>
@Grapes(
@Grab(group='org.lorislab.quarkus', module='quarkus-reactive-jms-tx', version='0.1.1')
)
libraryDependencies += "org.lorislab.quarkus" % "quarkus-reactive-jms-tx" % "0.1.1"
[org.lorislab.quarkus/quarkus-reactive-jms-tx "0.1.1"]

Dependencies

compile (5)

Group / Artifact Type Version
org.lorislab.quarkus : quarkus-reactive-jms-tx-impl jar 0.1.1
io.quarkus : quarkus-jsonb jar
io.quarkus : quarkus-mutiny jar
io.quarkus : quarkus-smallrye-reactive-streams-operators jar
io.quarkus : quarkus-smallrye-reactive-messaging jar

Project Modules

There are no modules declared in this project.

quarkus-reactive-jms-tx

Quarkus reactive JMS Session SESSION_TRANSACTED receiver.

License GitHub Workflow Status (branch) GitHub tag (latest SemVer) Maven Central

Example

@Incoming("input")
@Acknowledgment(Acknowledgment.Strategy.MANUAL)
public CompletionStage<Void> message(IncomingJmsTxMessage<Data> input) {
    try {    
      ...
      // optional send message
      input.send(Message.of("Output"));
        
      // session commit
      return input.ack();
    } catch (Exception ex) {
        // session rollback
        return input.rollback();
    }
}

Create a release

mvn semver-release:release-create

Create a patch branch

mvn semver-release:patch-create -DpatchVersion=x.x.0
org.lorislab.quarkus

lorislab

Versions

Version
0.1.1