smallrye-reactive-messaging

smallrye-reactive-messaging copied to clipboard

MQTT - Add support for Qos=2 for Mqtt Session

2

Missing QoS implementation When configure application.properties. ``` mp.messaging.incoming..qos=2 ``` Hit error. ``` Caused by: java.lang.IllegalArgumentException: SRMSG17001: Invalid QoS value: 2 146at io.smallrye.reactive.messaging.mqtt.session.RequestedQoS.valueOf(RequestedQoS.java:34) 147at io.smallrye.reactive.messaging.mqtt.MqttSource.(MqttSource.java:57) 148at io.smallrye.reactive.messaging.mqtt.MqttConnector.getPublisher(MqttConnector.java:88) ``` Note "This is...

kahlai

ExactlyOnceProcessingBatchTest.testExactlyOnceProcessorWithProcessingError

ozangunalp

OpenTelemetry is sometimes requested before it is created and thus build fails

1

I experienced this issue just once here https://github.com/quarkus-qe/beefy-scenarios/actions/runs/5770827990/job/15644520776?pr=404 and can't reproduce it, but judging by logs it seems like the order of build items is not ensured so that `KafkaOpenTelemetryInstrumenter`...

michalvavrik

Add support for request/reply

1

Using a specific emitter type it should be possible to implement the request/reply interaction scheme for connectors supporting it (RabbitMQ, AMQP 1.0).

cescoffier

cescoffier

cescoffier

cescoffier

cescoffier

cescoffier

cescoffier