NatsTimeout.java

public class Main {

    public static void main(String[] args) throws Exception {
        ConnectionFactory cf = new ConnectionFactory(Constants.DEFAULT_URL);
        final Connection conn = cf.createConnection();
        conn.subscribe("foo", new MessageHandler() {
            @Override
            public void onMessage(Message message) {
                conn.publish("bar", "hello".getBytes());
            }
        });
        for (int i = 0; i < 100000; i++) {
            SyncSubscription sub = conn.subscribeSync("bar");
            sub.autoUnsubscribe(1);
            conn.flush();
            conn.publish("foo", "test".getBytes());
            try {
                System.out.println(sub.nextMessage(5000));
            } catch (TimeoutException e) {
                System.out.println("got timeout " + i);
                return;
            }
        }
    }
    
}