diff --git a/monitoring-samples/task-apps/task-demo-metrics-wavefront/pom.xml b/monitoring-samples/task-apps/task-demo-metrics-wavefront/pom.xml
index 2d53c36..72379ff 100644
--- a/monitoring-samples/task-apps/task-demo-metrics-wavefront/pom.xml
+++ b/monitoring-samples/task-apps/task-demo-metrics-wavefront/pom.xml
@@ -8,6 +8,7 @@
2.3.1.RELEASE
+
com.example.task
task-demo-metrics-wavefront
0.0.1-SNAPSHOT
@@ -69,6 +70,15 @@
io.micrometer
micrometer-registry-wavefront
+
+
+
+ com.wavefront
+ wavefront-sdk-java
+ 2.6.0
+
diff --git a/monitoring-samples/task-apps/task-demo-metrics-wavefront/src/main/java/com/example/task/taskdemometrics/TaskDemoMetricsApplication.java b/monitoring-samples/task-apps/task-demo-metrics-wavefront/src/main/java/com/example/task/taskdemometrics/TaskDemoMetricsApplication.java
index a1096c1..fb49022 100644
--- a/monitoring-samples/task-apps/task-demo-metrics-wavefront/src/main/java/com/example/task/taskdemometrics/TaskDemoMetricsApplication.java
+++ b/monitoring-samples/task-apps/task-demo-metrics-wavefront/src/main/java/com/example/task/taskdemometrics/TaskDemoMetricsApplication.java
@@ -48,7 +48,7 @@ public class TaskDemoMetricsApplication {
public Step step1() {
return this.stepBuilderFactory.get("step1")
.chunk(10)
- .reader(new ListItemReader<>(IntStream.rangeClosed(0, this.random.nextInt(10000))
+ .reader(new ListItemReader<>(IntStream.rangeClosed(0, this.random.nextInt(10 * 1000))
.boxed().collect(Collectors.toList())))
.writer(list -> list.forEach(e -> {
if ((e % 100) == 0) {
@@ -61,7 +61,7 @@ public class TaskDemoMetricsApplication {
public Step step2() {
return this.stepBuilderFactory.get("step2")
.tasklet((contribution, context) -> {
- Thread.sleep(this.random.nextInt(10000));
+ Thread.sleep(3 * 60 * 1000 + this.random.nextInt(10000));
return RepeatStatus.FINISHED;
}).build();
}
@@ -71,7 +71,7 @@ public class TaskDemoMetricsApplication {
return jobBuilderFactory.get("job2")
.start(stepBuilderFactory.get("job2step1")
.tasklet((contribution, chunkContext) -> {
- Thread.sleep(this.random.nextInt(10000));
+ Thread.sleep(2 * 60 * 1000 + this.random.nextInt(10000));
return RepeatStatus.FINISHED;
})
.build())
diff --git a/monitoring-samples/task-apps/task-demo-metrics-wavefront/src/main/resources/application.properties b/monitoring-samples/task-apps/task-demo-metrics-wavefront/src/main/resources/application.properties
index ee693ee..035a8ae 100644
--- a/monitoring-samples/task-apps/task-demo-metrics-wavefront/src/main/resources/application.properties
+++ b/monitoring-samples/task-apps/task-demo-metrics-wavefront/src/main/resources/application.properties
@@ -3,3 +3,8 @@ info.app.name=@project.artifactId@
info.app.description=@project.description@
info.app.version=@project.version@
management.endpoints.web.exposure.include=health,info,bindings
+
+#management.metrics.export.wavefront.enabled=true
+#management.metrics.export.wavefront.api-token=
+#management.metrics.export.wavefront.uri=
+#management.metrics.export.wavefront.source=TASK-TEST