nats.java

nats.java copied to clipboard

Introduced a custom NATS logger facade

6

Rewired all STDOUTS to this facade and added extensive unit tests. Added new logs for dns resolving and socketdataport timeout to showcase usage in 2 examples where logging can be...

stefanLeo

Unable to run on Android 7.0 because java.util.Base64

6

### Observed behavior java.util.concurrent.ExecutionException: java.lang.NoClassDefFoundError: Failed resolution of: Ljava/util/Base64; ### Expected behavior can run on Android 7.0 ### Server and client version jnats 2.17.1 ### Host environment _No response_ ###...

zpsw

Make certain classes Serializable as required by Apache Flink

3

I propose an update to the NATS Java Client: making StreamConfiguration and Consumer Configuration classes Serializable. This change is vital for integrating NATS with Apache Flink (Nats-Flink Connector with JetStream...

somratdutta

Enable secure websocket connection behind TLS-terminating reverse proxy

8

In reverse proxy environment that supports TLS-terminating(ex. AWS ELB) wss:// connection throws `IOException("SSL connection wanted by client.")` This should only checked when using TLS not websocket

flex-seongbok

Exactly-once-processing not guaranteed by fire-and-forget NatsJetStreamMessage.inProgress()

3

### Observed behavior The signature of [NatsJetStreamMessage.inProgress()](https://github.com/nats-io/nats.java/blob/main/src/main/java/io/nats/client/impl/NatsJetStreamMessage.java#L84) returns void. Its internal implementation merely publishes an Ack message to the reply subject of the NatsJetStreamMessage without waiting for confirmation from JetStream...

davidmcote

### Proposed change There should be more documentation around exactly what is thrown when there is an optimistic locking failure related to the KeyValue [update method](https://javadoc.io/static/io.nats/jnats/2.17.1/io/nats/client/KeyValue.html#update-java.lang.String-java.lang.String-long-). ### Use case I...

senior

Hostname resolution happens too early in case of proxied websocket connections.

1

### Observed behavior c.f. https://github.com/nats-io/nats.java/pull/913 The problem is that even with the `isNoResolveHostnames ` option set, if the connection is proxied the actual tunneled connection to the NATS server happens...

GrafBlutwurst

### Background The nats-server package maintains a list of possible error codes at https://github.com/nats-io/nats-server/blob/main/server/errors.json. The elements of this JSON listing appear to be [ErrorsData](https://github.com/nats-io/nats-server/blob/main/server/jetstream_errors.go#L64) structures which feed a code generator...

davidmcote

NATS timeout errors when calling NatsJetStreamManagement

1

### Observed behavior As described in Slack channel https://natsio.slack.com/archives/CM3T6T7JQ/p1692790156946559 we´re sometimes seeing timeout errors when we try to fetch information from Jetstream. We see that the request goes into the...

joachimglink

Drain waits indefinitely after request timeout on fetch

5

(not sure if limited to the simplified API, but it can be reproduced with it) Calling `drain(Duration.ZERO)` will wait indefinitely when a request timeout happened on a fetch. For this...

MauriceVanVeen