Я пытаюсь интегрировать Hystrix CircuitBreaker в свое примерное приложение. У меня есть два приложения, одно из которых ведет себя как сервер, а другое — как клиент. CircuitBreaker также работает нормально, я вижу клиента формы Hystrix.stream.
Теперь я тестирую несколько клиентов в одном DashBoard, используя поток Turbine.
На стороне сервера я добавил 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? Любая помощь будет оценена по достоинству.