diff --git a/.classpath b/.classpath
deleted file mode 100644
index 87b4010..0000000
--- a/.classpath
+++ /dev/null
@@ -1,17 +0,0 @@
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
diff --git a/.gitignore b/.gitignore
index 1beb459..0677479 100644
--- a/.gitignore
+++ b/.gitignore
@@ -1,3 +1,5 @@
target
.settings
.springBeans
+.classpath
+.project
diff --git a/.project b/.project
deleted file mode 100644
index ba707a1..0000000
--- a/.project
+++ /dev/null
@@ -1,44 +0,0 @@
-
-
- spring-integration-flow
-
-
- spring-integration-core
-
-
-
- org.eclipse.wst.common.project.facet.core.builder
-
-
-
-
- org.eclipse.jdt.core.javabuilder
-
-
-
-
- org.eclipse.wst.validation.validationbuilder
-
-
-
-
- org.maven.ide.eclipse.maven2Builder
-
-
-
-
- org.springframework.ide.eclipse.core.springbuilder
-
-
-
-
-
- org.springframework.ide.eclipse.core.springnature
- org.eclipse.jem.workbench.JavaEMFNature
- org.eclipse.wst.common.modulecore.ModuleCoreNature
- org.eclipse.jdt.groovy.core.groovyNature
- org.maven.ide.eclipse.maven2Nature
- org.eclipse.jdt.core.javanature
- org.eclipse.wst.common.project.facet.core.nature
-
-
diff --git a/pom.xml b/pom.xml
index 0cb7e21..ddcc7e7 100644
--- a/pom.xml
+++ b/pom.xml
@@ -21,7 +21,7 @@
UTF8
- 3.1.0.M2
+ 3.1.0.RC1
2.1.0.M2
true
@@ -77,6 +77,12 @@
spring-integration-core
${spring.integration.version}
+
+ org.springframework.integration
+ spring-integration-jmx
+ ${spring.integration.version}
+ test
+
org.springframework
@@ -187,9 +193,6 @@
-
- run
-
diff --git a/src/main/java/org/springframework/integration/flow/Flow.java b/src/main/java/org/springframework/integration/flow/Flow.java
index f927384..ce81dfb 100644
--- a/src/main/java/org/springframework/integration/flow/Flow.java
+++ b/src/main/java/org/springframework/integration/flow/Flow.java
@@ -70,7 +70,7 @@ public class Flow implements InitializingBean, BeanNameAware, ChannelResolver, A
private volatile ChannelResolver flowChannelResolver;
- private volatile PublishSubscribeChannel flowOutputChannel;
+ private volatile SubscribableChannel flowOutputChannel;
private volatile boolean help;
@@ -211,7 +211,7 @@ public class Flow implements InitializingBean, BeanNameAware, ChannelResolver, A
* a single PublishSubscribeChannel
* @return the publish-subscribe channel
*/
- public PublishSubscribeChannel getFlowOutputChannel() {
+ public SubscribableChannel getFlowOutputChannel() {
return flowOutputChannel;
}
@@ -220,8 +220,8 @@ public class Flow implements InitializingBean, BeanNameAware, ChannelResolver, A
* a single PublishSubscribeChannel
* @param the publish-subscribe channel
*/
- public void setFlowOutputChannel(PublishSubscribeChannel flowOutputChannel) {
- this.flowOutputChannel = flowOutputChannel;
+ public void setFlowOutputChannel(SubscribableChannel flowOutputChannel) {
+ this.flowOutputChannel = flowOutputChannel;
}
@Override
diff --git a/src/test/java/org/springframework/integration/flow/config/xml/FlowContextTest.java b/src/test/java/org/springframework/integration/flow/config/xml/FlowContextTest.java
index 80c242a..26e95f0 100644
--- a/src/test/java/org/springframework/integration/flow/config/xml/FlowContextTest.java
+++ b/src/test/java/org/springframework/integration/flow/config/xml/FlowContextTest.java
@@ -32,4 +32,12 @@ public class FlowContextTest {
throw e;
}
}
+
+ @Test
+ public void testFlowWithJMX() {
+
+ new ClassPathXmlApplicationContext("/FlowContextWithJMXTest-context.xml");
+
+ }
+
}
diff --git a/src/test/resources/FlowContextTest-context.xml b/src/test/resources/FlowContextTest-context.xml
index 9b24b2d..8827133 100644
--- a/src/test/resources/FlowContextTest-context.xml
+++ b/src/test/resources/FlowContextTest-context.xml
@@ -1,12 +1,12 @@
-
+