[GitHub] [rocketmq-streams] Shuozeli commented on pull request #295: [ISSUE #281]Filter the removeQueues from addQueues when recovering the state

Sun, 11 Jun 2023 18:00:19 -0700 


Shuozeli commented on PR #295:
URL: https://github.com/apache/rocketmq-streams/pull/295#issuecomment-1586409055

   @ni-ze 抱歉，我之前的理解有些错误。我改了一下code：
   
   第一步：将需要被删除的 `removeQueue` 从 `originalListener` 删掉。做法是调用 
`originListener.messageQueueChanged`，但传入的是  `unchangedQueue` 的set，这样 
`originalListener` 会停止接收 `removedQueue` 的消息。
   第二步：对状态进行操作。
   第三步：把 `addQueue` 加入到 `originalListener` 里边。
   
   


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]

Reply via email to