void run()

in pekko-connectors-sample-mqtt-http-to-s3-java/src/main/java/alpakka/sample/triggereddownload/PublishDataToMqtt.java [42:55]

• 10 lines of code
• 1 McCabe index (conditional complexity)

    void run() throws Exception {


        final MqttConnectionSettings connectionSettings =
                MqttConnectionSettings.create(
                        "tcp://localhost:1883", "test-java-client", new MemoryPersistence());
        Sink<MqttMessage, CompletionStage<Done>> mqttSink =
                MqttSink.create(connectionSettings.withClientId("source-test/sink"), MqttQoS.atLeastOnce());

        DownloadCommand command = new DownloadCommand(Instant.now(), "https://doc.akka.io/docs/alpakka/current/s3.html");
        MqttMessage message = MqttMessage.create("downloads/trigger", ByteString.fromString(downloadCommandWriter.writeValueAsString(command)));

        Source.tick(Duration.ofSeconds(5), Duration.ofSeconds(30), message).runWith(mqttSink, system);
    }