Spring Cloud Stream同一通道根據消息內容分發不同的消費邏輯

應用場景 有的時候,我們對於同一通道中的消息處理,會通過判斷頭信息或者消息內容來做一些差異化處理,比如:可能在消息頭信息中帶入消息版本號,然後通過if判斷來執行不同的處理邏輯,其代碼結構可能是這樣的: @StreamListener(value = TestTopic.INPUT) public void receiveV1(String payload, @Header("version") S
相關文章
相關標籤/搜索