Skip to content

HTTPS clone URL

Subversion checkout URL

You can clone with HTTPS or Subversion.

Download ZIP
Browse files

upgraded to SI 2.2.O.RELEASE and enabled amqp inbound

  • Loading branch information...
commit ccc04930aaccdae74a05b03fd2734e8a68c232c6 1 parent 03d9f84
David Turanski authored
View
4 gradle.properties
@@ -2,5 +2,5 @@ version = 1.0.0.BUILD-SNAPSHOT
junitVersion = 4.8.2
log4jVersion = 1.2.14
mockitoVersion = 1.9.0
-springIntegrationVersion = 2.2.0.RC2
-groovyVersion = 2.0.5
+springIntegrationVersion = 2.2.0.RELEASE
+groovyVersion = 2.0.4
View
4 ...y-amqp/src/main/groovy/org/springframework/integration/dsl/groovy/amqp/builder/AmqpInboundFactory.groovy
@@ -15,6 +15,7 @@ package org.springframework.integration.dsl.groovy.amqp.builder
import groovy.util.FactoryBuilderSupport
import java.util.Map
import org.springframework.integration.dsl.groovy.builder.IntegrationComponentFactory
+import org.springframework.integration.dsl.groovy.amqp.AmqpInbound
/**
* @author David Turanski
@@ -27,8 +28,7 @@ class AmqpInboundFactory extends IntegrationComponentFactory {
*/
@Override
protected Object doNewInstance(FactoryBuilderSupport builder, Object name, Object value, Map attributes) {
- // TODO Auto-generated method stub
- return null;
+ new AmqpInbound(attributes)
}
}
View
15 ...roovy-amqp/src/test/groovy/org/springframework/integration/dsl/groovy/amqp/builder/AmqpUsageTests.groovy
@@ -76,4 +76,19 @@ class AmqpUsageTests {
}
}
}
+
+ @Test
+ //TODO: Not easy to test without running rabbit broker
+ void testInboundGateway() {
+ builder.doWithSpringIntegration {
+ doWithRabbit {
+ connectionFactory()
+ queue 'q1'
+ }
+ messageFlow {
+ amqpListen queueNames:'q1'
+ handle {println it}
+ }
+ }
+ }
}
View
2  ...core/src/main/groovy/org/springframework/integration/dsl/groovy/builder/dom/MessageFlowDomBuilder.groovy
@@ -64,7 +64,7 @@ class MessageFlowDomBuilder extends IntegrationComponentDomBuilder {
previousComponent = component
}
//Fix for https://jira.springsource.org/browse/INTDSLGROOVY-11
- if (messageFlow.inputChannel?.startsWith('$mflw')){
+ if (messageFlow.inputChannel?.startsWith('$mfl')){
channelBuilder.createDirectChannelIfNotDefined(builder, messageFlow.inputChannel)
}
}
View
2  ...vy-http/src/test/groovy/org/springframework/integration/dsl/groovy/http/builder/HttpOutboundTests.groovy
@@ -12,9 +12,7 @@
*/
package org.springframework.integration.dsl.groovy.http.builder
-import org.springframework.integration.Message
import org.springframework.integration.dsl.groovy.builder.IntegrationBuilder;
-import org.springframework.integration.message.GenericMessage
import org.junit.Test
import org.junit.Ignore
/**
Please sign in to comment.
Something went wrong with that request. Please try again.