Merge pull request #17 from guoshiqiufeng/0.5.0

0.5.1

Author: guoshiqiufeng

README-zh.md

@@ -39,7 +39,7 @@ https://guoshiqiufeng.github.io/spring-cloud-stream-redis/
         <dependency>
             <groupId>io.github.guoshiqiufeng.cloud</groupId>
             <artifactId>spring-cloud-stream-dependencies</artifactId>
-            <version>0.5.0</version>
+            <version>0.5.1</version>
             <type>import</type>
         </dependency>
     </dependencies>

README.md

@@ -41,7 +41,7 @@ https://guoshiqiufeng.github.io/spring-cloud-stream-redis/en/
         <dependency>
             <groupId>io.github.guoshiqiufeng.cloud</groupId>
             <artifactId>spring-cloud-stream-dependencies</artifactId>
-            <version>0.5.0</version>
+            <version>0.5.1</version>
             <type>import</type>
         </dependency>
     </dependencies>

binders/spring-cloud-stream-binder-redis-core/src/main/java/io/github/guoshiqiufeng/cloud/stream/binder/redis/support/converter/MessagingMessageConverter.java

@@ -41,7 +41,7 @@ public Object fromMessage(Message<?> messageArg, Class<?> targetClass) {
         if (this.messagingConverter != null) {
             Message<?> converted = this.messagingConverter.toMessage(message.getPayload(), message.getHeaders());
             if (converted != null) {
-                message = converted;
+                return converted;
             }
         }
 

gradle.properties

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