stan.java

stan.java copied to clipboard

Support redeliveryCount in Message object

3

`redeliveryCount` was added to `MsgProto` (in `protocol.proto`) and made available in the Go client as part of [nats-streaming-server #996](https://github.com/nats-io/nats-streaming-server/issues/996) . This is critical for implementation of setting a limit number...

liqweed

Redelivery count field addition to message

6

Fix for https://github.com/nats-io/stan.java/issues/155 As this is supported by server, just need to add field for `redeliveryCount`. Tested locally within my project.

jDzames

This project currently uses a fairly-old version of `protobuf-java` (`3.9.1`). That version was released on August 6, 2019. The current version is `3.17.3`. Please update the version of `protobuf-java` to...

cartermckinnon

Currently, I don't see any example of creating secure stan java client. Example of secure nats client is there where we can use SSLContext in Options but how to do...

ajay-kudale

Hi, We have a situtation when the app restart and for some reason didn't closed a subscription but did close the client connection. After the app starts again, the subscription...

pablobragan

NATS Streaming connection gets degraded over time

2

We have currently problems with one of our services connected to our cloud NATS-Cluster via Leafnode. We are using NATS-Streaming with Springboot MicroServices. The service runs very well for a...

wutkemtt

Hi, I am trying to mock the streaming connection in my tests that are publishing or subscribing to Nats. Is there any documentation, test-kit or examples on how to do...

francescoperera

restarting nats streaming server client connections dont recover

1

On a fresh install when things are working fine we can see 7 clients and 12 channels(subscriptions)  ![Screen Shot 2020-10-29 at 4...

tanzeelrana

gcolliso

Reactive support for subscriptions

3

Thanks for the awesome library! I was wondering if support for reactive subscriptions can be added. For example, instead of doing ```java Subscription sub = sc.subscribe("foo", new MessageHandler() { public...

pepijno