Как включить турбинный поток с помощью сервиса Cloud Foundry Rabbit MQ

Question

Я пытаюсь интегрировать Hystrix CircuitBreaker в мой пример приложения. У меня есть два приложения, одно из которых работает как сервер, а другое как клиент. CircuitBreaker работает нормально, я вижу форму клиента Hystrix.stream.

Теперь я испытываю несколько клиентов в одной панели DashBoard, используя поток турбины.

На стороне сервера я добавил 2 зависимости, как показано ниже:

spring-cloud-starter-turbine-stream
spring-cloud-starter-stream.rabbit

и аннотация @EnableTurbineStream в приложении.

На стороне клиента я добавил следующие зависимости:

spring-cloud-starter-hystrix-stream
spring-cloud-starter-stream.rabbit

Оба приложения развернуты в Pivotal Cloud Foundry и привязаны к сервису Rabbit Mq для PCF.

При развертывании клиента я вижу ниже исключение:

java.io.IOException :null
Caused by : com.rabbitmq.client.ShutDownSignalException :  channel error     :protocol method : #method<channel.close><reply-code=406, reply-test=PRECONDITION-FAILED - equivalent arg 'type' for exchange 'spring.cloud.hystrix.stream' in vhost '' : receieved 'topic' but current is 'Direct', class-id=40, methid-id=10>

При попадании на сервер Turbine я получаю

data : {type : ping}


Management port on turbine server is set to -1.

Требуется ли какая-либо конфигурация MQ на клиенте и сервере для передачи потока Hystrix в Rabbit MQ? Любая помощь будет оценена.

Answer 1

Ошибка на стороне клиента говорит вам, что вы пытаетесь объявить обмен, который уже существует, но с типом, который конфликтует. Вы можете исправить это, изменив имя обмена или просто удалив старое. Или просто удалите службу и заново создайте ее в Cloud Foundry,