Andrea Selva

Hi @fjcyue this issue is still valid after integration of deepCopy from PR #365? If not it could be closed

Not at the moment. Actually I'm busy in implementing a segmented queues implementation in #638, so I expected to work on the MQTT5 after that landed.

@OleksandrBerezianskyi you missed the publisher client part. I mean the error here relates to the fact that `PubRelMarker` can't be cast to `PublishedMessage` due to a timeout of a message...

Please file a request with more details, "bridging to a cloud broker" is not so clear to understand what you mean

You have to write some code to bridge it. Moquette exposes a set of Interceptor callback interfaces, you can implement the one you are interested in (for example a forwarder...

Hi Chris if you say "pause for 2-3 srconds" and than your client doesn't get notified seems like the timeout for missed activity on the channel gets triggered abd drop...

I mean when the keepalive time is set, https://github.com/andsel/moquette/blob/master/broker/src/main/java/io/moquette/spi/impl/ProtocolProcessor.java#L281

I've done some local test with `file-input` in various Logstash version running on JDK8 and JDK11, the results are: | | JDK 8 | JDK 11 | |----------------|--------|--------| | Logstash...

@hkelly when you delete the uncompressed file, do you also use the * shell expansion or point to a single file? Could you try with the latest `4.1.14` version of...

I've tried with this: - created sample text file in `/tmp` with ``` echo "blabla1" > ls_file_test1.txt && gzip ls_file_test1.txt && echo "blabla2" > ls_file_test2.txt && gzip ls_file_test2.txt ``` -...