import io.nats.client.Connection;
import io.nats.client.Nats;
import java.time.Duration;

public class Publisher {
  public static void main(String[] args) throws Exception {
    Connection nc = Nats.connect("nats://nats:4222");

    int counter = 0;

    while (true) {
      long sendTime = System.currentTimeMillis();
      String msg = counter + "," + sendTime;
      nc.publish("demo.subject", msg.getBytes());
      nc.flush(Duration.ofSeconds(1));

      System.out.println("Sent: " + counter);
      counter++;
      Thread.sleep(1000);
    }
  }
}