Merge pull request #104 from guoshiqiufeng/release-please--branches--dev--components--standard-version

chore(dev): release 1.2.1

Author: guoshiqiufeng

CHANGELOG.md

@@ -1,5 +1,15 @@
 # Changelog
 
+## [1.2.1](https://github.com/guoshiqiufeng/loki/compare/v1.2.0...v1.2.1) (2024-06-24)
+
+
+### 🔨 Dependency Upgrades
+
+* Update Gradle to 8.8 ([24e0970](https://github.com/guoshiqiufeng/loki/commit/24e09706063d9f31d1c1f2345fade3a3cefff95f))
+* Update JedisClient to 5.1.3 ([24e0970](https://github.com/guoshiqiufeng/loki/commit/24e09706063d9f31d1c1f2345fade3a3cefff95f))
+* Update rocketmq-client-java to 5.0.7 ([4e928bb](https://github.com/guoshiqiufeng/loki/commit/4e928bba19f9f01893b0413063b22ad05e078ddc))
+* Update Spring Framework to 5.3.37 ([24e0970](https://github.com/guoshiqiufeng/loki/commit/24e09706063d9f31d1c1f2345fade3a3cefff95f))
+
 ## [1.2.0](https://github.com/guoshiqiufeng/loki/compare/v1.1.1...v1.2.0) (2024-04-16)
 
 

README-zh.md

@@ -20,12 +20,12 @@ https://guoshiqiufeng.github.io/loki-doc/
 ### 开发框架
 
 - Java 21
-- Gradle 8.7
+- Gradle 8.8
 - Spring Boot 2.7.18
 - rocketmq-client 5.2.0
-- rocketmq-client-java 5.0.6 (RocketMQ-grpc)
+- rocketmq-client-java 5.0.7 (RocketMQ-grpc)
 - kafka-clients 3.7.0
-- jedis 5.1.2
+- jedis 5.1.3
 - spring-data-redis (可选)
 
 ### 功能

README.md

@@ -20,12 +20,12 @@ https://guoshiqiufeng.github.io/loki-doc/en/
 ### Development Framework
 
 - Java 21
-- Gradle 8.7
+- Gradle 8.8
 - Spring Boot 2.7.18
 - rocketmq-client 5.2.0
-- rocketmq-client-java 5.0.6 (RocketMQ-grpc)
+- rocketmq-client-java 5.0.7 (RocketMQ-grpc)
 - kafka-clients 3.7.0
-- jedis 5.1.2
+- jedis 5.1.3
 - spring-data-redis (Optional)
 
 ### Features

ext.gradle

@@ -6,11 +6,11 @@ ext {
     libraries = [
             springBootVersion = '2.7.18',
             springBoot3Version = '3.2.1',
-            springVersion = '5.3.34',
+            springVersion = '5.3.37',
             rocketMqClientVersion = '5.2.0',
-            rocketMqClientJavaVersion = '5.0.6',
+            rocketMqClientJavaVersion = '5.0.7',
             kafkaClientsVersion = '3.7.0',
-            jedisVersion = '5.1.2',
+            jedisVersion = '5.1.3',
             hutoolVersion = '5.8.26',
             opentelemetryVersion = "1.31.0",
             okhttpVersion = "4.12.0",

gradle.properties

@@ -1,4 +1,4 @@
 # {x-release-please-start-version}
-APP_VERSION=1.2.0
+APP_VERSION=1.2.1
 # {x-release-please-end-version}
 APP_GROUP=io.github.guoshiqiufeng

gradle/wrapper/gradle-wrapper.properties

@@ -1,6 +1,6 @@
 #Fri Nov 10 10:59:22 CST 2023
 distributionBase=GRADLE_USER_HOME
 distributionPath=wrapper/dists
-distributionUrl=https\://services.gradle.org/distributions/gradle-8.7-bin.zip
+distributionUrl=https\://services.gradle.org/distributions/gradle-8.8-bin.zip
 zipStoreBase=GRADLE_USER_HOME
 zipStorePath=wrapper/dists

loki-support/loki-support-core/src/test/java/io/github/guoshiqiufeng/loki/support/core/pipeline/PipelineUtilsTest.java

@@ -0,0 +1,36 @@
+package io.github.guoshiqiufeng.loki.support.core.pipeline;
+
+import io.github.guoshiqiufeng.loki.support.core.consumer.ConsumerRecord;
+import io.github.guoshiqiufeng.loki.support.core.producer.ProducerRecord;
+import org.junit.Assert;
+import org.junit.Test;
+
+/**
+ * @author yanghq
+ * @version 1.0
+ * @since 2024/4/17 15:41
+ */
+public class PipelineUtilsTest {
+
+    @Test
+    public void testProcessSend() {
+        ProducerRecord producerRecord = new ProducerRecord();
+        producerRecord.setTopic("processSend");
+        producerRecord.setTag("create");
+        producerRecord.setMessage("test message");
+
+        Assert.assertNull(PipelineUtils.processSend(producerRecord));
+    }
+
+    @Test
+    public void testProcessListener() {
+        ConsumerRecord consumerRecord = new ConsumerRecord();
+        consumerRecord.setTopic("processListener");
+        consumerRecord.setTag("create");
+        consumerRecord.setMessageId("");
+        consumerRecord.setMessageGroup("");
+        consumerRecord.setBodyMessage("test message listener");
+
+        Assert.assertNull(PipelineUtils.processListener(consumerRecord));
+    }
+}