spring boot 에서 active mq사용에 대한 질문이 있습니다.

Question

spring boot 에서 active mq를 이용해 토픽을 생성해서 메시지를 처리하고 있습니다.A(pub)는 5분에 한번씩 1토픽을 생성하고 mq에 넣습니다.B(sub)은 mq에 있는 메시지를 처리합니다.A가 매시간 5분, 10분, 15분, 20분, 25분, 30분, 35분, 40분, 45분, 50분, 55분에 메시지를 생성하는데 B가 5분, 10분 메시지 처리후, 시스템 에러로 종료되고 43분에 재시작 되었을때 mq에 있는 처리되지 않은 15분, 20분, 25분, 30분, 35분, 40분 의 메시지를 처리하고 45분의 메시지를 이어서 처리하게 하고 싶은데 재시작 되기 이전의 토픽을 처리하지 못하고 있습니다.재시작시 mq에 처리되지 않고 쌓여있는 토피을 처리하는 방법이 있을까요??

뒷집할머니 · Answer

pub / sub 는 일반적으로 실시간으로 메시지를 전달합니다.redis의 list를 이용한 queue 같은걸 이용해보시는건 어떨까요?

spring boot 에서 active mq사용에 대한 질문이 있습니다.

1개의 답변

Q&A 목록