Create distributed queue

consumer/build.gradle

@@ -1,6 +1,7 @@
 plugins {
 	id 'org.springframework.boot' version '2.2.7.RELEASE'
 	id 'io.spring.dependency-management' version '1.0.9.RELEASE'
+  id "io.freefair.lombok" version "5.0.1"
 	id 'java'
 }
 

consumer/src/main/java/com/example/consumer/ConsumerController.java

@@ -1,12 +1,27 @@
 package com.example.consumer;
 
+import org.redisson.api.RScoredSortedSet;
+import org.redisson.api.RedissonClient;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.PostMapping;
 import org.springframework.web.bind.annotation.RestController;
 
 @RestController
 public class ConsumerController {
+  @Autowired
+  RedissonClient redisson;
+
   @GetMapping("/hello")
   public String hello() {
     return "Hello Consumer";
   }
+
+  @PostMapping("/pollJob/{queueId}")
+  public String pollJob(@PathVariable String queueId) {
+    RScoredSortedSet<String> set = redisson.getScoredSortedSet(queueId);
+
+    return set.pollLast();
+  }
 }

consumer/src/main/java/com/example/consumer/Job.java

@@ -0,0 +1,10 @@
+package com.example.consumer;
+
+import lombok.Data;
+
+@Data
+public class Job {
+  private String queueId;
+  private double score;
+  private String name;
+}

docker-compose.yml

@@ -16,3 +16,5 @@ services:
 
   redis:
     image: "redis:alpine"
+    ports:
+      - 9379:6379

producer/build.gradle

@@ -1,6 +1,7 @@
 plugins {
 	id 'org.springframework.boot' version '2.2.7.RELEASE'
 	id 'io.spring.dependency-management' version '1.0.9.RELEASE'
+  id "io.freefair.lombok" version "5.0.1"
 	id 'java'
 }
 

producer/src/main/java/com/example/producer/Job.java

@@ -0,0 +1,10 @@
+package com.example.producer;
+
+import lombok.Data;
+
+@Data
+public class Job {
+  private String queueId;
+  private double score;
+  private String name;
+}

producer/src/main/java/com/example/producer/ProducerController.java

@@ -1,12 +1,26 @@
 package com.example.producer;
 
+import org.redisson.api.RScoredSortedSet;
+import org.redisson.api.RedissonClient;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RestController;
 
 @RestController
 public class ProducerController {
+  @Autowired
+  RedissonClient redisson;
+
   @GetMapping("/hello")
   public String hello() {
     return "Hello Producer";
   }
+
+  @PostMapping("/queueJob")
+  public void queueJob(@RequestBody Job job) {
+    RScoredSortedSet<String> set = redisson.getScoredSortedSet(job.getQueueId());
+    set.add(job.getScore(), job.getName());
+  }
 }