diff --git a/docs/pom.xml b/docs/pom.xml index c565a3e..d2f6968 100644 --- a/docs/pom.xml +++ b/docs/pom.xml @@ -16,7 +16,7 @@ spring-cloud-bus ${basedir}/.. - 1.1.x,1.2.x,1.3.x,2.1.x + 2.1.x,2.2.x spring.cloud.bus.* 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 d8e5e88..14d3030 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 @@ -18,6 +18,9 @@ package org.springframework.cloud.bus; import javax.annotation.PostConstruct; +import org.apache.commons.logging.Log; +import org.apache.commons.logging.LogFactory; + import org.springframework.beans.factory.annotation.Autowired; import org.springframework.boot.actuate.autoconfigure.endpoint.condition.ConditionalOnAvailableEndpoint; import org.springframework.boot.actuate.endpoint.annotation.Endpoint; @@ -69,6 +72,8 @@ import org.springframework.util.PathMatcher; // so actuator endpoints have needed dependencies public class BusAutoConfiguration implements ApplicationEventPublisherAware { + private static final Log log = LogFactory.getLog(BusAutoConfiguration.class); + /** * Name of the Bus path matcher. */ @@ -140,6 +145,9 @@ public class BusAutoConfiguration implements ApplicationEventPublisherAware { public void acceptLocal(RemoteApplicationEvent event) { if (this.serviceMatcher.isFromSelf(event) && !(event instanceof AckRemoteApplicationEvent)) { + if (log.isDebugEnabled()) { + log.debug("Sending remote event on bus: " + event); + } this.cloudBusOutboundChannel.send(MessageBuilder.withPayload(event).build()); } } @@ -154,6 +162,11 @@ public class BusAutoConfiguration implements ApplicationEventPublisherAware { // If it's an ACK we are finished processing at this point return; } + + if (log.isDebugEnabled()) { + log.debug("Received remote event from bus: " + event); + } + if (this.serviceMatcher.isForSelf(event) && this.applicationEventPublisher != null) { if (!this.serviceMatcher.isFromSelf(event)) { diff --git a/spring-cloud-bus/src/main/java/org/springframework/cloud/bus/event/EnvironmentChangeRemoteApplicationEvent.java b/spring-cloud-bus/src/main/java/org/springframework/cloud/bus/event/EnvironmentChangeRemoteApplicationEvent.java index 9548510..d80ebda 100644 --- a/spring-cloud-bus/src/main/java/org/springframework/cloud/bus/event/EnvironmentChangeRemoteApplicationEvent.java +++ b/spring-cloud-bus/src/main/java/org/springframework/cloud/bus/event/EnvironmentChangeRemoteApplicationEvent.java @@ -18,6 +18,8 @@ package org.springframework.cloud.bus.event; import java.util.Map; +import org.springframework.core.style.ToStringCreator; + /** * @author Spencer Gibb */ @@ -73,4 +75,13 @@ public class EnvironmentChangeRemoteApplicationEvent extends RemoteApplicationEv return true; } + @Override + public String toString() { + return new ToStringCreator(this).append("id", getId()) + .append("originService", getOriginService()) + .append("destinationService", getDestinationService()) + .append("values", values).toString(); + + } + } diff --git a/spring-cloud-bus/src/main/java/org/springframework/cloud/bus/event/RemoteApplicationEvent.java b/spring-cloud-bus/src/main/java/org/springframework/cloud/bus/event/RemoteApplicationEvent.java index e768d99..8fe5cce 100644 --- a/spring-cloud-bus/src/main/java/org/springframework/cloud/bus/event/RemoteApplicationEvent.java +++ b/spring-cloud-bus/src/main/java/org/springframework/cloud/bus/event/RemoteApplicationEvent.java @@ -22,6 +22,7 @@ import com.fasterxml.jackson.annotation.JsonIgnoreProperties; import com.fasterxml.jackson.annotation.JsonTypeInfo; import org.springframework.context.ApplicationEvent; +import org.springframework.core.style.ToStringCreator; import org.springframework.util.StringUtils; /** @@ -134,4 +135,12 @@ public abstract class RemoteApplicationEvent extends ApplicationEvent { return true; } + @Override + public String toString() { + return new ToStringCreator(this).append("id", id) + .append("originService", originService) + .append("destinationService", destinationService).toString(); + + } + } diff --git a/spring-cloud-bus/src/main/java/org/springframework/cloud/bus/event/UnknownRemoteApplicationEvent.java b/spring-cloud-bus/src/main/java/org/springframework/cloud/bus/event/UnknownRemoteApplicationEvent.java index 5c859dc..c1fbbbf 100644 --- a/spring-cloud-bus/src/main/java/org/springframework/cloud/bus/event/UnknownRemoteApplicationEvent.java +++ b/spring-cloud-bus/src/main/java/org/springframework/cloud/bus/event/UnknownRemoteApplicationEvent.java @@ -16,6 +16,8 @@ package org.springframework.cloud.bus.event; +import org.springframework.core.style.ToStringCreator; + /** * @author Stefan Pfeiffer */ @@ -49,7 +51,20 @@ public class UnknownRemoteApplicationEvent extends RemoteApplicationEvent { } public String getPayloadAsString() { - return new String(this.payload); + if (this.payload != null) { + return new String(this.payload); + } + return null; + } + + @Override + public String toString() { + return new ToStringCreator(this).append("id", getId()) + .append("originService", getOriginService()) + .append("destinationService", getDestinationService()) + .append("typeInfo", typeInfo).append("payload", getPayloadAsString()) + .toString(); + } }