我正在使用spring集成开发restful api,当我的一个服务出现异常时,我无法检索消息。
这是我的应用程序上下文:
<int-http:inbound-gateway id="v1.getEvent.inbound.gateway"
path="/ptgapi/{apiVersion}/clients/{clientId}/events/{eventId}"
supported-methods="GET"
request-channel="v1.getEvent.channel.input"
reply-channel="v1.getEvent.channel.output"
error-channel="v1.getEvent.channel.error"
convert-exceptions="true"
mapped-request-headers="HTTP_REQUEST_HEADERS,X-ptg-client-token,X-ptg-user-id,X-ptg-user-token,X-ptg-channel"
request-timeout="50000"
reply-timeout="50000">
<int-http:header name="apiVersion" expression="#pathVariables.apiVersion"/>
<int-http:header name="clientId" expression="#pathVariables.clientId"/>
<int-http:header name="eventId" expression="#pathVariables.eventId"/>
</int-http:inbound-gateway>
<int:chain input-channel="v1.getEvent.channel.input" output-channel="v1.getEvent.channel.output" send-timeout="50000">
<int:header-enricher>
<int:error-channel ref="v1.getEvent.channel.error" />
</int:header-enricher>
<int:service-activator ref="v1.validation.service" method="validateRequest"/>
<int:service-activator ref="v1.getEvent.service" method="getEvent"/>
<int:object-to-json-transformer/>
</int:chain>
<int:chain input-channel="v1.getEvent.channel.error" output-channel="v1.getEvent.channel.output">
<int:transformer ref="errorUnwrapper" method="manageError" />
</int:chain>
我的errorUnwrapper变压器是:
@消息终结点
公共类errorunwrapper{
@Transformer
public Message<?> manageError(Message<?> errorMessage) {
Message<?> failedMessage = ((MessagingException) errorMessage.getPayload())
.getFailedMessage();
Message<?> messageOut = MessageBuilder
.withPayload("")
.copyHeadersIfAbsent(failedMessage.getHeaders())
.setHeaderIfAbsent(HttpHeaders.STATUS_CODE, HttpStatus.ALREADY_REPORTED)
.build();
return failedMessage;
}
}
这个想法是在转换器中分配状态错误代码来通知用户,但是信息永远不会到达客户端,尽管我可以确认返回语句是在调试模式下到达的…
有什么问题吗?
谢谢!
最佳答案
问题是您正在从failedMessage
回复已失效的replychannel头;网关正在等待errorMessage中replychannel头的回复。
您可以简单地使用errorMessage,或者,如果您需要failedMessage中的其他头,则使用copyHeaders(errorMessage.getHeaders()).copyHeadersIfAbsent(failedMessge.getHeaders())
。
这将保留正确的replychannel。
在3.0中(目前处于里程碑2),我们添加了增强的诊断功能来报告这个相当常见的错误(其中回复被发送到一个失效的回复通道)。