diff --git a/.travis.yml b/.travis.yml index f1806a8756a..93a98e3b40b 100644 --- a/.travis.yml +++ b/.travis.yml @@ -11,7 +11,6 @@ addons: - mongodb-3.0-precise packages: - mongodb-org-server - - oracle-java8-installer before_cache: - rm -f $HOME/.gradle/caches/modules-2/modules-2.lock cache: diff --git a/spring-integration-core/src/main/java/org/springframework/integration/config/MessagingGatewayRegistrar.java b/spring-integration-core/src/main/java/org/springframework/integration/config/MessagingGatewayRegistrar.java index 89336ca6412..e2482e175b8 100644 --- a/spring-integration-core/src/main/java/org/springframework/integration/config/MessagingGatewayRegistrar.java +++ b/spring-integration-core/src/main/java/org/springframework/integration/config/MessagingGatewayRegistrar.java @@ -1,5 +1,5 @@ /* - * Copyright 2014-2017 the original author or authors. + * Copyright 2014-2018 the original author or authors. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. @@ -100,28 +100,33 @@ public BeanDefinitionHolder parse(Map gatewayAttributes) { if (hasDefaultHeaders || hasDefaultPayloadExpression) { BeanDefinitionBuilder methodMetadataBuilder = BeanDefinitionBuilder.genericBeanDefinition(GatewayMethodMetadata.class); + if (hasDefaultPayloadExpression) { methodMetadataBuilder.addPropertyValue("payloadExpression", defaultPayloadExpression); } - Map headerExpressions = new ManagedMap(); - for (Map header : defaultHeaders) { - String headerValue = (String) header.get("value"); - String headerExpression = (String) header.get("expression"); - boolean hasValue = StringUtils.hasText(headerValue); - - if (hasValue == StringUtils.hasText(headerExpression)) { - throw new BeanDefinitionStoreException("exactly one of 'value' or 'expression' " + - "is required on a gateway's header."); - } - BeanDefinition expressionDef = - new RootBeanDefinition(hasValue ? LiteralExpression.class : ExpressionFactoryBean.class); - expressionDef.getConstructorArgumentValues() - .addGenericArgumentValue(hasValue ? headerValue : headerExpression); + if (hasDefaultHeaders) { + Map headerExpressions = new ManagedMap(); + for (Map header : defaultHeaders) { + String headerValue = (String) header.get("value"); + String headerExpression = (String) header.get("expression"); + boolean hasValue = StringUtils.hasText(headerValue); + + if (hasValue == StringUtils.hasText(headerExpression)) { + throw new BeanDefinitionStoreException("exactly one of 'value' or 'expression' " + + "is required on a gateway's header."); + } - headerExpressions.put((String) header.get("name"), expressionDef); + BeanDefinition expressionDef = + new RootBeanDefinition(hasValue ? LiteralExpression.class : ExpressionFactoryBean.class); + expressionDef.getConstructorArgumentValues() + .addGenericArgumentValue(hasValue ? headerValue : headerExpression); + + headerExpressions.put((String) header.get("name"), expressionDef); + } + methodMetadataBuilder.addPropertyValue("headerExpressions", headerExpressions); } - methodMetadataBuilder.addPropertyValue("headerExpressions", headerExpressions); + gatewayProxyBuilder.addPropertyValue("globalMethodMetadata", methodMetadataBuilder.getBeanDefinition()); } diff --git a/spring-integration-core/src/main/java/org/springframework/integration/gateway/GatewayProxyFactoryBean.java b/spring-integration-core/src/main/java/org/springframework/integration/gateway/GatewayProxyFactoryBean.java index 3a7e67fb79b..3e51ab77331 100644 --- a/spring-integration-core/src/main/java/org/springframework/integration/gateway/GatewayProxyFactoryBean.java +++ b/spring-integration-core/src/main/java/org/springframework/integration/gateway/GatewayProxyFactoryBean.java @@ -1,5 +1,5 @@ /* - * Copyright 2002-2017 the original author or authors. + * Copyright 2002-2018 the original author or authors. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. @@ -487,10 +487,15 @@ private Object invokeGatewayMethod(MethodInvocation invocation, boolean runningO int paramCount = method.getParameterTypes().length; Object response = null; boolean hasPayloadExpression = method.isAnnotationPresent(Payload.class); - if (!hasPayloadExpression && this.methodMetadataMap != null) { + if (!hasPayloadExpression) { // check for the method metadata next - GatewayMethodMetadata metadata = this.methodMetadataMap.get(method.getName()); - hasPayloadExpression = (metadata != null) && StringUtils.hasText(metadata.getPayloadExpression()); + if (this.methodMetadataMap != null) { + GatewayMethodMetadata metadata = this.methodMetadataMap.get(method.getName()); + hasPayloadExpression = (metadata != null) && StringUtils.hasText(metadata.getPayloadExpression()); + } + else if (this.globalMethodMetadata != null) { + hasPayloadExpression = StringUtils.hasText(this.globalMethodMetadata.getPayloadExpression()); + } } if (paramCount == 0 && !hasPayloadExpression) { Long receiveTimeout = null; diff --git a/spring-integration-core/src/test/java/org/springframework/integration/gateway/GatewayInterfaceTests-context.xml b/spring-integration-core/src/test/java/org/springframework/integration/gateway/GatewayInterfaceTests-context.xml index 669a469a562..3b98b09c603 100644 --- a/spring-integration-core/src/test/java/org/springframework/integration/gateway/GatewayInterfaceTests-context.xml +++ b/spring-integration-core/src/test/java/org/springframework/integration/gateway/GatewayInterfaceTests-context.xml @@ -10,7 +10,7 @@ @@ -34,9 +34,14 @@ + + diff --git a/spring-integration-core/src/test/java/org/springframework/integration/gateway/GatewayInterfaceTests.java b/spring-integration-core/src/test/java/org/springframework/integration/gateway/GatewayInterfaceTests.java index 7a56c8d320c..de88360d26c 100644 --- a/spring-integration-core/src/test/java/org/springframework/integration/gateway/GatewayInterfaceTests.java +++ b/spring-integration-core/src/test/java/org/springframework/integration/gateway/GatewayInterfaceTests.java @@ -1,5 +1,5 @@ /* - * Copyright 2002-2017 the original author or authors. + * Copyright 2002-2018 the original author or authors. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. @@ -75,6 +75,7 @@ import org.springframework.integration.config.EnableIntegration; import org.springframework.integration.context.IntegrationContextUtils; import org.springframework.integration.context.IntegrationProperties; +import org.springframework.integration.handler.AbstractReplyProducingMessageHandler; import org.springframework.integration.handler.BridgeHandler; import org.springframework.integration.support.MessageBuilder; import org.springframework.integration.test.util.TestUtils; @@ -487,6 +488,26 @@ public void testIgnoredHeader() { ((SubscribableChannel) this.errorChannel).unsubscribe(messageHandler); } + @Test + public void testGatewayWithNoArgsMethod() { + ConfigurableApplicationContext ac = + new ClassPathXmlApplicationContext("GatewayInterfaceTests-context.xml", getClass()); + + DirectChannel channel = ac.getBean("requestChannelBar", DirectChannel.class); + channel.subscribe(new AbstractReplyProducingMessageHandler() { + + @Override + protected Object handleRequestMessage(Message requestMessage) { + assertEquals("foo", requestMessage.getPayload()); + return "FOO"; + } + + }); + + NoArgumentsGateway noArgumentsGateway = ac.getBean(NoArgumentsGateway.class); + assertEquals("FOO", noArgumentsGateway.pullData()); + ac.close(); + } public interface Foo { @@ -520,6 +541,11 @@ public interface Baz { void baz(String payload); } + public interface NoArgumentsGateway { + + String pullData(); + } + public static class BazMapper implements MethodArgsMessageMapper { @Override