Add examples

Signed-off-by: siri-varma <[email protected]>

Author: siri-varma

.github/workflows/validate.yml

@@ -115,6 +115,12 @@ jobs:
         run: ./mvnw install -q
         env:
           DOCKER_HOST: ${{steps.setup_docker.outputs.sock}}
+      - name: Validate Jobs example
+        working-directory: ./examples
+        run: |
+          mm.py ./src/main/java/io/dapr/examples/jobs/README.md
+        env:
+          DOCKER_HOST: ${{steps.setup_docker.outputs.sock}}
       - name: Validate invoke http example
         working-directory: ./examples
         run: |

examples/src/main/java/io/dapr/examples/jobs/DemoJobsClient.java

@@ -0,0 +1,36 @@
+package io.dapr.examples.jobs;
+
+import io.dapr.client.DaprClientBuilder;
+import io.dapr.client.DaprPreviewClient;
+import io.dapr.client.domain.GetJobRequest;
+import io.dapr.client.domain.GetJobResponse;
+import io.dapr.client.domain.JobSchedule;
+import io.dapr.client.domain.ScheduleJobRequest;
+import io.dapr.config.Properties;
+import io.dapr.config.Property;
+
+import java.util.Map;
+
+public class DemoJobsClient {
+
+  /**
+   * The main method of this app to register and fetch jobs.
+   */
+  public static void main(String[] args) throws Exception {
+    Map<Property<?>, String> overrides = Map.of(
+        Properties.HTTP_PORT, "3500",
+        Properties.GRPC_PORT, "51439"
+    );
+
+    try (DaprPreviewClient client = new DaprClientBuilder().withPropertyOverrides(overrides).buildPreviewClient()) {
+
+      // Schedule a job.
+      ScheduleJobRequest scheduleJobRequest = new ScheduleJobRequest("dapr-job-1",
+          JobSchedule.fromString("* * * * * *")).setData("Hello World!".getBytes());
+      client.scheduleJob(scheduleJobRequest).block();
+
+      // Get a job.
+      GetJobResponse getJobResponse = client.getJob(new GetJobRequest("dapr-job-1")).block();
+    }
+  }
+}

examples/src/main/java/io/dapr/examples/jobs/DemoJobsSpringApplication.java

@@ -0,0 +1,18 @@
+package io.dapr.examples.jobs;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+
+/**
+ * Spring Boot application to demonstrate Dapr Jobs callback API.
+ * <p>
+ * This application demonstrates how to use Dapr Jobs API with Spring Boot.
+ * </p>
+ */
+@SpringBootApplication
+public class DemoJobsSpringApplication {
+
+  public static void main(String[] args) throws Exception {
+    SpringApplication.run(DemoJobsSpringApplication.class, args);
+  }
+}

examples/src/main/java/io/dapr/examples/jobs/JobsController.java

@@ -0,0 +1,43 @@
+/*
+ * Copyright 2021 The Dapr Authors
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+limitations under the License.
+*/
+
+package io.dapr.examples.jobs;
+
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RestController;
+import reactor.core.publisher.Mono;
+
+/**
+ * SpringBoot Controller to handle jobs callback.
+ */
+@RestController
+public class JobsController {
+
+  /**
+   * Handles jobs callback from Dapr.
+   *
+   * @param jobName name of the job.
+   * @param payload data from the job if payload exists.
+   * @return Empty Mono.
+   */
+  @PostMapping("/job/{jobName}")
+  public Mono<Void> handleJob(@PathVariable("jobName") String jobName,
+                              @RequestBody(required = false) byte[] payload) {
+    System.out.println("Job Name: " + jobName);
+    System.out.println("Job Payload: " + new String(payload));
+
+    return Mono.empty();
+  }
+}

examples/src/main/java/io/dapr/examples/jobs/README.md

@@ -0,0 +1,123 @@
+## Mange Dapr Jobs via the Jobs API
+
+This example provides the different capabilities provided by Dapr Java SDK for Jobs. For further information about Job APIs please refer to [this link](https://docs.dapr.io/developing-applications/building-blocks/jobs/jobs-overview/)
+
+### Using the JobsAPI
+
+The Java SDK exposes several methods for this -
+* `client.scheduleJob(...)` for scheduling a job.
+* `client.getJob(...)` for retrieving a scheduled job.
+* `client.deleteJob(...)` for deleting a job.
+
+## Pre-requisites
+
+* [Dapr CLI](https://docs.dapr.io/getting-started/install-dapr-cli/).
+* Java JDK 11 (or greater):
+    * [Microsoft JDK 11](https://docs.microsoft.com/en-us/java/openjdk/download#openjdk-11)
+    * [Oracle JDK 11](https://www.oracle.com/technetwork/java/javase/downloads/index.html#JDK11)
+    * [OpenJDK 11](https://jdk.java.net/11/)
+* [Apache Maven](https://maven.apache.org/install.html) version 3.x.
+
+### Checking out the code
+
+Clone this repository:
+
+```sh
+git clone https://github.com/dapr/java-sdk.git
+cd java-sdk
+```
+
+Then build the Maven project:
+
+```sh
+# make sure you are in the `java-sdk` directory.
+mvn install
+```
+
+Then get into the examples directory:
+
+```sh
+cd examples
+```
+
+### Initialize Dapr
+
+Run `dapr init` to initialize Dapr in Self-Hosted Mode if it's not already initialized.
+
+### Running the example
+
+This example uses the Java SDK Dapr client in order to **Schedule and Get** Jobs.
+`DemoJobsClient.java` is the example class demonstrating these features.
+Kindly check [DaprPreviewClient.java](https://github.com/dapr/java-sdk/blob/master/sdk/src/main/java/io/dapr/client/DaprPreviewClient.java) for a detailed description of the supported APIs.
+
+```java
+public class DemoJobsClient {
+  /**
+   * The main method of this app to register and fetch jobs.
+   */
+  public static void main(String[] args) throws Exception {
+    Map<Property<?>, String> overrides = Map.of(
+        Properties.HTTP_PORT, "3500",
+        Properties.GRPC_PORT, "51439"
+    );
+
+    try (DaprPreviewClient client = new DaprClientBuilder().withPropertyOverrides(overrides).buildPreviewClient()) {
+
+      // Schedule a job.
+      ScheduleJobRequest scheduleJobRequest = new ScheduleJobRequest("dapr-job-1",
+          JobSchedule.fromString("* * * * * *")).setData("Hello World!".getBytes());
+      client.scheduleJob(scheduleJobRequest).block();
+
+      // Get a job.
+      GetJobResponse getJobResponse = client.getJob(new GetJobRequest("dapr-job-1")).block();
+    }
+  }
+}
+```
+
+Get into the examples' directory:
+```sh
+cd examples
+```
+
+Use the following command to run this example-
+
+<!-- STEP
+name: Run ConfigurationClient example
+expected_stdout_lines:
+  - "== APP == Job Name: dapr-job-1"
+  - "== APP == Job Payload: Hello World!"
+background: true
+output_match_mode: substring
+sleep: 10
+-->
+
+```bash
+dapr run --resources-path ./components/configuration --app-id myapp --app-port 8080 --dapr-http-port 3500 --dapr-grpc-port 51439  --log-level debug -- java -jar target/dapr-java-sdk-examples-exec.jar io.dapr.examples.jobs.DemoJobsSpringApplication
+```
+
+```bash
+java -jar target/dapr-java-sdk-examples-exec.jar io.dapr.examples.jobs.DemoJobsClient
+```
+
+<!-- END_STEP -->
+
+### Sample output
+```
+== APP == Job Name: dapr-job-1
+== APP == Job Payload: Hello World!
+```
+### Cleanup
+
+To stop the app, run (or press CTRL+C):
+
+<!-- STEP
+name: Cleanup
+-->
+
+```bash
+dapr stop --app-id myapp
+```
+
+<!-- END_STEP -->
+