fix: recreate Redis stream receiver after listener failure

[oosuhada]

요약

• Redis Stream listener가 오류로 종료된 뒤 재구독할 때 기존 StreamReceiver 인스턴스를 재사용하던 동작을 수정했습니다.
• 재구독마다 새로운 StreamReceiver를 생성하도록 변경해, 네트워크/연결 오류 이후 기존 receiver가 stale/terminal 상태에 남아도 listener가 복구될 수 있도록 했습니다.
• 첫 receiver가 오류를 반환한 뒤 자동 재구독 과정에서 두 번째 receiver가 새로 생성되는 회귀 테스트를 추가했습니다.
• 기존 릴리스 패턴에 맞춰 버전을 0.5.0 → 0.5.1로 올렸습니다.

배경

AbstractSagaListener는 listener가 종료되면 subscribeStream()을 다시 호출해 자동 복구를 시도합니다. 하지만 RedisStreamSagaListener는 StreamReceiver를 프로퍼티로 한 번만 생성해 두고 있었기 때문에, receiver 자체가 연결 오류 이후 복구 불가능한 상태가 되면 재구독에서도 같은 인스턴스를 계속 사용하게 됩니다.

이 동작은 git-goods/gitanimals#501에서 관찰된 장시간 실행 API의 Saga timeout 증상을 조사하면서 확인했습니다. 해당 서비스에서는 일반 read API는 정상인 상태에서 Saga 기반 write 요청만 기본 10초/100초 결과 timeout으로 실패하고 있었습니다.

테스트

• ./gradlew test --tests 'org.rooftop.netx.redis.RedisStreamSagaListenerTest' --console=plain
• patched Netx를 로컬 gitanimals-api에 연결해 아래 Saga 회귀 테스트를 각각 깨끗한 Redis에서 검증했습니다.
  • GotchaFacadeV3Test
  • RegisterProductFacadeTest
  • BuyProductFacadeTest

---

Summary

• recreate the Redis StreamReceiver whenever the listener subscribes again after an error
• avoid reusing a stale/terminal receiver instance across the existing auto-restart path
• add a regression test verifying that a receiver failure causes a new receiver to be created on resubscription
• bump the release version from 0.5.0 to 0.5.1, following the existing release pattern

Background

AbstractSagaListener already attempts to recover by calling subscribeStream() again after termination. However, RedisStreamSagaListener previously kept one StreamReceiver instance for its entire lifetime. If that receiver itself becomes stale or terminal after a connection failure, resubscribing keeps reusing the same broken receiver.

This behavior was identified while investigating git-goods/gitanimals#501, where long-running API instances continued serving reads while Saga-based writes consistently timed out waiting for results.

Test

• ./gradlew test --tests 'org.rooftop.netx.redis.RedisStreamSagaListenerTest' --console=plain
• verified the patched Netx against gitanimals-api Saga tests with clean Redis instances:
  • GotchaFacadeV3Test
  • RegisterProductFacadeTest
  • BuyProductFacadeTest

[oosuhada]

@devxb 확인 부탁드립니다.

git-goods/gitanimals#501 운영 장애가 아직 지속 중입니다. 방금 다시 확인했을 때 Gotcha 500 누적 건수는 199 → 204로 증가했고 성공 건수는 4,025에서 그대로였으며, Auction 신규 등록도 2026-08-22 이후 멈춰 있습니다.

이 PR의 0.5.1을 사용하도록 gitanimals-api dependency bump 브랜치도 준비해두었습니다: oosuhada/gitanimals-api:fix/issue-501-shop (749c7da). 0.5.1이 merge/release되면 바로 API 쪽 PR로 이어갈 수 있습니다.

---

@devxb Could you please take a look when you have a chance?

The production issue tracked in git-goods/gitanimals#501 is still ongoing. The Gotcha 500 count increased from 199 to 204 while successful requests stayed at 4,025, and new Auction registrations are still stuck after 2026-08-22.

I also prepared the gitanimals-api dependency bump branch for Netx 0.5.1: oosuhada/gitanimals-api:fix/issue-501-shop (749c7da). Once 0.5.1 is merged/released, the API PR is ready to follow.