busrefresh 에러

Question

안녕하세요. postman으로 busrefresh 전송할때 에러나서 어떻게 해결할 수 있을지 질문 드립니다. 127.0.0.1:8000/actuator/busrefresh 혹은 127.0.0.1:8000/user-service/actuator/busrefresh 로 전송하면 500 Internal Server Error 로 응답 받으면서 "org.springframework.messaging.MessageHandlingException: error occurred in message handler [org.springframework.integration.amqp.outbound.AmqpOutboundEndpoint@5c20f1e]; nested exception is org.springframework.amqp.AmqpConnectException: java.net.ConnectException: Connection refused: connect, failedMessage=GenericMessage [payload=byte[202], headers={id=673f43aa-6af0-73de-d386-1b08af6ed560, contentType=application/json, target-protocol=amqp, timestamp=1660318593074}]
	at org.springframework.integration.support.utils.IntegrationUtils.wrapInHandlingExceptionIfNecessary(IntegrationUtils.java:191)
	at org.springframework.integration.handler.AbstractMessageHandler.handleMessage(AbstractMessageHandler.java:65)
	at org.springframework.cloud.stream.binder. 해당 에러메세지를 trace 값으로 내려받고 있습니다. user-service에서도 로그를 보면 Connection refused: connect 로그가 찍힙니다. application.yml에 management endpoint 부분에 busrefresh도 추가했습니다. 해당 설정에서 busrefresh를 제외한 다른 값들은 문제 없지 잘 작동하고 있습니다.

Dowon Lee · Answer

안녕하세요, 이도원입니다. Actuator의 busrefresh를 사용하기 위해서 강의에서는 AMQP를 사용하고 있습니다. AMQP 서버는 RabbirMQ를 설치해서 사용했고요. OS에 직접 RabbitMQ를 설치하거나 Docker로 설치해서 사용해 보시기 바랍니다. RabbitMQ 서버를 기동한 다음에도 오류가 발생하면 다시 질문 남겨 주세요. 감사합니다.