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

GH-717 Add support for adding MessageConverters to FunctionCatalog

Browse Source 
Resolves #717
This commit is contained in:
Oleg Zhurakousky
2021-07-26 13:10:52 +02:00
parent dc98f0b49f
commit 7d1ef3474f
1 changed files with 12 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
spring-cloud-function-context/src/main/java/org/springframework/cloud/function/context/catalog/SimpleFunctionRegistry.java
View File

@@ -64,6 +64,7 @@ import org.springframework.lang.Nullable;
import org.springframework.messaging.Message; import org.springframework.messaging.Message;
import org.springframework.messaging.MessageHeaders; import org.springframework.messaging.MessageHeaders;
import org.springframework.messaging.converter.CompositeMessageConverter; import org.springframework.messaging.converter.CompositeMessageConverter;
import org.springframework.messaging.converter.MessageConverter;
import org.springframework.messaging.support.MessageBuilder; import org.springframework.messaging.support.MessageBuilder;
import org.springframework.util.Assert; import org.springframework.util.Assert;
import org.springframework.util.CollectionUtils; import org.springframework.util.CollectionUtils;
@@ -121,6 +122,17 @@ public class SimpleFunctionRegistry implements FunctionRegistry, FunctionInspect
this.functionProperties = functionProperties; this.functionProperties = functionProperties;
} }
/**
* Will add provided {@link MessageConverter}s to the head of the stack of the existing MessageConverters.
*
* @param messageConverters list of {@link MessageConverter}s.
*/
public void addMessageConverters(List<MessageConverter> messageConverters) {
if (!CollectionUtils.isEmpty(messageConverters)) {
this.messageConverter.getConverters().addAll(0, messageConverters);
}
}
@Override @Override
public FunctionRegistration<?> getRegistration(Object function) { public FunctionRegistration<?> getRegistration(Object function) {
throw new UnsupportedOperationException("FunctionInspector is deprecated. There is no need " throw new UnsupportedOperationException("FunctionInspector is deprecated. There is no need "