stan.java
stan.java copied to clipboard
nats-io
NATS Streaming Java Client
hi, what's the best practice to use StreamConnection? I suppose, a long live StreamConnection means a long live socket connection.
[CI SKIP] Update to MAINTAINERS.md based on newly adopted Governance and Maintainership definitions.
Calling publish on an instance of StreamingConnection with an AckHandler can result in NPEs if the connection is closed before ACKs have been sent. The result should be an "java.lang.IllegalStateException:...
Per a Slack conversation with @sasbury , I'm creating this issue. In summary, while troubleshooting some issues in our projects, we've run in to some problems where we've found ourselves...
The only way to acknowledge a message today is by calling `Message.ack()`. Would it be possible to get hold of the subscription or ackInbox from the message so that we...
Add longer timeout to gradle tasks Maybe move off travis
In the NatsStreaming class the connect method throws an InterruptedException: ``` public static StreamingConnection connect( String clusterId, String clientId, Options opts) throws IOException, InterruptedException { try { StreamingConnectionImpl conn =...
Include: * Examples * Recommended practices * Potential pitfalls
It is a wonderful feature which saves time if you properly understand them. I made the assumption that durable meant only the position not all settings such as MaxInFlight etc....
