1.1.0

loki-redis-test/src/main/java/io/github/guoshiqiufeng/lokitest/controller/TestController.java

@@ -55,6 +55,16 @@ public String customSend2() {
         return "success";
     }
 
+    @GetMapping("customSend3")
+    public String customSend3() {
+        TestEntity entity = new TestEntity();
+        entity.setId("9521");
+        entity.setMessage("test");
+        String messageId = testMapper.customSend3(entity);
+        log.debug("send messageId:{}", messageId);
+        return "success";
+    }
+
     @GetMapping("customAsyncSend")
     public String customAsyncSend() throws ExecutionException, InterruptedException {
         TestEntity entity = new TestEntity();
@@ -65,4 +75,4 @@ public String customAsyncSend() throws ExecutionException, InterruptedException
         log.debug("send messageId:{}", messageId);
         return "success";
     }
-}
+}

loki-redis-test/src/main/java/io/github/guoshiqiufeng/lokitest/mapper/TestMapper.java

@@ -19,6 +19,9 @@ public interface TestMapper extends BaseMapper<TestEntity> {
     @SendMessage(topic = "loki", tag = "custom", message = "#entity.message", messageKey = "#entity.id")
     String customSend2(TestEntity entity);
 
+    @SendMessage(topic = "loki", tag = "custom", message = "#entity.message", messageKey = "#entity.id", deliveryTimestamp = 10000)
+    String customSend3(TestEntity entity);
+
     @SendMessage(topic = "loki", tag = "custom", async = true, message = "#entity.message", messageKey = "#entity.id")
     CompletableFuture<String> customAsyncSend(TestEntity entity);
 

loki-redis-test/src/main/resources/application-sentinel.yml

@@ -0,0 +1,20 @@
+spring:
+  data:
+    redis:
+      sentinel:
+        master: mymaster
+        nodes:
+          - 127.0.0.1:26380
+          - 127.0.0.1:26379
+          - 127.0.0.1:26381
+        password: 123456
+      password: 123456
+      database: 12
+
+loki:
+  global-config:
+    mq-config:
+      mq-type: redis
+      address: mymaster,127.0.0.1:26380,127.0.0.1:26379,127.0.0.1:26381
+      auth: true
+      password: 123456

loki-redis-test/src/main/resources/application-single.yml

@@ -0,0 +1,15 @@
+spring:
+  data:
+    redis:
+      host: 127.0.0.1
+      #password: 123456
+      database: 12
+
+loki:
+  global-config:
+    mq-config:
+      mq-type: redis
+      address: 127.0.0.1:6379
+      auth: false
+      password: 123456
+    redis-history-delay-message-send: true

loki-redis-test/src/main/resources/application.yml

@@ -6,22 +6,5 @@ logging:
     io.github.guoshiqiufeng.lokitest: debug
 
 spring:
-  data:
-    redis:
-      sentinel:
-        master: mymaster
-        nodes:
-          - 127.0.0.1:26380
-          - 127.0.0.1:26379
-          - 127.0.0.1:26381
-        password: 123456
-      password: 123456
-      database: 12
-
-loki:
-  global-config:
-    mq-config:
-      mq-type: redis
-      address: mymaster,127.0.0.1:26380,127.0.0.1:26379,127.0.0.1:26381
-      auth: true
-      password: 123456
+  profiles:
+    active: single

pom.xml

@@ -19,7 +19,7 @@
 
     <properties>
         <java.version>17</java.version>
-        <loki.version>1.0.1</loki.version>
+        <loki.version>1.1.0</loki.version>
     </properties>
 
     <dependencyManagement>