Merge pull request #20 from guoshiqiufeng/0.5.1

0.5.2

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.1</version>
+            <version>0.5.2</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.1</version>
+            <version>0.5.2</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) {
-                return converted;
+                message = converted;
             }
         }
 

binders/spring-cloud-stream-binder-redis/src/main/java/io/github/guoshiqiufeng/cloud/stream/binder/redis/RedisMessageChannelBinder.java

@@ -159,9 +159,10 @@ protected MessageProducer createConsumerEndpoint(ConsumerDestination destination
                 redisInboundChannelAdapter.setTopics(destination.getName());
             }
             redisInboundChannelAdapter.setBeanName(extendedConsumerProperties.getBindingName());
-            if (consumerProperties != null && consumerProperties.getSerializer() != null) {
-                redisInboundChannelAdapter.setSerializer(consumerProperties.getSerializer());
-            }
+//            if (consumerProperties != null && consumerProperties.getSerializer() != null) {
+//                redisInboundChannelAdapter.setSerializer(consumerProperties.getSerializer());
+//            }
+            redisInboundChannelAdapter.setSerializer(null);
             redisInboundChannelAdapter.setMessageConverter(new MessagingMessageConverter());
             redisInboundChannelAdapter.setBeanFactory(getBeanFactory());
             redisInboundChannelAdapter.setApplicationContext(applicationContext);

gradle.properties

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