当前位置: 首页 > 知识库问答 >
问题:

如何重写SqsConfiguration以返回SimpleMessageListenerContainer的自定义实现

孔山
2023-03-14

在我们的Spring Boot应用程序中,我们使用Spring Cloud AWS:

  • Spring-Cloud-Starter-AWS
  • Spring-Cloud-AWS-AutoConfigure
  • Spring-Cloud-AWS-Messaging

若要从SQS队列接收消息,请执行以下操作。然而,我们需要能够启动应用程序,即使队列不可访问(即“(服务:AmazonSQS;状态代码:403;错误代码:AccessDenied”)。为此,我们需要能够重写org.SpringFramework.Cloud.aws.Messaging.config.Annotation.SQSConfiguration类,并提供我们自己的org.SpringFramework.Cloud.aws.Messaging.Listener.SimpleMessageListenerContainer实现。

什么是正确的方法来做到这一点,并且不破坏我们现有代码中的自动连接?

共有1个答案

莫繁
2023-03-14

您必须为自定义的SimpleMessageListenerContainerFactory声明@bean,但仍然保留@enableSQLSQSConfiguration将与您的自定义一起为@autowired

 类似资料:
  • 如何在不同的springboot控制器方法中使用不同的json序列化?假设我有 在一些控制器方法中,我只想以JSON的形式返回一个家伙的名字。在某些方法中,我希望以JSON的形式返回名称和年龄。在某些方法中,我只想以JSON的形式返回列表。注释POJO中的属性是没有意义的,因为每个方法都有不同的返回规范······

  • TL;DR:如何选择一个WP REST API自定义endpoint的响应的每一点信息? 长版 如果我想使用WP REST API构建自定义endpoint - 从不同的帖子类型发送特定帖子数据 - 按照手册中的示例,我得到了这个: 但是get_post()函数没有返回一些数据,如果您希望在页面中显示帖子,这些数据是非常有用的(例如类别id、特色图片)。那么,我如何构建一个自定义endpoint来

  • 在Spring Boot控制器中,我使用检查用户是否登录(使用基本auth+)。 但是如果用户没有登录,即他们没有经过身份验证,控制器返回。 根据我对身份验证与授权的了解,用于身份验证,而用于授权。 根据我的理解,总是检查用户的授权(顾名思义),但是有什么方法可以根据我们传递给它的参数自定义它,即? 我知道还有另一种解决方案:在中使用基于URL的安全配置,但如果我不想这样做,该怎么办。 有什么想法

  • 改变json输出策略 默认使用阿里的fastjson进行json输出 JSON.toJSONString(obj) 如果要更换输出策略,操作方式如下: @Override protected void initApiConfig(ApiConfig apiConfig) { ... // 自定义json格式输出,将null字符串变成"" apiConfig.setJson

  • 网关默认对业务结果进行合并,然后返回统一的格式。 针对alipay.story.find接口,微服务端返回结果如下: { "name": "白雪公主", "id": 1, "gmtCreate": 1554193987378 } 网关合并后,最终结果如下 { "alipay_story_find_response": { "msg": "Succe

  • 问题内容: 我在做 是否可以将结果自动“解析”到“ POJO”列表? 这样我就可以做到这一点: 问题答案: 尝试 就像参考手册所建议的那样。