rabbitmq-java-client
rabbitmq-java-client copied to clipboard
rabbitmq
RabbitMQ Java client
To avoid thread execution for too long, we interrupt the thread after the time limit is reached. Recently, We find that occasionally messages get lost. We use TX mode ,...
Several methods defined in `ExceptionHandler` interface accept `Throwable` as one of arguments. `ForgivingExceptionHandler` and `DefaultExceptionHandler` (which is used as a default `ExceptionHandler` implementation) as one of it's descendants effectively ignore...
We noticed that when using java client version 5.11.0 there is a significant skew in client connections towards the first Rabbit node in the list. It appears that AutoRecovering connection...
Related to #330. Many settings have been added to `ConnectionFactory` over the years, making it somewhat harder to configure. It's for instance easy to omit an important option when setting...
Classes/interfaces from `com.rabbitmq.utility` and `com.rabbitmq.json` should go under the `com.rabbitmq.client` package. This makes more sense when considering modular platform like Jigsaw and OSGi.
It would be useful if the API of `ConnectionFactory` supported fluent style. For example: Connection c = new ConnectionFactory().setUri(...).newConnection(); Connection c = new ConnectionFactory().load(...).newConnection(); Most of the times, this involves...
This should be done as soon as the developer specifies a `SSLContext` or a `TrustStore` so with all the `ConnectionFactory#useSslProtocol` methods, except `ConnectionFactory#useSslProtocol()` and `ConnectionFactory#useSslProtocol(String protocol)` methods, where server checks...
On the code below that I got from master: `/** Public API - {@inheritDoc} */ @Override public void abort(int closeCode, String closeMessage) throws IOException { try { close(closeCode, closeMessage, true,...
