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

对于Azure servicebus jms spring boot starter,是否有属性设置在处理失败时请求消息?

傅献
2023-03-14

我正在使用azure-servicebus-jms-spring-boot-starter侦听来自Microsoft Azure队列的消息。Azure服务总线api有一个PEEKLOCK设置Azure.servicebus.subscription-receive-mode=PEEKLOCK,该设置在消息处理失败时请求消息。spring JMS侦听器是否有类似的设置?

共有1个答案

朱淮晨
2023-03-14

您可以指定服务总线接收消息的两种不同模式:receiveanddeletepeeklock

peeklock模式下,接收操作变成两个阶段,这使得支持不能容忍丢失消息的应用程序成为可能。

当服务总线接收到请求时,它会找到下一个要使用的消息,锁定它以防止其他使用者接收它,然后将它返回给应用程序。在应用程序完成对消息的处理(或可靠地存储消息以备将来处理)后,它通过对接收到的消息调用CompleteAsync来完成接收过程的第二阶段。当服务总线看到CompleteAsync调用时,它将消息标记为已消费。

 类似资料:
  • 类项目: hbm文件: 方法如下:

  • 我得到的。 这是我的密码: 我得到错误作为 2014年10月16日下午4:31:47 严重:Servlet。路径为[/CustomerPortal]的上下文中servlet[dispatcherServlet]的服务()引发了异常[Request processing failed;嵌套异常为java.lang.NumberFormatException:null],其根本原因为 当我运行这个项目

  • 这是我的同意模式 这是同意控制器获取声明 这是声明后的同意 同意html thymeleaf表单是 提交表格后。我得到这个错误 HTTP状态500-请求处理失败;嵌套异常是org.thymeleaf.exceptions.TemplateProcessing异常:异常评估SpringEL表达式:"user.providers"(提供者/createOrUpdateConentForm 组织。spr

  • 我在使用react native fetch api时遇到了一个问题。多次请求失败。我有一个高速连接。但很多次都失败了。这个问题发生在android和ios上。 作为post请求发送给服务器的数据

  • 我有一个spring boot应用程序与单个Kafka消费者从一些主题获取消息。但有时在处理消息时会出现错误。 我理解我需要禁用自动提交并手动提交成功的消息,但是,在这种情况下,如果我没有为这个异常情况抛出任何异常,并手动提交每个下一个成功的消息,那么我将丢失前一个不成功的消息,对吗?

  • 我有以下代码: 我想删除脚本,我尝试使用c: set与不同的范围,但它不起作用。是否可以使用JSTL标签设置请求属性? 我试过了,但没有成功: 而且还 之后有一个包括: 显然,在包含的JSP中,请求属性不可见。