SpringCloud/spring-cloud-stream
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

GH-1614 Added Expression Serializer to ObjectMapper

Browse Source 
Resolves #1614
This commit is contained in:
Oleg Zhurakousky
2019-02-28 17:34:56 +01:00
parent 6e6483b00c
commit 717cf647f4
1 changed files with 24 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

25
spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binder/AbstractMessageChannelBinder.java
View File

@@ -16,13 +16,18 @@
package org.springframework.cloud.stream.binder;
import java.io.IOException;
import java.util.LinkedHashMap;
import java.util.Map;
import java.util.function.Consumer;
import java.util.function.Function;
import java.util.function.Supplier;
import com.fasterxml.jackson.core.JsonGenerator;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.fasterxml.jackson.databind.SerializerProvider;
import com.fasterxml.jackson.databind.module.SimpleModule;
import com.fasterxml.jackson.databind.ser.std.StdSerializer;
import org.apache.commons.logging.Log;
import org.reactivestreams.Publisher;
@@ -44,6 +49,7 @@ import org.springframework.context.ApplicationEventPublisher;
import org.springframework.context.ApplicationEventPublisherAware;
import org.springframework.context.Lifecycle;
import org.springframework.context.support.GenericApplicationContext;
import org.springframework.expression.Expression;
import org.springframework.integration.channel.AbstractMessageChannel;
import org.springframework.integration.channel.AbstractSubscribableChannel;
import org.springframework.integration.channel.DirectChannel;
@@ -145,6 +151,10 @@ public abstract class AbstractMessageChannelBinder<C extends ConsumerProperties,
@Nullable ListenerContainerCustomizer<?> containerCustomizer,
@Nullable MessageSourceCustomizer<?> sourceCustomizer) {
SimpleModule module = new SimpleModule();
module.addSerializer(Expression.class, new ExpressionSerializer(Expression.class));
objectMapper.registerModule(module);
this.headersToEmbed = headersToEmbed == null ? new String[0] : headersToEmbed;
this.provisioningProvider = provisioningProvider;
this.containerCustomizer = containerCustomizer == null ? (c, q, g) -> {
@@ -464,7 +474,7 @@ public abstract class AbstractMessageChannelBinder<C extends ConsumerProperties,
MessageSource<?> messageSource = resources.getSource();
if (messageSource instanceof BeanFactoryAware) {
((BeanFactoryAware)messageSource).setBeanFactory(getApplicationContext().getBeanFactory());
((BeanFactoryAware) messageSource).setBeanFactory(getApplicationContext().getBeanFactory());
}
bindingTarget.setSource(messageSource);
if (resources.getErrorInfrastructure() != null) {
@@ -1146,4 +1156,17 @@ public abstract class AbstractMessageChannelBinder<C extends ConsumerProperties,
}
@SuppressWarnings("serial")
private static class ExpressionSerializer extends StdSerializer<Expression> {
protected ExpressionSerializer(Class<Expression> t) {
super(t);
}
@Override
public void serialize(Expression value, JsonGenerator gen, SerializerProvider provider) throws IOException {
gen.writeString(value.getExpressionString());
}
}
}