Как включить турбинный поток, используя облачный литейный сервис 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 и переплетены с кроликом службой Мда для ФКПА.

На клиенте развертывания я см ниже Исключение:

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> 

На hiting сервер Турбина, я получаю

data : {type : ping} 


Management port on turbine server is set to -1. 

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

Answer 1

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