nats.java
nats.java copied to clipboard
nats-io
Java client for NATS
### Observed behavior When parallel subscribe in different threads two consumer on local idle nats, i received sometimes an IOException:Timeout after two seconds. ### Expected behavior No timeout ### Server...
### Overview Document the proper use, when using an [ordered] push consumer, of ``` JetStreamSubscription#getConsumerInfo().getCalculatedPending() ``` versus ``` JetStreamSubscription#getPendingMessageCount() ``` ### Description For the use case where a stream consumer...
## Feature Request The current `MessageHandler` interface has a synchronous method. Please provide an asynchronous version of the same interface. #### Use Case: Not sure, but hoping that providing this...
Proxied connections resolve the hostname to an IP address while tunneling even when noResolveHostname option is set. This behavior is unwanted in some scenarios, especially when a proxy does whitelisting...
## Feature Request Add support for idiomatic Kotlin use of NATS. This might entail creating a new repo `nats.kotlin`. #### Use Case: The primary use case is to leverage `suspend`ing...
## Feature Request In order to allow usage of NATS through MiroProfile-base application, an integration with [smallrye-reactive-messaging (`github.com`)](https://github.com/smallrye/smallrye-reactive-messaging) would be beneficial. #### Use Case: Usage of NATS through the [MicroProfile...
## Feature Request I am currently in the situation that I'd like to connect to NATS from behind an authenticated HTTP Proxy. And while the library handles proxying just fine,...
Better identify JetStream connection and /communication errors. #### Versions of `io.nats:jnats` and `nats-server`: io.nats:jnats: 2.16.1 nats-server: 2.8.4 #### OS/Container environment: Client: Windows 10 Server: alpine docker image #### Steps or...
I has search domain at my /etc/resolv.conf: ``` cat /etc/resolv.conf search dev.svc.cluster.local svc.cluster.local cluster.local local nameserver 10.222.0.10 options ndots:5 ``` On 2.16.8 version it worked well, i resolved nats:4222 on...
Async errors are too generic `NatsJetStream:168` throws a `RuntimeException` in case an error happens. As this happens inside a future that RTE gets wrapped in a `CompletionException` before it re-emerges...
