grails - 使用RxJava在Grails 3中将RabbitMQ队列视为可观察到的

Question

有没有办法在Grails 3 Controller 或服务中使用RabbitMq，就像消费者是可观察者一样？
我的实际代码是这样的

def consumer
rx.stream { Subscriber subscriber ->
     consumer = new DefaultConsumer(channel) {
        @Override
        void handleDelivery(String consumerTag, Envelope envelope,
                            AMQP.BasicProperties properties, byte[] body) throws IOException {

            String message = new String(body, "UTF-8")                    
            subscriber.onNext(rx.render(message))

        }
    }
    channel.basicConsume(queueName, true, consumer)
}

但我真的不喜欢这种实现方式，我认为坚持Rx范例会更好。

Answer 1

您可以更改代码以在RabbitMQ端使用基于拉的模型而不是基于回调的模型吗？如果是，则可以使用SyncOnSubscribe轻松获取消息。