From cc659d3ae7e808127d2d6f3bd9f96b7d1d002091 Mon Sep 17 00:00:00 2001
From: Spencer Gibb <spencer@gibb.us>
Date: Wed, 3 Sep 2014 15:22:54 -0600
Subject: [PATCH] changed s-i-java-dsl to snapshot to remove java 8
 requirement; renamed platform* to cloud*

---
 pom.xml                                       |  2 +-
 .../bus/amqp/AmqpBusAutoConfiguration.java    | 24 +++++++++----------
 2 files changed, 13 insertions(+), 13 deletions(-)

diff --git a/pom.xml b/pom.xml
index d14eb56..5e59d7d 100644
--- a/pom.xml
+++ b/pom.xml
@@ -62,7 +62,7 @@
         <dependency>
             <groupId>org.springframework.integration</groupId>
             <artifactId>spring-integration-java-dsl</artifactId>
-            <version>1.0.0.M2</version>
+            <version>1.0.0.BUILD-SNAPSHOT</version>
         </dependency>
         <dependency>
             <groupId>org.springframework.integration</groupId>
diff --git a/src/main/java/org/springframework/cloud/bus/amqp/AmqpBusAutoConfiguration.java b/src/main/java/org/springframework/cloud/bus/amqp/AmqpBusAutoConfiguration.java
index c811402..ace837d 100644
--- a/src/main/java/org/springframework/cloud/bus/amqp/AmqpBusAutoConfiguration.java
+++ b/src/main/java/org/springframework/cloud/bus/amqp/AmqpBusAutoConfiguration.java
@@ -34,7 +34,7 @@ import org.springframework.integration.handler.LoggingHandler;
 @ConditionalOnExpression("${bus.amqp.enabled:true}")
 public class AmqpBusAutoConfiguration {
 
-    public static final String SPRING_PLATFORM_BUS = "spring.platform.bus";
+    public static final String SPRING_CLOUD_BUS = "spring.cloud.bus";
 
     @Autowired
     private ConnectionFactory connectionFactory;
@@ -50,23 +50,23 @@ public class AmqpBusAutoConfiguration {
 
     //TODO: how to fail gracefully if no rabbit?
     @Bean
-    protected FanoutExchange platformBusExchange() {
+    protected FanoutExchange cloudBusExchange() {
         //TODO: change to TopicExchange?
-        FanoutExchange exchange = new FanoutExchange(SPRING_PLATFORM_BUS);
+        FanoutExchange exchange = new FanoutExchange(SPRING_CLOUD_BUS);
         amqpAdmin.declareExchange(exchange);
         return exchange;
     }
 
     @Bean
-    protected Queue localPlatformBusQueue() {
+    protected Queue localCloudBusQueue() {
         Queue queue = amqpAdmin.declareQueue();
-        amqpAdmin.declareBinding(BindingBuilder.bind(queue).to(platformBusExchange()));
+        amqpAdmin.declareBinding(BindingBuilder.bind(queue).to(cloudBusExchange()));
         return queue;
     }
 
     @SuppressWarnings("unchecked")
 	@Bean
-    public ApplicationEventListeningMessageProducer platformBusProducer() {
+    public ApplicationEventListeningMessageProducer cloudBusProducer() {
         ApplicationEventListeningMessageProducer producer = new ApplicationEventListeningMessageProducer();
         producer.setEventTypes(RemoteApplicationEvent.class);
         producer.setOutputChannel(new DirectChannel());
@@ -74,10 +74,10 @@ public class AmqpBusAutoConfiguration {
     }
 
     @Bean
-    public IntegrationFlow platformBusOutboundFlow() {
-        return IntegrationFlows.from(platformBusProducer())
+    public IntegrationFlow cloudBusOutboundFlow() {
+        return IntegrationFlows.from(cloudBusProducer())
                 .filter(outboundFilter())
-                .handle(Amqp.outboundAdapter(this.amqpTemplate).exchangeName(SPRING_PLATFORM_BUS))
+                .handle(Amqp.outboundAdapter(this.amqpTemplate).exchangeName(SPRING_CLOUD_BUS))
                 .get();
     }
 
@@ -119,9 +119,9 @@ public class AmqpBusAutoConfiguration {
     }
 
     @Bean
-    public IntegrationFlow platformBusInboundFlow(Environment env) {
+    public IntegrationFlow cloudBusInboundFlow(Environment env) {
         ApplicationEventPublishingMessageHandler messageHandler = new ApplicationEventPublishingMessageHandler();
-        return IntegrationFlows.from(Amqp.inboundAdapter(connectionFactory, localPlatformBusQueue()))
+        return IntegrationFlows.from(Amqp.inboundAdapter(connectionFactory, localCloudBusQueue()))
             .filter(inboundFilter())
             .handle(messageHandler)
             .get();
@@ -133,7 +133,7 @@ public class AmqpBusAutoConfiguration {
     }
 
     @Bean
-    @GlobalChannelInterceptor(patterns = "platformBusInboundFlow*")
+    @GlobalChannelInterceptor(patterns = "cloudBusInboundFlow*")
     public WireTap wireTap() {
         return new WireTap(wiretapChannel());
     }