Spring/spring-integration
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Use StandardEvalCtx in the ZeroMqMessageHandler

Browse Source 
A simple one was used by mistake
This commit is contained in:
abilan
2023-04-11 16:15:27 -04:00
parent e69285a06f
commit bbbfc47ca4
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
spring-integration-zeromq/src/main/java/org/springframework/integration/zeromq/outbound/ZeroMqMessageHandler.java
View File

@@ -68,7 +68,7 @@ public class ZeroMqMessageHandler extends AbstractReactiveMessageHandler
implements ManageableLifecycle {
private static final List<SocketType> VALID_SOCKET_TYPES =
Arrays.asList(SocketType.PAIR, SocketType.PUSH, SocketType.PUB);
List.of(SocketType.PAIR, SocketType.PUSH, SocketType.PUB);
private final AtomicBoolean running = new AtomicBoolean();
@@ -202,7 +202,7 @@ public class ZeroMqMessageHandler extends AbstractReactiveMessageHandler
protected void onInit() {
super.onInit();
BeanFactory beanFactory = getBeanFactory();
this.evaluationContext = ExpressionUtils.createSimpleEvaluationContext(beanFactory);
this.evaluationContext = ExpressionUtils.createStandardEvaluationContext(beanFactory);
if (this.messageMapper == null) {
ConfigurableCompositeMessageConverter messageConverter = new ConfigurableCompositeMessageConverter();
messageConverter.setBeanFactory(beanFactory);