基于Kotlin的Spring RabbitListener在尝试发回`kotlin.Unit`时会产生无限循环
。这是因为在Kotlin中，Unit类型表示无返回值，而RabbitMQ的消息监听器默认会将返回值发送回消息队列。当尝试返回kotlin.Unit时，RabbitMQ会将其解释为需要将Unit类型的消息发送回队列，从而导致无限循环。
为了解决这个问题，可以采取以下几种方法：
- 返回其他类型的值：可以将返回类型修改为其他非
Unit类型，例如String、Boolean等，确保返回值不会被RabbitMQ误解为需要发送回队列。 - 使用
@RabbitHandler注解：可以在消息监听方法上添加@RabbitHandler注解，并指定一个特定的消息类型作为参数。这样，只有匹配指定消息类型的方法才会被调用，避免了无限循环的问题。 - 显式确认消息：可以在消息监听方法中手动确认消息的处理完成，而不返回任何值。这样，RabbitMQ就不会期望接收到返回值，也避免了无限循环的问题。
总结起来，基于Kotlin的Spring RabbitListener在尝试发回kotlin.Unit时会产生无限循环的问题可以通过修改返回类型、使用@RabbitHandler注解或显式确认消息来解决。具体选择哪种方法取决于实际需求和业务逻辑。
腾讯云相关产品和产品介绍链接地址：
相关·内容
我们有一个用Kotlin实现的RabbitListener。该方法返回Unit，所以我不希望Spring发送结果，但我们得到了以下错误消息。看起来Spring尝试将Unit作为结果进行iterprete，并发回一条兔消息： 2021-04-16 16:39:21
msg="Execution of Rabbit message listenerorg.springframework.amqp.rabbit.listener.adapter.ReplyFail
浏览 46提问于2021-04-16得票数 0
1回答
如何在中使用默认死信队列的消息？
、、、、
我将默认DLQ配置如下： cloud: rabbit: consumer:auto-bind-dlq: true dead-letter-queue-name: my-dlq
我想使用默认DLQ中的消息
浏览 0提问于2019-09-20得票数 1
回答已采纳
所以我一直在尝试使用Spring Cloud Contract来测试RabbitListener。到目前为止，我已经发现，通过在约定中定义"triggeredBy“，生成的测试将调用那里提供的方法，因此我们需要提供该方法在TestBase中做什么的实际实现。来源：和
我的问题是，有没有办法从契约中产生输入消息，而不是触发自己的自定义方法？可能类似于文档中的</em
浏览 7提问于2018-07-19得票数 0
回答已采纳
2回答
角度摘要循环
、、
我的应用程序有一个问题，因为它在尝试生成表单时会产生无限循环。我的表单是基于json生成的(代码中的示例)。只有当我转到另一个步骤并返回到表单时，才会发生问题。我不知道是什么导致了这个问题，因为它只在第二次加载状态时发生。有没有可能angular保留了在以前的状态下创建的观察器，并且它只是相互重叠？
浏览 0提问于2016-06-29得票数 1
在用Validator注释注释的任何Spring控制器方法之前调用我的拦截器。发行：
对于某些Spring控制器，我的RequestDispatcher的errorView导致请求被转发回同一个方法，导致无限循环(invoke()被一次又一次地调用)。我认为这是因为Spring控制器的请求映射(见下文)是如何设置的。它总是转发给‘doesn’方法，从而在MethodIntercep
浏览 7提问于2016-04-26得票数 5
我花了一整天的时间试着让它工作。我一直在遵循RabbitMQ tutorials页面中的Spring AMQP教程5和6。@RabbitListener(bindings = @QueueBinding(
value = @Queue(value = "requestspublic String func1(long id) {
浏览 0提问于2018-04-05得票数 1
在左边的菜单中，我将放置一个日历，其中将突出显示路由中提供的日期。 </IonPage> </IonReactRouter>我尝试过几种解决办法哪一个是最好的？
将所有内容放在IonRouterOutlet下面，即
浏览 5提问于2020-05-27得票数 0
1回答
我正在使用Spring与RabbitMQ一起创建应用程序。当我在方法getResendDisposalPayload中得到异常时，它侦听RESEND_DISPOSAL_QUEUE队列(例如，数据库中的临时问题)，兔子立即开始重新发送最后一个未处理的消息。它产生了大量的日志，出于某种原因，我的系统不舒服。
正如我在本文中所读到的，“同时使用死信队列是处理失败消息的标准方法”。为了使用这种模式，我创建了RetryOper
浏览 8提问于2021-10-16得票数 2
回答已采纳
我想在我的控制器响应中返回相同的请求头，但是如果我这样做了，那么在尝试使用postman进行测试时会出现无限等待。clientInput) {当我尝试用postman测试它时，这会导致无限的等待循环，我如何在响应中返回从我的
浏览 0提问于2020-12-22得票数 0
我目前正在开发一种流媒体服务，我想用它以更高效的方式在客户端上播放音频文件。为了做到这一点，我有一个端点，它返回一个StreamingRepsonseBody，并且只返回一个音频文件的请求字节。然而，在播放音频文件之后，我遇到了一个问题，就是对于我向服务器提出的任何请求都要获得一个CannotGetJdbcConnectionException (请在下面找到完整的堆栈跟踪)。异常(通常)在10个请求后抛出(我认为这也是打开连接的限制)。
我可以通过不
浏览 3提问于2020-09-14得票数 0
回答已采纳
3回答
目前，我有一个利用Spring-Hibernate和Jackson来处理JSON的项目。当我第一次尝试使用Jackson时，我总是会得到LazyInitializationException，有时会出现多个实体相互引用的无限循环。现在的问题是有时需要忽略属性，但有时我只需要这些属性是可序列化的。有没有办法有时忽略几个字段，有时在运行时序列化这些字段？例如：在page1中，我需要propertyA、propertyB、
浏览 1提问于2013-08-29得票数 0
1回答
有没有办法创建一个typedef来编译以下代码(y-组合器的一个基本的“纯”实现)？[](f x){x(x);} ([](f x){x(x);});
这产生了创建“递归lambda”的效果，即通过使用第二个lambda来获得对自身的引用来调用自身。第一个lambda中的x是对第二个lambda的引用，因此x(x)使用对其自身的引用来调用第二个lambda。此后，第二个lambda通过调用x(x)递归。此代码在</e
浏览 0提问于2013-03-12得票数 6
回答已采纳
这是我的上下文提供者。在组件中，我获取本地JSON数据。如果我控制日志数据，它就会产生objs数组。这很好。但是当我尝试使用setProfile(数据)的时候，这个应用程序就疯狂了。让我向您展示当我尝试用数据设置配置文件时会发生什么。
我假设这是一个无限的提取循环。老实说，我不确定为什么在我尝试setProfile(数据)时会发生这种情况。如果有别的
浏览 3提问于2021-09-18得票数 2
回答已采纳
我找到了this的帖子，里面也问了类似的问题。然而，答案并不是我所期望的，所以我将尝试以不同的方式来问它。让我们假设函数searching_for_connection将在while True循环中无限期运行。在该函数中，我们将循环并执行检查，以查看是否已使用/dev/ttyAMA0建立了新连接。如果该连接存在，则退出循环，完成searching_for_connection，然后开始一些其他进程。这是可能
浏览 11提问于2021-02-05得票数 1
回答已采纳
我有一个简单的应用程序，只有一个屏幕，在可组合项目列表中显示电影：
@Composable }为了将进度指示符添加到初始加载阶段(例如，正如在中解释的那样)，我尝试基于loadState.refresh应用以下条件fun FlixListScreen，而是将分页加载器放入一个无限循环中，在这个<em
浏览 5提问于2022-12-04得票数 1
我正在尝试编写一个延迟的seq来为给定的输入int生成。，这会产生无限的seqs： => (5 16 8 4 2 1 4 2 1 4)
我可以通过添加(take-while #(not= 1 %) ...)轻松地减少循环所有其他的方法，我一直认为，修剪后的循环是丑陋的，混淆了数学核心的Collatz序列。(我已经考虑过将可见值存
浏览 0提问于2018-08-08得票数 2
回答已采纳
3回答
在我的App.js中，我使用<PrivateRoute>保护了一些经过身份验证的页面，如下所示： <Dashboard />我是这样实现<PrivateRoute>的： return (
<Route
浏览 3提问于2021-05-02得票数 2
1回答
我正在尝试编写一个循环来吸引人们的Twitter追随者。因为Twitter一次只返回5K的追随者，所以这个循环应该对每个用户重复，直到它获得所有的追随者。因为Twitter有时会随机返回错误，所以它还应该在失败的情况下重试几次。
这是我目前的尝试，它产生了一个无限循环，但我不知道如何修复它。我很确定有一种更简单的方法来写它，我只是不知道它是什么。count=cou
浏览 0提问于2018-04-19得票数 0
我有一个Spring服务，它使用AMQP消息并为每条消息调用一个http资源。在http调用完成后，将调用另一个队列来报告错误或完成。只有这样，消息处理才能完成，下一条消息才会从队列中取出。我需要的是让我的amqp服务从队列中获取一定数量的消息，在单独的线程中处理它们，在每个线程中进行http调用，并返回带有"message“的消息。但是，从队列中获取的消息数量需要在该服务的多个实例之间共
浏览 3提问于2020-01-22得票数 0
云服务器
ICP备案
腾讯会议
云直播
对象存储
腾讯云开发者
