|
|
|
@ -75,7 +75,7 @@ public class RabbitReceiver { |
|
|
|
|
universal(receiveMessage); |
|
|
|
|
break; |
|
|
|
|
case COMMON: |
|
|
|
|
his(receiveMessage); |
|
|
|
|
commonRetry(receiveMessage); |
|
|
|
|
break; |
|
|
|
|
|
|
|
|
|
default: |
|
|
|
@ -220,8 +220,8 @@ public class RabbitReceiver { |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
private void his(Map<String, String> receiveMessage) { |
|
|
|
|
MessageSendResult messageSendResult = MessageApiHelper.templateMessageForCode02(receiveMessage); |
|
|
|
|
private void commonRetry(Map<String, String> receiveMessage) { |
|
|
|
|
MessageSendResult messageSendResult = MessageApiHelper.templateMessageForMap(receiveMessage); |
|
|
|
|
retry(messageSendResult, receiveMessage); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|