public void executeStream()

in streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/tutorial/VehicleStream.java [37:60]

• 20 lines of code
• 3 McCabe index (conditional complexity)

  public void executeStream() {
    SpKafkaProducer producer = new SpKafkaProducer("localhost:9094", "org.apache.streampipes.tutoria.vehicle", Collections.emptyList());
    Random random = new Random();
    Runnable runnable = () -> {
      for (;;) {
        JsonObject jsonObject = new JsonObject();
        jsonObject.addProperty("timestamp", System.currentTimeMillis());
        jsonObject.addProperty("plateNumber", "KA-SP 1");
        jsonObject.addProperty("latitude", random.nextDouble());
        jsonObject.addProperty("longitude", random.nextDouble());

        producer.publish(jsonObject.toString());

        try {
          TimeUnit.SECONDS.sleep(1);
        } catch (InterruptedException e) {
          e.printStackTrace();
        }

      }
    };

    new Thread(runnable).start();
  }