diff --git a/pom.xml b/pom.xml index 8644c62..c0cd229 100644 --- a/pom.xml +++ b/pom.xml @@ -27,7 +27,7 @@ bus 1.1.0.BUILD-SNAPSHOT - 1.0.0.BUILD-SNAPSHOT + 1.0.0.M2 diff --git a/spring-cloud-bus/src/main/java/org/springframework/cloud/bus/BusAutoConfiguration.java b/spring-cloud-bus/src/main/java/org/springframework/cloud/bus/BusAutoConfiguration.java index 74f63d5..4155f0b 100644 --- a/spring-cloud-bus/src/main/java/org/springframework/cloud/bus/BusAutoConfiguration.java +++ b/spring-cloud-bus/src/main/java/org/springframework/cloud/bus/BusAutoConfiguration.java @@ -78,9 +78,6 @@ public class BusAutoConfiguration implements ApplicationEventPublisherAware { if (input.getDestination() == null) { input.setDestination(this.bus.getDestination()); } - if (input.getGroup() == null) { - input.setGroup(this.bus.getGroup()); - } BindingProperties outputBinding = this.bindings.getBindings() .get(SpringCloudBusClient.OUTPUT); if (outputBinding == null) { diff --git a/spring-cloud-bus/src/main/java/org/springframework/cloud/bus/BusProperties.java b/spring-cloud-bus/src/main/java/org/springframework/cloud/bus/BusProperties.java index abce838..71f1b9e 100644 --- a/spring-cloud-bus/src/main/java/org/springframework/cloud/bus/BusProperties.java +++ b/spring-cloud-bus/src/main/java/org/springframework/cloud/bus/BusProperties.java @@ -16,8 +16,6 @@ package org.springframework.cloud.bus; -import java.util.UUID; - import org.springframework.boot.context.properties.ConfigurationProperties; import lombok.Data; @@ -38,11 +36,6 @@ public class BusProperties { * Name of Spring Cloud Stream destination for messages. */ private String destination = "topic:springCloudBus"; - /** - * Group ID for message consumer. Usually globally unique (so all consumers get a - * copy of all messages). - */ - private String group = UUID.randomUUID().toString(); private boolean enabled = true;