Andrej Petras
Andrej Petras
Hi, I solve it differently. ```yaml apiVersion: argoproj.io/v1alpha1 kind: ApplicationSet metadata: name: test spec: generators: - git: repoURL: [email protected]:1000kit/playground/local/env.git revision: test2 files: - path: '*.yaml' template: metadata: name: '{{path.basename}}-test-local' spec:...
@jgwest I agree, my solution is only PoC for my use case. `global.yml` is a temporary solution. `JSON flattened` doesn't work for me. I want to add a "values" structure...
@marcozov is working for me. The downside is that you can not do this: `{{ parent.value.attribute }}`. You have only `{{ parent }}` which represents string. @mksha I like `go...
Hi @stefanprodan, @hiddeco, @squaremo we want to use the **fluxcd** in the large project (multiple teams, multiple services) but the release process should be based on helm chart version and...
I end up with my database migration solution which is using only the reactive drivers. https://github.com/lorislab/quarkus-barn I did look on the Flyway and Liquibase implementation, but they are strongly linked...
Does this depend on the `@Acknowledgment`? I am not sure if my test was correct but I have a method without `@Acknowledgment` and first was `ack` on incoming message and...
In my case I would like to have one acknowledgment after received message and sent all out-going messages. 1. receive message - consumer.receive() 2. send messages - producer.send(...) 3. commit...
``` @Acknowledgment(Acknowledgment.Strategy.MANUAL) public PublisherBuilder message(Message input) { String data = input.getPayload(); return ReactiveStreams.of(Message.of("RESULT_1 " + data), Message.of("RESULT_2 " + data)) .onComplete(() -> { // input.commit(); // input.ack() -> JMSContext.commit() input.ack();...
In the end, I had this solution ```java @Incoming("input") @Acknowledgment(Acknowledgment.Strategy.MANUAL) public CompletionStage message(IncomingJmsTxMessage input) { try { ... // optional send message input.send(Message.of("Output")); // session commit return input.ack(); } catch...