1

我正在尝试使用 RabbitMQ 插件,无论我做什么我都会得到一个 org.springframework.amqp.ImmediateAcknowledgeAmqpException: Recovered message force ack (如果 ack 模式需要它):...

我正在使用 AMQP 模板使用纯 Spring 应用程序发送 AMQP 消息,并尝试在 Grails 2.0.3 应用程序中处理消息。有什么我想念的吗?我能做些什么来摆脱这个错误?

亲切的问候,马可

4

1 回答 1

1

我有一个类似的问题。但后来我意识到我错误地命名了我的 handleMessage 方法。我的监听器类(我只是在学习!)现在看起来像这样,并且没有显示 ImmediateAcknowledgeAmqpException。

class ListenerService {

static rabbitQueue = 'sub'
    def handleMessage(message) {
        println "Message received"
    }
 }
于 2012-04-28T10:20:51.137 回答