Arnaud Cogoluègnes
Arnaud Cogoluègnes
`Predicate` is a JDK 8 API and Lyra 0.5.x minimum JDK version is 1.6, so this would need to go into a major release, e.g. 1.x.
The static executor service scopes all the connections created in the process. Stopping it for a connection would make the recovery impossible for all the other connections created in the...
Good point. We already use the `stream` prefix for the [stream plugin](https://github.com/rabbitmq/rabbitmq-server/blob/master/deps/rabbitmq_stream/priv/schema/rabbitmq_stream.schema) (no `s`), this is the usual convention for plugins. I understand that `streams` makes more sense than `osiris`,...
`LocalizedQueueConnectionFactory` uses only the `/queues/{vhost}/{queue}` endpoint. The easiest would be to use the `RestTemplate` and Jackson, to keep the same dependencies as Hop.
Good point. Should go into 2.0, as it is a breaking change.
Please provide the broker and Erlang versions, as well the broker logs when the problems occurs. It seems the connection is closed for some reason, so the broker logs will...
Could you please try with the blocking IO mode as well?
This might be a bug in the Java client NIO connector. Contrary to blocking IO, TLS is not transparent with NIO, it requires crypting/decrypting before leaving/reaching the application code. It...
The underlying Java client uses blocking IO by default. You can switch to NIO with `ConnectionFactory#useNio()` and this should make the Blockhound failure from above disappear. See the [documentation](https://rabbitmq.com/api-guide.html#java-nio) for...