My Cleint가 2 개의 인스턴스를 가지고 있고 큐의 이름을 바꾸기 위해 스 니펫을 사용하고 있습니다. testExchange.testQueue가 생성되었습니다. 2 명의 고객, 즉 클라이언트 인스턴스를 볼 수 있지만 while/버스/새로 고침 하나의 인스턴스가 새로 고쳐지고있는 것을 볼 수 있습니다. /버스/새로 고침 모든 인스턴스가 새로 고쳐 져야하
내 봄 클라우드 구성 클라이언트는 spring.cloud.starter.bus.amqp에 의존성을 가지고 있지만, 여전히 아직도 내가 내 설정 클라이언트 응용 프로그램에서 이러한 종속성이 build.gradle
compile("org.springframework.cloud:spring-cloud-starter-stream-rabbit:1.1.3.RELE
(https://github.com/spring-cloud/spring-cloud-bus)으로는 그 두 가장 일반적인 구현이기 때문에 버스 우선은, 카프카토끼 및 을 포함 같은 언급 하지만 Spring Cloud Stream은 매우 유연한 이며 바인더는 스프링 클라우드 버스와 함께 작동합니다. 우리는 토끼 나 카프카에 대한 또 다른 인프라를 유지할 수없는
제안 된 SCS 집계를 구현하려고하지만 실제로 그 목적을 이해하지 못하고 있습니다. 결과가 놀랍습니다. 첫째, 여기서 코드 ... 소스, 예약 할 수있는 메시지를 제공이다이어서 @SpringBootApplication
@EnableBinding(Source.class)
public class SourceApplication {
private
세 가지 응용 프로그램이 있습니다. 하나는 spring-cloud-config 서버 지점이고 나머지는 spring-cloud-config 클라이언트 지점입니다. 나는 나의 클라이언트가 자동 새로 고침이 변경 된 점하기 위해 서로 봄 - 클라우드 버스를 구성하지만 내 응용 프로그램을 실행에, 나는 c.netflix.discovery.TimedSuperviso
스프링 부트 1.5.6.RELEASE, 스프링 클라우드 구성 1.3.2.RELEASE 및 스프링 클라우드 스타터 버스 (Kafka) 1.2.0.RELEASE, 카프카 버전은 0.10.1.1입니다. 나는이 SSL을 사용하는 브로커를 사용하도록 구성하기 위해 노력하고 있어요,하지만 다음과 같습니다 경고 메시지의 반복 순서 (각 브로커에 대해 하나) 치울 : 내