xstefank

diff --git a/tyr-core/src/test/java/org/jboss/tyr/TestUtils.java b/tyr-core/src/test/java/org/jboss/tyr/TestUtils.java
index ab47155..f790417 100644
--- a/tyr-core/src/test/java/org/jboss/tyr/TestUtils.java
+++ b/tyr-core/src/test/java/org/jboss/tyr/TestUtils.java
@@ -46,6 +46,7 @@ public class TestUtils {
     public static final JsonObject EMPTY_PAYLOAD = createEmptyJsonPayload();
 
     public static final JsonArray TEST_COMMITS_PAYLOAD = loadJsonArray(JSON_DIR + "/testCommitsPayload.json");
+    public static final JsonArray MULTIPLE_COMMIT_MESSAGES_PAYLOAD = loadJsonArray(JSON_DIR + "/multipleCommitMessagesPayload.json");
 

xstefank

diff --git a/tyr-core/src/test/java/org/jboss/tyr/TestUtils.java b/tyr-core/src/test/java/org/jboss/tyr/TestUtils.java
index ab47155..f790417 100644
--- a/tyr-core/src/test/java/org/jboss/tyr/TestUtils.java
+++ b/tyr-core/src/test/java/org/jboss/tyr/TestUtils.java
@@ -46,6 +46,7 @@ public class TestUtils {
     public static final JsonObject EMPTY_PAYLOAD = createEmptyJsonPayload();
 
     public static final JsonArray TEST_COMMITS_PAYLOAD = loadJsonArray(JSON_DIR + "/testCommitsPayload.json");
+    public static final JsonArray MULTIPLE_COMMIT_MESSAGES_PAYLOAD = loadJsonArray(JSON_DIR + "/multipleCommitMessagesPayload.json");
 

xstefank

package io.narayana.lra.arquillian.resource;

import org.eclipse.microprofile.lra.annotation.ws.rs.LRA;

import javax.ws.rs.GET;
import javax.ws.rs.HeaderParam;
import javax.ws.rs.Path;
import javax.ws.rs.core.Response;
import java.net.URI;

xstefank

// This may be required but it won't compile without adding additional parameter to one of the methods

public SmallRyeHealth getLiveness() {
    return getHealth(livenessChecks);
}

public ExtendedSmallRyeHealth getLiveness() {
    return null;
}

xstefank

@Path("reused-participant")
public class ReusedParticipant2 {

    @GET
    @Path("reused-endpoint")
    // no LRA annotation!
    public Object reusedEndpoint(@HeaderParam("flow-type") String flowType) {
        if (flowType.equals("first-flow")) {
            selfRestInvoke("first-flow");
        } else if (flowType.equals("second-flow")) {

xstefank

@Path("participant")
public class ReusedParticipant {
    @GET
    @Path("first-flow")
    @LRA(LRA.Type.MANDATORY)
    public Object firstFlow(@HeaderParam(LRA_HTTP_CONTEXT_HEADER) URI lraId) {
        // ...
    }

    @GET

xstefank

## Orders topic
mp.messaging.outgoing.orders.connector=smallrye-kafka
mp.messaging.outgoing.orders.value.serializer=org.apache.kafka.common.serialization.StringSerializer

## Beverage / queue topic
mp.messaging.incoming.beverages.connector=smallrye-kafka
mp.messaging.incoming.beverages.topic=queue
mp.messaging.incoming.beverages.value.deserializer=org.apache.kafka.common.serialization.StringDeserializer

## Queue topic - write

xstefank

## Orders topic
mp.messaging.incoming.orders.connector=smallrye-kafka
mp.messaging.incoming.orders.topic=orders
mp.messaging.incoming.orders.bootstrap.servers=localhost:9092
mp.messaging.incoming.orders.key.deserializer=org.apache.kafka.common.serialization.StringDeserializer
mp.messaging.incoming.orders.value.deserializer=org.apache.kafka.common.serialization.StringDeserializer
mp.messaging.incoming.orders.enable.auto.commit=false
mp.messaging.incoming.orders.auto.offset.reset=earliest
mp.messaging.incoming.orders.group.id=baristas

xstefank

package io.xstefank;

import org.eclipse.microprofile.lra.annotation.Compensate;
import org.eclipse.microprofile.lra.annotation.Complete;
import org.eclipse.microprofile.lra.annotation.ws.rs.LRA;

import javax.ws.rs.GET;
import javax.ws.rs.HeaderParam;
import javax.ws.rs.PUT;
import javax.ws.rs.Path;

xstefank

package org.eclipse.microprofile.lra.tck.participant.nonjaxrs.valid;

import org.eclipse.microprofile.lra.annotation.Compensate;
import org.eclipse.microprofile.lra.annotation.ParticipantStatus;
import org.eclipse.microprofile.lra.annotation.Status;
import org.eclipse.microprofile.lra.annotation.ws.rs.LRA;

import javax.ws.rs.GET;
import javax.ws.rs.HeaderParam;
import javax.ws.rs.Path;