spring bus.

发表于

  1. request /actuator/bus-refresh

  2. BusRefreshEndpoint received request

  3. ApplicationEventPublisher.publish(RemoteApplicationEvent)

  4. BusAutoConfiguration#

@EventListener(classes = RemoteApplicationEvent.class)
	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());
		}
	}