Carsten Lohmann
Carsten Lohmann
A note about MQTT, thinking about possible future MQTT 5 support (see #2955): In MQTT 5, a response topic can be given when publishing a message: https://docs.oasis-open.org/mqtt/mqtt/v5.0/os/mqtt-v5.0-os.html#_Toc3901114 https://docs.oasis-open.org/mqtt/mqtt/v5.0/os/mqtt-v5.0-os.html#_Request_/_Response Important to...
It might be because test-tenant related Kafka topics get deleted in the tests too early (although we already apply a considerable delay) and then the Kafka blocks while repeatedly trying...
Fixed via #3382.
And _if_ we found a case where the delivery processing handler was run in a non-vert.x thread, potentially causing such a race condition, we would have to fix that by...
Some background info here: Let's suppose a running LoRa adapter container contains 4 `LoraProtocolAdapter` verticle instances. Each of that instance refers to a separate `InternalCommandConsumer` instance, keeping its own adapterInstanceId...
Along with the modifications here, a change towards using the `DeviceChangeNotification` mechanism for removing obsolete command consumers can also be done here. See: https://github.com/eclipse-hono/hono/issues/2704#issuecomment-1246754628
Similar kind of exception, during "get Tenant by ID" invocation: ``` java.lang.IllegalStateException: The pool is closed at com.mongodb.internal.connection.ConcurrentPool.poolClosedException(ConcurrentPool.java:296) at com.mongodb.internal.connection.ConcurrentPool.get(ConcurrentPool.java:144) at com.mongodb.internal.connection.ConcurrentPool.get(ConcurrentPool.java:130) at com.mongodb.internal.session.ServerSessionPool.get(ServerSessionPool.java:84) at com.mongodb.internal.session.BaseClientSessionImpl.(BaseClientSessionImpl.java:49) at com.mongodb.reactivestreams.client.internal.ClientSessionPublisherImpl.(ClientSessionPublisherImpl.java:57) at com.mongodb.reactivestreams.client.internal.ClientSessionHelper.createClientSession(ClientSessionHelper.java:90)...
@sophokles73 I'm still on it, yes. But I think this should be merged after the 2.0.0 release.
@sophokles73 Not yet.
I've added the `lifecycleStatus` handling now directly in `ProtonBasedApplicationClient` in order to implement the added `addOnClientReadyHandler` method. Changing `AbstractServiceClient` would have meant a lot more changes.